Struct VectorStore 

pub struct VectorStore { /* private fields */ }

Manages all SQLite read/write operations for collections and vector records.

Implementations

impl VectorStore

pub async fn new(db_path: &Path) -> VectorResult<Self>

Open (or create) the SQLite database at db_path, applying schema migrations.

pub async fn open(path: &Path) -> VectorResult<Self>

Alias for VectorStore::new.

pub fn pool(&self) -> &SqlitePool

Return the underlying SQLx connection pool.

pub async fn create_collection( &self, workspace_id: &str, col: &Collection, ) -> VectorResult<()>

Persist a new collection definition (upsert).

pub async fn save_collection( &self, workspace_id: &str, col: &Collection, ) -> VectorResult<()>

Alias for VectorStore::create_collection.

pub async fn get_collection( &self, workspace_id: &str, name: &str, ) -> VectorResult<Collection>

Retrieve a collection by name.

pub async fn delete_collection( &self, workspace_id: &str, name: &str, ) -> VectorResult<()>

Delete a collection by name.

pub async fn list_collections( &self, workspace_id: &str, ) -> VectorResult<Vec<Collection>>

List all collections.

pub async fn list_all_collections(&self) -> VectorResult<Vec<Collection>>

List all collections across all workspaces.

pub async fn insert_record( &self, workspace_id: &str, record: &VectorRecord, internal_id: usize, ) -> VectorResult<()>

Persist a vector record, linking it to the given internal_id.

pub async fn save_record( &self, workspace_id: &str, record: &VectorRecord, internal_id: usize, ) -> VectorResult<()>

Alias for VectorStore::insert_record.

pub async fn get_record( &self, workspace_id: &str, id: Uuid, ) -> VectorResult<(VectorRecord, usize)>

Retrieve a record and its internal identifier by UUID.

pub async fn delete_record( &self, workspace_id: &str, id: Uuid, ) -> VectorResult<Option<usize>>

Delete a vector record by id and return its previous internal id when found.

pub async fn batch_insert_records( &self, workspace_id: &str, records: &[(VectorRecord, usize)], ) -> VectorResult<()>

Insert multiple vector records in a single transaction.

pub async fn uuid_to_internal( &self, workspace_id: &str, id: Uuid, ) -> VectorResult<usize>

Resolve a record UUID to its internal id.

pub async fn internal_to_uuid( &self, workspace_id: &str, collection: &str, internal_id: usize, ) -> VectorResult<Uuid>

Resolve a collection-scoped internal id to its UUID.

pub async fn bulk_internal_to_uuid( &self, workspace_id: &str, collection: &str, ids: &[usize], ) -> VectorResult<Vec<(usize, VectorRecord)>>

Bulk-resolve collection-scoped internal ids to stored vector metadata.

pub async fn increment_vector_count( &self, workspace_id: &str, collection: &str, delta: i64, ) -> VectorResult<()>

Increment a collection’s stored vector count.

pub async fn update_collection_index_type( &self, workspace_id: &str, collection: &str, index_type: IndexType, ) -> VectorResult<()>

Update the persisted index type for a collection.

pub async fn collection_stats( &self, workspace_id: &str, name: &str, ) -> VectorResult<CollectionStats>

Return collection storage statistics as tracked in SQLite.

pub async fn next_internal_id( &self, workspace_id: &str, collection: &str, ) -> VectorResult<usize>

Return the next available internal id for a collection.

pub async fn list_records_for_collection( &self, workspace_id: &str, collection: &str, ) -> VectorResult<Vec<(VectorRecord, usize)>>

Load all persisted records for a collection, ordered by internal id.

pub async fn keyword_search( &self, workspace_id: &str, collection: &str, query: &str, limit: usize, ) -> VectorResult<Vec<(usize, VectorRecord, f32)>>

Search full-text records for a collection using SQLite FTS5.

pub async fn close(&self)

Close the underlying SQLx pool.