Struct MemoryManager 

pub struct MemoryManager { /* private fields */ }

High-level memory manager that coordinates database, embeddings, and chunking

Implementations

impl MemoryManager

pub fn db(&self) -> &Arc<MemoryDatabase>

pub async fn new(db_path: &Path) -> MemoryResult<Self>

Initialize the memory manager

pub async fn store_message( &self, request: StoreMessageRequest, ) -> MemoryResult<Vec<String>>

Store a message in memory

This will:

1. Chunk the message content
2. Generate embeddings for each chunk
3. Store chunks and embeddings in the database

pub async fn search( &self, query: &str, tier: Option<MemoryTier>, project_id: Option<&str>, session_id: Option<&str>, limit: Option<i64>, ) -> MemoryResult<Vec<MemorySearchResult>>

Search memory for relevant chunks

pub async fn retrieve_context( &self, query: &str, project_id: Option<&str>, session_id: Option<&str>, token_budget: Option<i64>, ) -> MemoryResult<MemoryContext>

Retrieve context for a message

This retrieves relevant chunks from all tiers and formats them for injection into the prompt

pub async fn retrieve_context_with_meta( &self, query: &str, project_id: Option<&str>, session_id: Option<&str>, token_budget: Option<i64>, ) -> MemoryResult<(MemoryContext, MemoryRetrievalMeta)>

Retrieve context plus retrieval metadata for observability.

pub async fn clear_session(&self, session_id: &str) -> MemoryResult<u64>

Clear session memory

pub async fn clear_project(&self, project_id: &str) -> MemoryResult<u64>

Clear project memory

pub async fn get_stats(&self) -> MemoryResult<MemoryStats>

Get memory statistics

pub async fn get_config(&self, project_id: &str) -> MemoryResult<MemoryConfig>

Get memory configuration for a project

pub async fn set_config( &self, project_id: &str, config: &MemoryConfig, ) -> MemoryResult<()>

Update memory configuration for a project

pub async fn run_cleanup(&self, project_id: Option<&str>) -> MemoryResult<u64>

Run cleanup based on retention policies

pub async fn get_cleanup_log( &self, _limit: i64, ) -> MemoryResult<Vec<CleanupLogEntry>>

Get cleanup log entries

pub fn count_tokens(&self, text: &str) -> usize

Count tokens in text

pub async fn embedding_health(&self) -> EmbeddingHealth

Report embedding backend health for UI/telemetry.

pub async fn consolidate_session( &self, session_id: &str, project_id: Option<&str>, providers: &ProviderRegistry, config: &MemoryConsolidationConfig, ) -> MemoryResult<Option<String>>

Consolidate a session’s memory into a summary chunk using the cheapest available provider.