v1.13.0 (#77)

* v1.13.0

Signed-off-by: Anush008 <[email protected]>

* with:
        dotnet-version: 6.x

Signed-off-by: Anush008 <[email protected]>

* Added StrictModeConfig param

Signed-off-by: Anush008 <[email protected]>

* chore: Comment out VectorInput variants

Signed-off-by: Anush008 <[email protected]>

* chore: MissedstrictModeConfig param

Signed-off-by: Anush008 <[email protected]>

* Update Docker image to 1.13

Co-authored-by: Anush  <[email protected]>

---------

Signed-off-by: Anush008 <[email protected]>
Co-authored-by: Tim Visée <[email protected]>

Author: Anush008

.github/workflows/test.yml

@@ -23,6 +23,10 @@ jobs:
 
     - name: Setup .NET
       uses: actions/setup-dotnet@v4
+      with:
+        dotnet-version: | 
+          6.x
+          8.x
 
     - name: Build
       run: ./build.sh build

Directory.Build.props

@@ -9,7 +9,7 @@
     <PackageProjectUrl>https://github.com/qdrant/qdrant-dotnet</PackageProjectUrl>
     <PackageReleaseNotes>https://github.com/qdrant/qdrant-dotnet/releases</PackageReleaseNotes>
     <PackageTags>qdrant, database, vector, search</PackageTags>
-    <QdrantVersion>v1.12.0</QdrantVersion>
+    <QdrantVersion>v1.13.0</QdrantVersion>
   </PropertyGroup>
 
   <PropertyGroup>

src/Qdrant.Client/Grpc/Conditions.cs

@@ -284,6 +284,19 @@ public static Condition DatetimeRange(string field, DateTime? lt = null, DateTim
 		return new Condition { Field = new FieldCondition { Key = field, DatetimeRange = datetimeRange } };
 	}
 
+	/// <summary>
+	/// Match all records which contain the specified vector.
+	/// </summary>
+	/// <param name="vector">The ids to match</param>
+	/// <returns>a new instance of <see cref="Condition"/></returns>
+	public static Condition HasVector(string vector) => new Condition
+	{
+		HasVector = new HasVectorCondition
+		{
+			HasVector = vector
+		}
+	};
+
 }
 
 

src/Qdrant.Client/Grpc/VectorInput.cs

@@ -84,4 +84,34 @@ public static implicit operator VectorInput(float[][] values)
 	{
 		Id = id
 	};
+
+	// /// <summary>
+	// /// Implicitly converts a <see cref="Document"/> to a new instance of <see cref="VectorInput"/>
+	// /// </summary>
+	// /// <param name="document">an instance of <see cref="Document"/></param>
+	// /// <returns>a new instance of <see cref="VectorInput"/></returns>
+	// public static implicit operator VectorInput(Document document) => new()
+	// {
+	// 	Document = document
+	// };
+
+	// /// <summary>
+	// /// Implicitly converts an <see cref="Image"/> to a new instance of <see cref="VectorInput"/>
+	// /// </summary>
+	// /// <param name="image">an instance of <see cref="Image"/></param>
+	// /// <returns>a new instance of <see cref="VectorInput"/></returns>
+	// public static implicit operator VectorInput(Image image) => new()
+	// {
+	// 	Image = image
+	// };
+
+	// /// <summary>
+	// /// Implicitly converts an <see cref="InferenceObject"/> to a new instance of <see cref="VectorInput"/>
+	// /// </summary>
+	// /// <param name="obj">an instance of <see cref="InferenceObject"/></param>
+	// /// <returns>a new instance of <see cref="VectorInput"/></returns>
+	// public static implicit operator VectorInput(InferenceObject obj) => new()
+	// {
+	// 	Object = obj
+	// };
 }

src/Qdrant.Client/QdrantClient.cs

@@ -131,11 +131,12 @@ private QdrantClient(
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
 	/// <param name="initFromCollection">Use data stored in another collection to initialize this collection.</param>
+	/// <param name="shardingMethod">Sharding method.</param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="shardingMethod">Sharding method.</param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -153,12 +154,13 @@ public Task CreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> CreateCollectionAsync(
 			collectionName, new VectorsConfig { Params = vectorsConfig }, shardNumber, replicationFactor,
 			writeConsistencyFactor, onDiskPayload, hnswConfig, optimizersConfig, walConfig, quantizationConfig,
-			initFromCollection, shardingMethod, sparseVectorsConfig, timeout, cancellationToken);
+			initFromCollection, shardingMethod, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	/// <summary>
 	/// Creates a new collection with the given parameters.
