Struct QdrantClient 

pub struct QdrantClient { /* private fields */ }

Direct Qdrant client wrapper.

Implementations

impl QdrantClient

pub async fn new(url: &str) -> Result<Self, VectorDbError>

Creates a client for url.

pub fn client(&self) -> &Qdrant

Returns the underlying Qdrant client.

pub fn url(&self) -> &str

Returns the configured URL.

pub async fn health_check(&self) -> Result<(), VectorDbError>

Performs a basic health check request.

pub async fn create_collection( &self, name: &str, vector_size: u64, ) -> Result<(), VectorDbError>

Creates a collection with cosine distance.

pub async fn ensure_collection( &self, name: &str, vector_size: u64, ) -> Result<(), VectorDbError>

Ensures a collection exists (creates it if missing).

pub async fn collection_exists(&self, name: &str) -> Result<bool, VectorDbError>

Returns true if the collection exists.

pub async fn upsert_points( &self, collection: &str, points: Vec<VectorPoint>, consistency: WriteConsistency, ) -> Result<(), VectorDbError>

Upserts points into a collection.

pub async fn search( &self, collection: &str, query: Vec<f32>, limit: u64, tenant_filter: Option<u64>, ) -> Result<Vec<SearchResult>, VectorDbError>

Searches a collection by vector similarity.

pub async fn delete_points( &self, collection: &str, ids: Vec<u64>, ) -> Result<(), VectorDbError>

Deletes points by id.

Trait Implementations

impl Clone for QdrantClient

fn clone(&self) -> QdrantClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl VectorDbClient for QdrantClient

async fn ensure_collection( &self, name: &str, vector_size: u64, ) -> Result<(), VectorDbError>

Ensures a collection exists.

async fn upsert_points( &self, collection: &str, points: Vec<VectorPoint>, consistency: WriteConsistency, ) -> Result<(), VectorDbError>

Upserts points.

async fn search( &self, collection: &str, query: Vec<f32>, limit: u64, tenant_filter: Option<u64>, ) -> Result<Vec<SearchResult>, VectorDbError>

Searches for similar points.

async fn delete_points( &self, collection: &str, ids: Vec<u64>, ) -> Result<(), VectorDbError>

Deletes points.