Class QdrantStore

Namespace

Mythosia.VectorDb.Qdrant

Assembly

Mythosia.VectorDb.Qdrant.dll

Qdrant implementation of IVectorStore. Uses a single Qdrant collection (configured via CollectionName) with payload-based metadata filtering for logical isolation.

public class QdrantStore : IVectorStore, IDisposable

Inheritance

object

QdrantStore

Implements

IVectorStore

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

QdrantStore(QdrantOptions)

Creates a new QdrantStore that owns its QdrantClient.

public QdrantStore(QdrantOptions options)

Parameters

options QdrantOptions

Configuration options. Validated on construction.

QdrantStore(QdrantOptions, QdrantClient)

Creates a new QdrantStore using an externally managed QdrantClient. The caller is responsible for disposing the client.

public QdrantStore(QdrantOptions options, QdrantClient client)

Parameters

options QdrantOptions

Configuration options. Validated on construction.

client QdrantClient

Pre-configured Qdrant client instance.

Methods

CountAsync(VectorFilter?, CancellationToken)

Returns the number of records matching the optional filter. When filter is null, returns the total record count. Implementations may ignore MinScore as it is not meaningful for counting.

public Task<long> CountAsync(VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<long>

DeleteAsync(string, VectorFilter?, CancellationToken)

Deletes a single record by its Id. Implementations may use filter to narrow by metadata conditions.

public Task DeleteAsync(string id, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

id string

filter VectorFilter

cancellationToken CancellationToken

Returns

Task

DeleteByFilterAsync(VectorFilter, CancellationToken)

Deletes all records matching the specified filter.

public Task DeleteByFilterAsync(VectorFilter filter, CancellationToken cancellationToken = default)

Parameters

filter VectorFilter

cancellationToken CancellationToken

Returns

Task

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

GetAsync(string, VectorFilter?, CancellationToken)

Retrieves a single record by its Id. Implementations may use filter to narrow results by metadata conditions.

public Task<VectorRecord?> GetAsync(string id, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

id string

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<VectorRecord>

GetBatchAsync(IEnumerable<string>, VectorFilter?, CancellationToken)

Retrieves multiple records by their Ids in a single batch operation. Records that do not exist or do not match filter are omitted from the result. The order of results is not guaranteed to match the order of ids.

public Task<IReadOnlyList<VectorRecord>> GetBatchAsync(IEnumerable<string> ids, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

ids IEnumerable<string>

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorRecord>>

HybridSearchAsync(float[], string, int, VectorFilter?, CancellationToken)

Performs a native hybrid search using Qdrant's prefetch + server-side fusion. Dense vector search and sparse (BM25-based) vector search are combined using HybridFusionStrategy.

public Task<IReadOnlyList<VectorSearchResult>> HybridSearchAsync(float[] denseVector, string query, int topK, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

denseVector float[]

query string

topK int

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorSearchResult>>

SearchAsync(float[], int, VectorFilter?, CancellationToken)

Performs a similarity search. Implementations should respect Conditions and MinScore when present.

public Task<IReadOnlyList<VectorSearchResult>> SearchAsync(float[] queryVector, int topK = 5, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

queryVector float[]

The query embedding vector.

topK int

Maximum number of results to return.

filter VectorFilter

Optional filter criteria (metadata conditions, min score).

cancellationToken CancellationToken

Cancellation token.

Returns

Task<IReadOnlyList<VectorSearchResult>>

Results ordered by descending similarity score.

UpsertAsync(VectorRecord, CancellationToken)

Inserts or updates a single vector record. If a record with the same Id already exists, it is overwritten.

public Task UpsertAsync(VectorRecord record, CancellationToken cancellationToken = default)

Parameters

record VectorRecord

cancellationToken CancellationToken

Returns

Task

UpsertBatchAsync(IEnumerable<VectorRecord>, CancellationToken)

Inserts or updates multiple vector records in a batch.

public Task UpsertBatchAsync(IEnumerable<VectorRecord> records, CancellationToken cancellationToken = default)

Parameters

records IEnumerable<VectorRecord>

cancellationToken CancellationToken

Returns

Task

VerifyConnectionAsync(CancellationToken)

Verifies that the store can reach its backend (e.g. database, API). Throws on failure. In-memory stores succeed immediately.

public Task VerifyConnectionAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task