Struct LocalMemoryStore 

pub struct LocalMemoryStore { /* private fields */ }

Concrete private SQLite memory store.

Implementations

impl LocalMemoryStore

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

Opens or creates a private local SQLite store at path on first use.

pub async fn merge_remote_export( &self, memories: Vec<MemoryRecord>, ) -> Result<MemoryImportReport, MemoryError>

Imports a validated remote snapshot into a local store as new probationary records.

Trait Implementations

impl Clone for LocalMemoryStore

fn clone(&self) -> LocalMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalMemoryStore

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

Formats the value using the given formatter.

impl MemoryStore for LocalMemoryStore

fn scan( &self, query: &str, limit: usize, ) -> impl Future<Output = Result<MemoryScan, MemoryError>> + Send

Searches visible records and records scan telemetry.

fn read( &self, ids: &[i64], keys: &[MemoryKey], ) -> impl Future<Output = Result<Vec<MemoryRecord>, MemoryError>> + Send

Reads unversioned IDs and versioned keys, recording use telemetry.

fn list( &self, ) -> impl Future<Output = Result<Vec<MemoryRecord>, MemoryError>> + Send

Lists a deterministic visible window after pruning probation.

fn put( &self, content: &str, replacement: Option<MemoryKey>, ) -> impl Future<Output = Result<MemoryRecord, MemoryError>> + Send

Inserts content or compare-and-swap replaces replacement.

fn delete( &self, key: MemoryKey, ) -> impl Future<Output = Result<(), MemoryError>> + Send

Compare-and-swap deletes key.

fn sync( &self, memories: &[MemoryRecord], ) -> impl Future<Output = Result<SyncReport, MemoryError>> + Send

Atomically applies an authoritative full snapshot to the owned namespace.

fn export_page( &self, _namespaces: Option<&[String]>, cursor: Option<&ExportCursor>, limit: usize, ) -> impl Future<Output = Result<(Vec<MemoryRecord>, Option<ExportCursor>), MemoryError>> + Send

Exports one page in stable (namespace, id) order after cursor.

fn export_all( &self, namespaces: Option<&[String]>, ) -> impl Future<Output = Result<Vec<MemoryRecord>, MemoryError>> + Send

Collects a complete bounded export through the paginated storage contract.