Struct TursoStorage 

pub struct TursoStorage { /* private fields */ }

Turso-backed implementation of crate::traits::ContextStorage.

Implementations

impl TursoStorage

pub async fn open(db_path: &Path, max_entries: usize) -> Result<Self>

Open (or create) a turso database at db_path and run migrations.

Rebuilds the in-memory tantivy FTS index from all existing entries so BM25 corpus statistics are accurate from the first query.

Errors

Returns an error if the database cannot be opened or migrations fail.

Trait Implementations

impl ContextStorage for TursoStorage

fn save<'life0, 'life1, 'async_trait>( &'life0 self, entry: &'life1 ContextEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Persist a single entry.

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

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

Return the top-k entries (most recent or highest priority).

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

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

Return every stored entry.

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

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

Delete an entry by id. Returns true if an entry was removed.

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

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

Remove all entries. Returns the number of entries removed.

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

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

Remove all entries within a given scope. Returns the number of entries removed.

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

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

Return the total number of stored entries.

fn save_embedding<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, embedding: &'life2 [f32], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Persist a dense embedding vector for an already-saved entry.

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

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

Return entries that do not yet have an embedding stored.