Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Agent memory store: write-time lexical recall + async enrichment queue.

Implementations

impl MemoryStore

pub fn embedder(&self) -> &Arc<dyn EmbeddingProvider>

pub fn enrich_episode(&self, job: &EnrichmentJob) -> Result<(), String>

Embed an episode and store its vector for semantic retrieval.

pub fn drain_enrichment_queue(&self) -> usize

Drain all pending enrichment jobs synchronously (tests / bench warmup).

pub fn search_vector( &self, namespace: &str, query: &str, k: usize, ) -> Vec<(u64, f32)>

Vector lane search over enriched episodes (brute-force; tuned for agent-memory scale).

pub fn enriched_episode_count(&self, namespace: &str) -> usize

impl MemoryStore

pub fn query(&self, q: &MemoryQuery) -> MemoryQueryResult

Three-lane fusion: BM25 + trigram (+ vector when enriched).

impl MemoryStore

pub fn new(_data_dir: Option<&Path>, config: MemoryStoreConfig) -> Self

pub fn with_embedder( _data_dir: Option<&Path>, config: MemoryStoreConfig, embedder: Arc<dyn EmbeddingProvider>, ) -> Self

pub fn with_defaults() -> Self

pub fn enrichment_queue(&self) -> &EnrichmentQueue

pub fn write_episode(&self, write: EpisodeWrite) -> MemoryResult<WriteResult>

Write episode: lexical lanes indexed synchronously; enrichment queued async.

pub fn get_episode( &self, namespace: &str, id: EpisodeId, ) -> MemoryResult<Episode>

pub fn namespace_bm25(&self, namespace: &str) -> Option<Arc<InvertedIndex>>

pub fn search_bm25( &self, namespace: &str, query: &str, k: usize, ) -> Vec<(u64, f32)>

pub fn search_trigram_literal( &self, namespace: &str, literal: &str, k: usize, ) -> Vec<(u64, f32)>

pub fn episode_text(&self, namespace: &str, doc_id: u64) -> Option<String>

pub fn add_fact(&self, namespace: &str, fact: FactEdge) -> MemoryResult<FactId>

pub fn facts_valid_at(&self, namespace: &str, tau: u64) -> Vec<FactEdge>

pub fn invalidate_fact( &self, namespace: &str, fact_id: FactId, t_invalid: u64, ) -> bool

pub fn episode_count(&self, namespace: &str) -> usize