@@ -191,11 +193,12 @@ public Task CreateCollectionAsync(
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
 	/// <param name="initFromCollection">Use data stored in another collection to initialize this collection.</param>
+	/// <param name="shardingMethod">Sharding method.</param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="shardingMethod">Sharding method.</param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -213,12 +216,13 @@ public Task CreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> CreateCollectionAsync(
 			collectionName, vectorsConfig == null ? null : new VectorsConfig { ParamsMap = vectorsConfig }, shardNumber, replicationFactor,
 			writeConsistencyFactor, onDiskPayload, hnswConfig, optimizersConfig, walConfig, quantizationConfig,
-			initFromCollection, shardingMethod, sparseVectorsConfig, timeout, cancellationToken);
+			initFromCollection, shardingMethod, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	private async Task CreateCollectionAsync(
 		string collectionName,
@@ -234,6 +238,7 @@ private async Task CreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 	{
@@ -250,6 +255,7 @@ private async Task CreateCollectionAsync(
 			WalConfig = walConfig,
 			QuantizationConfig = quantizationConfig,
 			SparseVectorsConfig = sparseVectorsConfig,
+			StrictModeConfig = strictModeConfig
 		};
 
 		if (timeout is not null)
@@ -316,11 +322,12 @@ private async Task CreateCollectionAsync(
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
 	/// <param name="initFromCollection">Use data stored in another collection to initialize this collection.</param>
+	/// <param name="shardingMethod">Sharding method.</param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="shardingMethod">Sharding method.</param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -338,12 +345,13 @@ public Task RecreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> RecreateCollectionAsync(
 			collectionName, new VectorsConfig { Params = vectorsConfig }, shardNumber, replicationFactor,
 			writeConsistencyFactor, onDiskPayload, hnswConfig, optimizersConfig, walConfig, quantizationConfig,
-			initFromCollection, shardingMethod, sparseVectorsConfig, timeout, cancellationToken);
+			initFromCollection, shardingMethod, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	/// <summary>
 	/// Deletes a collection if one exists, and creates a new collection with the given parameters.
@@ -376,11 +384,12 @@ public Task RecreateCollectionAsync(
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
 	/// <param name="initFromCollection">Use data stored in another collection to initialize this collection.</param>
+	/// <param name="shardingMethod">Sharding method.</param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="shardingMethod">Sharding method.</param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -398,12 +407,13 @@ public Task RecreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> RecreateCollectionAsync(
 			collectionName, vectorsConfig == null ? null : new VectorsConfig { ParamsMap = vectorsConfig }, shardNumber, replicationFactor,
 			writeConsistencyFactor, onDiskPayload, hnswConfig, optimizersConfig, walConfig, quantizationConfig,
-			initFromCollection, shardingMethod, sparseVectorsConfig, timeout, cancellationToken);
+			initFromCollection, shardingMethod, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	private async Task RecreateCollectionAsync(
 		string collectionName,
@@ -419,6 +429,7 @@ private async Task RecreateCollectionAsync(
 		string? initFromCollection = null,
 		ShardingMethod? shardingMethod = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 	{
@@ -429,7 +440,7 @@ private async Task RecreateCollectionAsync(
 		await CreateCollectionAsync(
 				collectionName, vectorsConfig, shardNumber, replicationFactor,
 				writeConsistencyFactor, onDiskPayload, hnswConfig, optimizersConfig, walConfig, quantizationConfig,
-				initFromCollection, shardingMethod, sparseVectorsConfig, timeout, cancellationToken)
+				initFromCollection, shardingMethod, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken)
 			.ConfigureAwait(false);
 	}
 
@@ -595,10 +606,11 @@ public async Task<bool> CollectionExistsAsync(
 	/// <param name="quantizationConfig">
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -610,10 +622,11 @@ public Task UpdateCollectionAsync(
 		HnswConfigDiff? hnswConfig = null,
 		QuantizationConfigDiff? quantizationConfig = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> UpdateCollectionCoreAsync(collectionName, new VectorsConfigDiff { Params = vectorsConfig }, optimizersConfig,
-			collectionParams, hnswConfig, quantizationConfig, sparseVectorsConfig, timeout, cancellationToken);
+			collectionParams, hnswConfig, quantizationConfig, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	/// <summary>
 	/// Update parameters of the collection.
@@ -629,10 +642,11 @@ public Task UpdateCollectionAsync(
 	/// <param name="quantizationConfig">
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -644,10 +658,11 @@ public Task UpdateCollectionAsync(
 		HnswConfigDiff? hnswConfig = null,
 		QuantizationConfigDiff? quantizationConfig = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> UpdateCollectionCoreAsync(collectionName, new VectorsConfigDiff { ParamsMap = vectorsConfig },
-			optimizersConfig, collectionParams, hnswConfig, quantizationConfig, sparseVectorsConfig, timeout, cancellationToken);
+			optimizersConfig, collectionParams, hnswConfig, quantizationConfig, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	/// <summary>
 	/// Update parameters of the collection.
@@ -659,10 +674,11 @@ public Task UpdateCollectionAsync(
 	/// <param name="quantizationConfig">
 	/// Params for quantization, if <c>null</c> - quantization will be disabled.
 	/// </param>
+	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
+	/// <param name="strictModeConfig">Configuration for strict mode.</param>
 	/// <param name="timeout">
 	/// Wait for operation commit timeout. If timeout is reached, the request will return with a service error.
 	/// </param>
-	/// <param name="sparseVectorsConfig">Configuration for sparse vectors.</param>
 	/// <param name="cancellationToken">
 	/// The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None" />.
 	/// </param>
@@ -673,10 +689,11 @@ public Task UpdateCollectionAsync(
 		HnswConfigDiff? hnswConfig = null,
 		QuantizationConfigDiff? quantizationConfig = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 		=> UpdateCollectionCoreAsync(collectionName, vectorsConfig: null, optimizersConfig, collectionParams,
-			hnswConfig, quantizationConfig, sparseVectorsConfig, timeout, cancellationToken);
+			hnswConfig, quantizationConfig, sparseVectorsConfig, strictModeConfig, timeout, cancellationToken);
 
 	private async Task UpdateCollectionCoreAsync(
 		string collectionName,
@@ -686,6 +703,7 @@ private async Task UpdateCollectionCoreAsync(
 		HnswConfigDiff? hnswConfig = null,
 		QuantizationConfigDiff? quantizationConfig = null,
 		SparseVectorConfig? sparseVectorsConfig = null,
+		StrictModeConfig? strictModeConfig = null,
 		TimeSpan? timeout = null,
 		CancellationToken cancellationToken = default)
 	{
@@ -698,6 +716,7 @@ private async Task UpdateCollectionCoreAsync(
 			HnswConfig = hnswConfig,
 			QuantizationConfig = quantizationConfig,
 			SparseVectorsConfig = sparseVectorsConfig,
+			StrictModeConfig = strictModeConfig
 		};
 
 		if (timeout is not null)