Struct FileMemoryRepository 

pub struct FileMemoryRepository { /* private fields */ }

Durable local repository backed by a checksummed write-ahead journal.

One live instance owns a repository directory at a time. Mutations are validated before they are appended and synced; only then are they published to the in-memory read view. A restart deterministically replays the journal.

Implementations

impl FileMemoryRepository

pub async fn open(root: impl AsRef<Path>) -> Result<Self, MemoryRepositoryError>

Trait Implementations

impl Clone for FileMemoryRepository

fn clone(&self) -> FileMemoryRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileMemoryRepository

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

Formats the value using the given formatter.

impl MemoryRepository for FileMemoryRepository

fn apply<'life0, 'async_trait>( &'life0 self, change_set: MemoryChangeSet, ) -> Pin<Box<dyn Future<Output = Result<MemoryChangeResult, MemoryRepositoryError>> + Send + 'async_trait>>

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

Atomically apply a bounded, revision-checked change set.

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 MemoryNamespace, node_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<MemoryNode>, MemoryRepositoryError>> + Send + 'async_trait>>

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

Read one node from an exact namespace without recording access.

fn query<'life0, 'async_trait>( &'life0 self, query: MemoryQuery, ) -> Pin<Box<dyn Future<Output = Result<MemoryQueryResult, MemoryRepositoryError>> + Send + 'async_trait>>

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

Query one exact namespace without mutating repository state.

fn snapshot_namespace<'life0, 'async_trait>( &'life0 self, request: MemorySnapshotRequest, ) -> Pin<Box<dyn Future<Output = Result<MemoryNamespaceSnapshot, MemoryRepositoryError>> + Send + 'async_trait>>

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

Capture one complete, bounded, deterministic namespace view.

fn namespace_change_token<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 MemoryNamespace, ) -> Pin<Box<dyn Future<Output = Result<Option<MemoryNamespaceChangeToken>, MemoryRepositoryError>> + Send + 'async_trait>>

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

Return an optional exact-namespace change token.

fn record_admission<'life0, 'async_trait>( &'life0 self, event: MemoryAccessEvent, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryRepositoryError>> + Send + 'async_trait>>

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

Record that the host admitted the current active node revision into a model context.

fn record_use<'life0, 'async_trait>( &'life0 self, event: MemoryAccessEvent, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryRepositoryError>> + Send + 'async_trait>>

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

Record that the host cited, selected, or otherwise used a node.

fn usage_summary<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 MemoryNamespace, node_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<MemoryUsageSummary, MemoryRepositoryError>> + Send + 'async_trait>>

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

Return explicit admission and use counts for a node.