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.

Idempotent: no-op if the collection already exists.

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.

Idempotent: no-op if the collection already exists.

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 + '_>>