Struct MemoryDatabase 

pub struct MemoryDatabase { /* private fields */ }

Database connection manager

Implementations

impl MemoryDatabase

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

Initialize or open the memory database

pub async fn validate_vector_tables(&self) -> MemoryResult<()>

Validate that sqlite-vec tables are readable. This catches legacy/corrupted vector blobs early so startup can recover.

pub async fn ensure_vector_tables_healthy(&self) -> MemoryResult<bool>

Ensure vector tables are readable and recreate them if corruption is detected. Returns true when a repair was performed.

pub async fn store_chunk( &self, chunk: &MemoryChunk, embedding: &[f32], ) -> MemoryResult<()>

Store a chunk with its embedding

pub async fn search_similar( &self, query_embedding: &[f32], tier: MemoryTier, project_id: Option<&str>, session_id: Option<&str>, limit: i64, ) -> MemoryResult<Vec<(MemoryChunk, f64)>>

Search for similar chunks

pub async fn get_session_chunks( &self, session_id: &str, ) -> MemoryResult<Vec<MemoryChunk>>

Get chunks by session ID

pub async fn get_project_chunks( &self, project_id: &str, ) -> MemoryResult<Vec<MemoryChunk>>

Get chunks by project ID

pub async fn get_global_chunks( &self, limit: i64, ) -> MemoryResult<Vec<MemoryChunk>>

Get global chunks

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

Clear session memory

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

Clear project memory

pub async fn cleanup_old_sessions( &self, retention_days: i64, ) -> MemoryResult<u64>

Clear old session memory based on retention policy

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

Get or create memory config for a project

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

Update memory config for a project

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

Get memory statistics

pub async fn log_cleanup( &self, cleanup_type: &str, tier: MemoryTier, project_id: Option<&str>, session_id: Option<&str>, chunks_deleted: i64, bytes_reclaimed: i64, ) -> MemoryResult<()>

Log cleanup operation

pub async fn vacuum(&self) -> MemoryResult<()>

Vacuum the database to reclaim space

pub async fn project_file_index_count( &self, project_id: &str, ) -> MemoryResult<i64>

pub async fn project_has_file_chunks( &self, project_id: &str, ) -> MemoryResult<bool>

pub async fn get_file_index_entry( &self, project_id: &str, path: &str, ) -> MemoryResult<Option<(i64, i64, String)>>

pub async fn upsert_file_index_entry( &self, project_id: &str, path: &str, mtime: i64, size: i64, hash: &str, ) -> MemoryResult<()>

pub async fn delete_file_index_entry( &self, project_id: &str, path: &str, ) -> MemoryResult<()>

pub async fn list_file_index_paths( &self, project_id: &str, ) -> MemoryResult<Vec<String>>

pub async fn delete_project_file_chunks_by_path( &self, project_id: &str, source_path: &str, ) -> MemoryResult<(i64, i64)>

pub async fn upsert_project_index_status( &self, project_id: &str, total_files: i64, processed_files: i64, indexed_files: i64, skipped_files: i64, errors: i64, ) -> MemoryResult<()>

pub async fn get_project_stats( &self, project_id: &str, ) -> MemoryResult<ProjectMemoryStats>

pub async fn clear_project_file_index( &self, project_id: &str, vacuum: bool, ) -> MemoryResult<ClearFileIndexResult>