Struct LocalCoreStateStore 

pub struct LocalCoreStateStore { /* private fields */ }

One journaled private namespace shared by core control-plane state.

Implementations

impl LocalCoreStateStore

pub fn new(root: impl Into<PathBuf>) -> Self

Opens a private companion namespace below root.

Directories are created lazily on first mutation.

pub fn root(&self) -> &Path

Returns the namespace root.

pub async fn materialization_operations_async( &self, ) -> Result<Vec<OperationId>, LocalCoreStateStoreError>

Lists durable materialization journals without blocking an async executor.

pub async fn remove_materialization_async( &self, operation_id: OperationId, ) -> Result<(), LocalCoreStateStoreError>

Removes a terminal journal without blocking an async executor.

Trait Implementations

impl Clone for LocalCoreStateStore

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LocalCoreStateStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl GitCompatStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Adapter error.

async fn load( &self, workspace_id: WorkspaceId, ) -> Result<Option<GitCompatState>, Self::Error>

Loads state for one repository/workspace identity.

async fn compare_and_swap( &self, workspace_id: WorkspaceId, expected_revision: u64, replacement: GitCompatState, ) -> Result<bool, Self::Error>

Atomically replaces one expected revision. Revision zero creates state.

async fn compare_and_delete( &self, workspace_id: WorkspaceId, expected_revision: u64, ) -> Result<bool, Self::Error>

Atomically removes one exact compatibility-state revision.

impl LazyWorkspaceStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Backend error.

fn load_lazy_workspace<'life0, 'async_trait>( &'life0 self, workspace_id: WorkspaceId, ) -> Pin<Box<dyn Future<Output = Result<Option<LazyWorkspaceState>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads one workspace binding.

fn compare_and_swap_lazy_workspace<'life0, 'async_trait>( &'life0 self, workspace_id: WorkspaceId, expected_revision: u64, replacement: LazyWorkspaceState, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replaces one binding only at the expected revision (0 means absent).

fn load_lazy_overlay<'life0, 'async_trait>( &'life0 self, overlay: LazyOverlayId, ) -> Pin<Box<dyn Future<Output = Result<Option<LazyOverlay>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads an immutable content-addressed overlay.

fn put_lazy_overlay<'life0, 'async_trait>( &'life0 self, overlay: LazyOverlayId, value: LazyOverlay, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores an immutable overlay, idempotently rejecting digest mismatches.

fn load_lazy_shadow<'life0, 'async_trait>( &'life0 self, shadow: LazyShadowId, ) -> Pin<Box<dyn Future<Output = Result<Option<LazyShadow>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads one immutable source-identity shadow node.

fn put_lazy_shadow<'life0, 'async_trait>( &'life0 self, shadow: LazyShadowId, value: LazyShadow, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores one immutable source-identity shadow node.

fn load_lazy_workspace_measured<'life0, 'life1, 'async_trait>( &'life0 self, workspace_id: WorkspaceId, budget: WorkBudget, cancellation: &'life1 CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<OperationReceipt<Option<LazyWorkspaceState>>, LazyWorkspaceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads one binding under an explicit logical durable-read budget.

fn compare_and_swap_lazy_workspace_measured<'life0, 'life1, 'async_trait>( &'life0 self, workspace_id: WorkspaceId, expected_revision: u64, replacement: LazyWorkspaceState, budget: WorkBudget, cancellation: &'life1 CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<OperationReceipt<bool>, LazyWorkspaceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replaces one binding under an explicit logical durable-write budget.

fn load_lazy_overlay_measured<'life0, 'life1, 'async_trait>( &'life0 self, overlay: LazyOverlayId, budget: WorkBudget, cancellation: &'life1 CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<OperationReceipt<Option<LazyOverlay>>, LazyWorkspaceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads one immutable overlay under an explicit logical read budget.

fn load_lazy_shadow_measured<'life0, 'life1, 'async_trait>( &'life0 self, shadow: LazyShadowId, budget: WorkBudget, cancellation: &'life1 CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<OperationReceipt<Option<LazyShadow>>, LazyWorkspaceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads one immutable shadow under an explicit logical read budget.

impl MaterializationJournalStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Adapter error.

async fn load( &self, operation_id: OperationId, ) -> Result<Option<MaterializationJournal>, Self::Error>

Loads one operation journal.

async fn compare_and_swap( &self, operation_id: OperationId, expected_revision: u64, replacement: MaterializationJournal, ) -> Result<bool, Self::Error>

Atomically replaces expected_revision; zero creates a journal.

impl MultiRootPublicationStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Adapter error.

async fn load( &self, operation_id: OperationId, ) -> Result<Option<MultiRootPublication>, Self::Error>

Loads one operation record.

async fn compare_and_swap( &self, operation_id: OperationId, expected_revision: u64, replacement: MultiRootPublication, ) -> Result<bool, Self::Error>

Atomically replaces one expected revision; zero creates the record.

async fn list_operations(&self) -> Result<Vec<OperationId>, Self::Error>

Lists durable operations that may require restart recovery.

async fn compare_and_delete( &self, operation_id: OperationId, expected_revision: u64, ) -> Result<bool, Self::Error>

Removes a terminal record only when its exact revision still matches. Failed physical cleanup leaves the record intact for restart recovery.

async fn claim_parent( &self, parent_context_id: WorkspaceContextId, operation_id: OperationId, ) -> Result<bool, Self::Error>

Atomically claims the one publication slot for a parent context.

async fn release_parent( &self, parent_context_id: WorkspaceContextId, operation_id: OperationId, ) -> Result<bool, Self::Error>

Releases the exact parent claim after terminal cleanup.

impl WorkspaceContextStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Adapter error.

async fn load( &self, context_id: WorkspaceContextId, ) -> Result<Option<WorkspaceContext>, Self::Error>

Loads one context, if registered.

async fn list(&self) -> Result<Vec<WorkspaceContext>, Self::Error>

Lists all durable contexts. Records are small and this is used only for routing, recursive discard, and recovery—not filesystem indexing.

async fn compare_and_swap( &self, context_id: WorkspaceContextId, expected_revision: u64, replacement: WorkspaceContext, ) -> Result<bool, Self::Error>

Atomically replaces expected_revision; zero creates a context.

async fn compare_and_swap_many( &self, expected_revisions: BTreeMap<WorkspaceContextId, u64>, replacements: Vec<WorkspaceContext>, require_exact_set: bool, ) -> Result<bool, Self::Error>

Atomically verifies every listed revision and replaces the supplied records. Expected revision zero means that context must be absent.

async fn discard_subtree( &self, parent: WorkspaceContextId, child: WorkspaceContextId, maximum: u32, ) -> Result<WorkspaceContextDiscardOutcome, Self::Error>

Atomically validates and tombstones one direct-child subtree.

impl WorkspaceLineageStore for LocalCoreStateStore

type Error = LocalCoreStateStoreError

Adapter error.

async fn load( &self, workspace_id: WorkspaceId, ) -> Result<Option<WorkspaceLineageRecord>, Self::Error>

Loads the record for one workspace, if registered.

async fn compare_and_swap( &self, workspace_id: WorkspaceId, expected_revision: u64, replacement: WorkspaceLineageRecord, ) -> Result<bool, Self::Error>

Atomically replaces expected_revision; zero creates a record.