Struct QdrantOps 

pub struct QdrantOps { /* private fields */ }

Thin wrapper over Qdrant client encapsulating common collection operations.

Implementations

impl QdrantOps

pub fn new(url: &str) -> Result<Self, Box<QdrantError>>

Create a new QdrantOps connected to the given URL.

Errors

Returns an error if the Qdrant client cannot be created.

pub fn client(&self) -> &Qdrant

Access the underlying Qdrant client for advanced operations.

pub async fn ensure_collection( &self, collection: &str, vector_size: u64, ) -> Result<(), Box<QdrantError>>

Ensure a collection exists with cosine distance vectors.

If the collection already exists but has a different vector dimension than vector_size, the collection is deleted and recreated. All existing data in the collection is lost.

Errors

Returns an error if Qdrant cannot be reached or collection creation fails.

pub async fn collection_exists( &self, collection: &str, ) -> Result<bool, Box<QdrantError>>

Check whether a collection exists.

Errors

Returns an error if Qdrant cannot be reached.

pub async fn delete_collection( &self, collection: &str, ) -> Result<(), Box<QdrantError>>

Delete a collection.

Errors

Returns an error if the collection cannot be deleted.

pub async fn upsert( &self, collection: &str, points: Vec<PointStruct>, ) -> Result<(), Box<QdrantError>>

Upsert points into a collection.

Errors

Returns an error if the upsert fails.

pub async fn search( &self, collection: &str, vector: Vec<f32>, limit: u64, filter: Option<Filter>, ) -> Result<Vec<ScoredPoint>, Box<QdrantError>>

Search for similar vectors, returning scored points with payloads.

Errors

Returns an error if the search fails.

pub async fn delete_by_ids( &self, collection: &str, ids: Vec<PointId>, ) -> Result<(), Box<QdrantError>>

Delete points by their IDs.

Errors

Returns an error if the deletion fails.

pub async fn scroll_all( &self, collection: &str, key_field: &str, ) -> Result<HashMap<String, HashMap<String, String>>, Box<QdrantError>>

Scroll all points in a collection, extracting string payload fields.

Returns a map of key_field value -> { field_name -> field_value }.

Errors

Returns an error if the scroll operation fails.

pub async fn ensure_collection_with_quantization( &self, collection: &str, vector_size: u64, keyword_fields: &[&str], ) -> Result<(), VectorStoreError>

Create a collection with scalar INT8 quantization if it does not exist, then create keyword indexes for the given fields.

If the collection already exists but has a different vector dimension than vector_size, the collection is deleted and recreated. All existing data in the collection is lost.

Errors

Returns an error if any Qdrant operation fails.

pub fn json_to_payload(value: Value) -> Result<HashMap<String, Value>, Error>

Convert a JSON value to a Qdrant payload map.

Errors

Returns a JSON error if deserialization fails.

Trait Implementations

impl Clone for QdrantOps

fn clone(&self) -> QdrantOps

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QdrantOps

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl VectorStore for QdrantOps

fn ensure_collection( &self, collection: &str, vector_size: u64, ) -> Pin<Box<dyn Future<Output = Result<(), VectorStoreError>> + Send + '_>>

fn collection_exists( &self, collection: &str, ) -> Pin<Box<dyn Future<Output = Result<bool, VectorStoreError>> + Send + '_>>

fn delete_collection( &self, collection: &str, ) -> Pin<Box<dyn Future<Output = Result<(), VectorStoreError>> + Send + '_>>

fn upsert( &self, collection: &str, points: Vec<VectorPoint>, ) -> Pin<Box<dyn Future<Output = Result<(), VectorStoreError>> + Send + '_>>

fn search( &self, collection: &str, vector: Vec<f32>, limit: u64, filter: Option<VectorFilter>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScoredVectorPoint>, VectorStoreError>> + Send + '_>>

fn delete_by_ids( &self, collection: &str, ids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), VectorStoreError>> + Send + '_>>

fn scroll_all( &self, collection: &str, key_field: &str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, HashMap<String, String>>, VectorStoreError>> + Send + '_>>

fn health_check( &self, ) -> Pin<Box<dyn Future<Output = Result<bool, VectorStoreError>> + Send + '_>>