Struct CompositeContextStore 

pub struct CompositeContextStore { /* private fields */ }

The both backend: a local (aria memo) store plus a cloud store.

• memorize writes to both (local first, so an offline write still lands); a single-side failure is logged and tolerated — only a total failure returns an error.
• recall queries both, merges, dedupes and re-ranks with the shared rank scoring so ordering matches a single-backend run.
• get_by_key prefers the cloud copy and falls back to local.

Implementations

impl CompositeContextStore

pub fn new( local: Arc<dyn ContextStore>, cloud: Arc<dyn ContextStore>, ) -> Arc<Self>

pub fn local(&self) -> &Arc<dyn ContextStore>

pub fn cloud(&self) -> &Arc<dyn ContextStore>

Trait Implementations

impl ContextStore for CompositeContextStore

fn memorize<'life0, 'async_trait>( &'life0 self, frag: ContextFragment, ) -> Pin<Box<dyn Future<Output = Result<(), ContextError>> + Send + 'async_trait>>

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

Persist a fragment.

fn recall<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 RecallQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<ContextFragment>, ContextError>> + Send + 'async_trait>>

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

Retrieve the most relevant fragments for a query.

fn compact<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ContextFragment, ContextError>> + Send + 'async_trait>>

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

Merge a session’s fragments into a single compact fragment.

fn get_by_key<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ContextFragment>, ContextError>> + Send + 'async_trait>>

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

Lookup an explicit long-term memory by key (used by SDK recall).

fn list_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 str, top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<ContextFragment>, ContextError>> + Send + 'async_trait>>

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

Every fragment of a session, oldest first (used by compact and by the session memory listing).