Struct VectorEngine 

pub struct VectorEngine {
    pub config: VectorConfig,
    pub collections: Arc<CollectionManager>,
    pub ann_searcher: Arc<AnnSearcher>,
    pub hybrid_searcher: Arc<HybridSearcher>,
    pub embedding_client: Arc<dyn EmbeddingProvider>,
}

High-level engine that manages collections, search, and embeddings.

Fields

config: VectorConfig

Runtime configuration.

collections: Arc<CollectionManager>

Collection lifecycle and persistence manager.

ann_searcher: Arc<AnnSearcher>

ANN search service.

hybrid_searcher: Arc<HybridSearcher>

Hybrid vector + keyword search service.

embedding_client: Arc<dyn EmbeddingProvider>

Embedding provider used for text ingestion and search.

Implementations

impl VectorEngine

pub async fn new(config: VectorConfig) -> VectorResult<Self>

Create a new engine using the configured gRPC embedding service.

pub async fn open_default() -> VectorResult<Self>

Open an engine using the default configuration.

pub async fn with_embedding_provider( config: VectorConfig, embedding_client: Arc<dyn EmbeddingProvider>, ) -> VectorResult<Self>

Create a new engine with a caller-supplied embedding provider.

pub async fn create_collection( &self, name: &str, dimensions: usize, distance: DistanceMetric, ) -> VectorResult<Collection>

Create a collection with the provided dimensions and distance metric.

pub async fn create_collection_in_workspace( &self, workspace_id: &str, name: &str, dimensions: usize, distance: DistanceMetric, ) -> VectorResult<Collection>

Create a collection inside a specific workspace.

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

Delete a collection and all of its persisted state.

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

Delete a collection inside a specific workspace.

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

List all collections.

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

List collections scoped to a workspace.

pub async fn upsert( &self, collection: &str, text: &str, metadata: Value, ) -> VectorResult<Uuid>

Embed text, persist the record, and return its UUID.

pub async fn upsert_in_workspace( &self, workspace_id: &str, collection: &str, text: &str, metadata: Value, ) -> VectorResult<Uuid>

Embed and insert a record in a workspace-scoped collection.

pub async fn upsert_batch( &self, collection: &str, items: Vec<(String, Value)>, ) -> VectorResult<Vec<Uuid>>

Embed and insert multiple text records.

pub async fn upsert_batch_in_workspace( &self, workspace_id: &str, collection: &str, items: Vec<(String, Value)>, ) -> VectorResult<Vec<Uuid>>

Embed and insert multiple records in a workspace-scoped collection.

pub async fn upsert_vector( &self, collection: &str, vector: Vec<f32>, metadata: Value, ) -> VectorResult<Uuid>

Insert a raw vector directly.

pub async fn upsert_vector_in_workspace( &self, workspace_id: &str, collection: &str, vector: Vec<f32>, metadata: Value, ) -> VectorResult<Uuid>

Insert a raw vector directly into a workspace-scoped collection.

pub async fn search(&self, query: SearchQuery) -> VectorResult<SearchResponse>

Execute ANN search.

pub async fn search_in_workspace( &self, workspace_id: &str, query: SearchQuery, ) -> VectorResult<SearchResponse>

Execute ANN search scoped to a workspace.

pub async fn search_text( &self, collection: &str, text: &str, top_k: usize, ) -> VectorResult<SearchResponse>

Execute ANN search from raw text.

pub async fn search_text_in_workspace( &self, workspace_id: &str, collection: &str, text: &str, top_k: usize, ) -> VectorResult<SearchResponse>

Execute ANN search from raw text scoped to a workspace.

pub async fn hybrid_search( &self, query: HybridQuery, ) -> VectorResult<SearchResponse>

Execute hybrid search.

pub async fn delete(&self, collection: &str, id: Uuid) -> VectorResult<bool>

Delete a vector record by UUID.

pub async fn delete_in_workspace( &self, workspace_id: &str, collection: &str, id: Uuid, ) -> VectorResult<bool>

Delete a vector by UUID from a workspace-scoped collection.

pub async fn get( &self, collection: &str, id: Uuid, ) -> VectorResult<VectorRecord>

Fetch a vector record by UUID.

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

Fetch a vector by UUID from a workspace-scoped collection.

pub async fn close(&self) -> VectorResult<()>

Persist indexes and close the underlying store.

pub async fn stats(&self) -> EngineStats

Return runtime statistics for the engine.