Struct SqliteStore 

pub struct SqliteStore {
    pool: SqlitePool,
}

SQLite implementation of the Store trait.

Wraps a [SqlitePool] and translates every Store method into one or more SQL statements against the existing schema (documents, chunks, chunks_fts, chunk_vectors, embeddings).

Fields

pool: SqlitePool

Implementations

impl SqliteStore

pub fn new(pool: SqlitePool) -> Self

pub fn pool(&self) -> &SqlitePool

Trait Implementations

impl Store for SqliteStore

fn upsert_document<'life0, 'life1, 'async_trait>( &'life0 self, doc: &'life1 Document, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

Insert or update a document.

fn replace_chunks<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, doc_id: &'life1 str, chunks: &'life2 [Chunk], vectors: Option<&'life3 [Vec<f32>]>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Replace all chunks for a document, optionally storing vectors.

fn upsert_embedding<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, chunk_id: &'life1 str, doc_id: &'life2 str, vector: &'life3 [f32], model: &'life4 str, dims: usize, content_hash: &'life5 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Store or update an embedding vector for a chunk.

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

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

Retrieve a full document with all its chunks, by ID.

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

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

Retrieve lightweight metadata for a document, by ID.

fn keyword_search<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, query: &'life1 str, limit: i64, _source: Option<&'life2 str>, _since: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChunkCandidate>>> + Send + 'async_trait>>

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

Perform keyword (full-text) search, returning candidate chunks.

fn vector_search<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, query_vec: &'life1 [f32], limit: i64, _source: Option<&'life2 str>, _since: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChunkCandidate>>> + Send + 'async_trait>>

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

Perform vector similarity search, returning candidate chunks.