Struct SqliteAppStore 

pub struct SqliteAppStore {
    config: Config,
    pool: SqlitePool,
}

SQLite-backed AppStore implementation.

Fields

config: Config

pool: SqlitePool

Implementations

impl SqliteAppStore

pub async fn connect(config: &Config) -> Result<Self>

pub async fn initialize_config(config: &Config) -> Result<()>

pub fn pool(&self) -> &SqlitePool

pub fn agent_runs(&self, workspace_id: &str) -> Result<AgentRunStore>

Runtime history uses the same canonical database as ingestion/retrieval.

pub fn agent_tasks(&self, workspace_id: &str) -> Result<AgentTaskStore>

Accepted background tasks share the canonical database but remain workspace-scoped and distinct from concrete run attempts.

pub async fn close(&self)

fn core_store(&self) -> SqliteStore

pub(crate) async fn replace_source_item_atomic( &self, item: &SourceItem, max_tokens: usize, ) -> Result<CanonicalDocumentWrite>

Atomically replace one canonical document and all of its searchable chunks.

Trait Implementations

impl AppStore for SqliteAppStore

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

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

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

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

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

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

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

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

fn find_pending_chunks<'life0, 'life1, 'async_trait>( &'life0 self, model: &'life1 str, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<PendingChunk>>> + Send + 'async_trait>>

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

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

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

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

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

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

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

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

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

impl Store for SqliteAppStore

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.