Struct RemoteMemoryClient 

pub struct RemoteMemoryClient { /* private fields */ }

Authenticated HTTP implementation of MemoryStore.

Implementations

impl RemoteMemoryClient

pub fn new( endpoint: &str, namespace: String, token: RemoteToken, ) -> Result<Self, RemoteClientError>

Creates a client bound to one validated namespace.

pub fn namespace(&self) -> &str

Returns the configured namespace without network I/O.

pub async fn session(&self) -> Result<RemoteRole, RemoteClientError>

Negotiates and caches the authenticated remote role.

Trait Implementations

impl Clone for RemoteMemoryClient

fn clone(&self) -> RemoteMemoryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteMemoryClient

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

Formats the value using the given formatter.

impl MemoryStore for RemoteMemoryClient

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.