Struct MemoryDatabase 

pub struct MemoryDatabase {
    pub conversations: ConversationStore,
    pub embeddings: EmbeddingStore,
    pub local_files: LocalFilesStore,
    pub all_files: AllFilesStore,
    pub api_keys: ApiKeysStore,
    pub users: UsersStore,
    pub session_file_contexts: SessionFileContextsStore,
    pub session_summaries: SessionSummariesStore,
    /* private fields */
}

Main database manager that coordinates all stores

Fields

conversations: ConversationStore

embeddings: EmbeddingStore

local_files: LocalFilesStore

all_files: AllFilesStore

api_keys: ApiKeysStore

users: UsersStore

session_file_contexts: SessionFileContextsStore

session_summaries: SessionSummariesStore

Implementations

impl MemoryDatabase

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

Create a new memory database at the specified path

pub fn new_in_memory() -> Result<Self>

Create an in-memory database (useful for testing)

pub fn begin_transaction(&self) -> Result<Transaction<'_>>

Begin a transaction for atomic operations

pub fn with_transaction<T, F>(&self, f: F) -> Result<T>

where F: FnOnce(&mut Transaction<'_>) -> Result<T>,

Execute operations in a transaction

pub fn get_stats(&self) -> Result<DatabaseStats>

Get database statistics

pub fn cleanup_old_data(&self, older_than_days: i32) -> Result<usize>

Cleanup old data (older than specified days)

pub async fn create_kv_snapshot( &self, session_id: &str, entries: &[KVEntry], ) -> Result<i64>

Create a KV snapshot

pub async fn get_recent_kv_snapshots( &self, session_id: &str, limit: usize, ) -> Result<Vec<KvSnapshot>>

Get recent KV snapshots for a session

pub async fn get_kv_snapshot_entries( &self, snapshot_id: i64, ) -> Result<Vec<KVEntry>>

Get KV snapshot entries

pub async fn search_messages_by_keywords( &self, session_id: &str, keywords: &[String], limit: usize, ) -> Result<Vec<StoredMessage>>

Search messages by keywords (for ConversationStore)

pub async fn update_kv_cache_metadata( &self, session_id: &str, state: &SessionCacheState, ) -> Result<()>

Update KV cache metadata

pub async fn cleanup_session_snapshots(&self, session_id: &str) -> Result<()>

Cleanup session snapshots

pub async fn prune_old_kv_snapshots(&self, keep_max: usize) -> Result<usize>

Prune old KV snapshots

pub fn optimize(&self) -> Result<()>

Run SQLite maintenance: update query planner statistics and truncate the WAL file.

PRAGMA optimize lets SQLite decide when to run ANALYZE — safe to call at any time. PRAGMA wal_checkpoint(TRUNCATE) flushes the WAL to the main DB file and resets the WAL to zero bytes, reclaiming disk space after heavy write sessions.

Trait Implementations

impl Drop for MemoryDatabase

fn drop(&mut self)

Executes the destructor for this type.