Struct MemoryBus 

pub struct MemoryBus { /* private fields */ }

Central memory facade used by the runtime.

Implementations

impl MemoryBus

pub fn builder(config: VolatileConfig) -> MemoryBusBuilder

Creates a builder for a memory bus.

pub fn volatile(&self) -> &Arc<VolatileMemory>

Returns the underlying volatile store.

pub fn journal(&self) -> &Arc<dyn Journal>

Returns the configured journal.

pub fn vector_store(&self) -> Option<&Arc<dyn VectorStoreClient>>

Returns the configured vector store, if present.

pub async fn record(&self, record: MemoryRecord) -> MemoryResult<()>

Persists a record across all configured stores.

Errors

Returns MemoryError when writing to the journal or vector store fails.

pub async fn recent(&self, limit: usize) -> Vec<MemoryRecord>

Returns recent records from volatile memory.

pub async fn journal_tail( &self, limit: usize, ) -> MemoryResult<Vec<MemoryRecord>>

Reads the tail of the journal.

Errors

Returns MemoryError when reading or decoding entries from the journal fails.

pub async fn recall(&self, query: VectorQuery) -> MemoryResult<Vec<VectorMatch>>

Queries the configured vector store.

Errors

Returns MemoryError::MissingVectorStore when the bus was not initialised with a vector store implementation.

pub async fn stats(&self) -> VolatileStats

Returns utilisation statistics for the volatile store.

Trait Implementations

impl Clone for MemoryBus

fn clone(&self) -> MemoryBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.