Struct PersistentFileStorage 

pub struct PersistentFileStorage { /* private fields */ }

File-backed DocumentStorage that snapshots an in-memory store to a JSON file on every write. Construction reads any prior snapshot back.

Implementation note: delegates all read paths to the wrapped InMemoryStorage so cosine-similarity search etc. stays identical. Only store_chunks / delete_documents / clear_all rewrite the snapshot — read-only ops stay zero-IO.

Implementations

impl PersistentFileStorage

pub fn new(dir: PathBuf) -> Result<Self>

Create a persistent file storage at <dir>/storage.json. Reads any existing snapshot at construction time.

Trait Implementations

impl DocumentStorage for PersistentFileStorage

fn store_chunks<'life0, 'async_trait>( &'life0 self, chunks: Vec<DocumentChunk>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Store document chunks

fn search_similar<'life0, 'life1, 'async_trait>( &'life0 self, query_embedding: &'life1 [f32], top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<DocumentChunk>>> + Send + 'async_trait>>

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

Search for similar chunks

fn search_with_params<'life0, 'life1, 'async_trait>( &'life0 self, query_embedding: &'life1 [f32], params: SearchParams, ) -> Pin<Box<dyn Future<Output = Result<Vec<DocumentChunk>>> + Send + 'async_trait>>

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

Search with custom parameters

fn get_chunk<'life0, 'life1, 'async_trait>( &'life0 self, chunk_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<DocumentChunk>>> + Send + 'async_trait>>

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

Get chunk by ID

fn delete_chunk<'life0, 'life1, 'async_trait>( &'life0 self, chunk_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Delete chunk by ID

fn get_chunks_by_document<'life0, 'life1, 'async_trait>( &'life0 self, document_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<DocumentChunk>>> + Send + 'async_trait>>

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

Get chunks by document ID

fn delete_document<'life0, 'life1, 'async_trait>( &'life0 self, document_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Delete all chunks for a document

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

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

Get storage statistics

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

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

List all document IDs

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

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

Get total number of chunks

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

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

Clear all data

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

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

Optimize storage (rebuild indexes, compact data)

fn create_backup<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Create backup

fn restore_backup<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Restore from backup

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

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

Check storage health