Struct SqliteMemoryStore 

pub struct SqliteMemoryStore { /* private fields */ }

SQLite-backed memory store with FTS5 support.

Implementations

impl SqliteMemoryStore

pub async fn open(path: &Path, config: MnemoConfig) -> Result<Self>

Open or create a memory database at the given path.

Trait Implementations

impl MemoryStore for SqliteMemoryStore

fn name(&self) -> &str

Return the human-readable name of this memory backend.

fn ingest<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, role: &'life1 str, content: &'life2 str, token_count: usize, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

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

Ingest a new message into the store.

fn search<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryHit>>> + Send + 'async_trait>>

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

Full-text search across all stored messages and summaries.

fn get_context<'life0, 'async_trait>( &'life0 self, max_tokens: usize, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

Generate context string for agent bootstrap.

fn get_context_entries<'life0, 'async_trait>( &'life0 self, max_tokens: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryEntry>>> + Send + 'async_trait>>

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

Get recent context entries for the agent.

fn compact<'life0, 'life1, 'async_trait>( &'life0 self, summarizer: &'life1 dyn Summarizer, ) -> Pin<Box<dyn Future<Output = Result<CompactionStats>> + Send + 'async_trait>>

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

Run compaction if thresholds are exceeded.

fn message_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Return total message count (including compacted).

fn summary_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Return total summary count.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Flush any buffered data to persistent storage.