Struct FileMemoryStore 

pub struct FileMemoryStore { /* private fields */ }

Storage and query engine for file memories

Implementations

impl FileMemoryStore

pub fn cf_descriptors() -> Vec<ColumnFamilyDescriptor>

Return CF descriptors needed by this store. The caller must include these when opening the shared RocksDB instance.

pub fn new(db: Arc<DB>, storage_path: &Path) -> Result<Self>

Create a new file memory store backed by a shared DB that already contains the required column families (files, file_index).

pub fn with_config(self, config: CodebaseConfig) -> Self

Set custom configuration

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

Flush all column families to disk (critical for graceful shutdown)

pub fn databases(&self) -> Vec<(&str, &Arc<DB>)>

Get references to all RocksDB databases for backup

pub fn store(&self, file_memory: &FileMemory) -> Result<()>

Store a new file memory

pub fn get( &self, user_id: &str, file_id: &FileMemoryId, ) -> Result<Option<FileMemory>>

Get a file memory by ID

pub fn get_by_path( &self, user_id: &str, project_id: &ProjectId, path: &str, ) -> Result<Option<FileMemory>>

Get a file memory by path (relative path within project)

pub fn update(&self, file_memory: &FileMemory) -> Result<()>

Update a file memory

pub fn delete(&self, user_id: &str, file_id: &FileMemoryId) -> Result<bool>

Delete a file memory

pub fn delete_project_files( &self, user_id: &str, project_id: &ProjectId, ) -> Result<usize>

Delete all file memories for a project

pub fn list_by_user( &self, user_id: &str, limit: Option<usize>, ) -> Result<Vec<FileMemory>>

List all file memories for a user

pub fn list_by_project( &self, user_id: &str, project_id: &ProjectId, limit: Option<usize>, ) -> Result<Vec<FileMemory>>

List all file memories for a project

pub fn list_by_type( &self, user_id: &str, project_id: &ProjectId, file_type: &FileType, limit: Option<usize>, ) -> Result<Vec<FileMemory>>

List file memories by type

pub fn count_by_project( &self, user_id: &str, project_id: &ProjectId, ) -> Result<usize>

Get file count for a project

pub fn record_access( &self, user_id: &str, project_id: &ProjectId, path: &str, learned_from: LearnedFrom, ) -> Result<Option<FileMemory>>

Record an access to a file (increments counter, updates timestamp)

pub fn scan_codebase( &self, codebase_path: &Path, config: Option<&CodebaseConfig>, ) -> Result<CodebaseScanResult>

Scan a directory and return eligible files for indexing

pub fn hash_file_content(content: &[u8]) -> String

Compute SHA256 hash of file content

pub fn index_file( &self, codebase_root: &Path, relative_path: &str, project_id: &ProjectId, user_id: &str, ) -> Result<FileMemory>

Index a single file: read, hash, count lines, detect type, extract key items

pub fn index_file_with_embedding<E: Embedder>( &self, codebase_root: &Path, relative_path: &str, project_id: &ProjectId, user_id: &str, embedder: &E, ) -> Result<FileMemory>

Index a single file and generate embedding

pub fn index_codebase( &self, codebase_root: &Path, project_id: &ProjectId, user_id: &str, config: Option<&CodebaseConfig>, ) -> Result<IndexingResult>

Index all files in a codebase (blocking version)

pub fn index_codebase_with_embeddings<E: Embedder>( &self, codebase_root: &Path, project_id: &ProjectId, user_id: &str, embedder: &E, config: Option<&CodebaseConfig>, progress_callback: Option<&dyn Fn(IndexingProgress)>, ) -> Result<IndexingResult>

Index codebase with embeddings (requires embedder)

pub fn stats(&self, user_id: &str) -> Result<FileMemoryStats>

Get statistics for file memories