Enum SelectedMemoryStore 

pub enum SelectedMemoryStore {
    Local(LocalMemoryStore),
    Remote(RemoteMemoryClient),
}

Runtime-selected local-or-remote memory backend.

Variants

Local(LocalMemoryStore)

Private local SQLite storage.

Remote(RemoteMemoryClient)

Authenticated namespaced HTTP storage.

Implementations

impl SelectedMemoryStore

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

Selects a private local SQLite backend.

pub const fn remote(client: RemoteMemoryClient) -> Self

Selects an authenticated remote HTTP backend.

pub const fn source(&self) -> MemorySource

Returns the selected backend kind without performing I/O.

pub async fn access(&self) -> Result<MemoryAccess, MemoryError>

Returns backend provenance and negotiated remote authorization.

Trait Implementations

impl Clone for SelectedMemoryStore

fn clone(&self) -> SelectedMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SelectedMemoryStore

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

Formats the value using the given formatter.

impl MemoryStore for SelectedMemoryStore

Available on crate features client and local only.

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 window that excludes expired probationary records.

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.