support update condition filter param

generall · generall · commit 27a4c6e7f4e7 · 2025-11-13T23:05:50.000+01:00
diff --git a/src/Qdrant.Client/QdrantClient.cs b/src/Qdrant.Client/QdrantClient.cs
@@ -1345,6 +1345,7 @@ public async Task<IReadOnlyList<AliasDescription>> ListAliasesAsync(Cancellation
 	/// </summary>
 	/// <param name="collectionName">The name of the collection.</param>
 	/// <param name="points">The points to be upserted.</param>
+	/// <param name="updateFilter">Conditional update filter.</param>
 	/// <param name="wait">Whether to wait until the changes have been applied. Defaults to <c>true</c>.</param>
 	/// <param name="ordering">Write ordering guarantees.</param>
 	/// <param name="shardKeySelector">Option for custom sharding to specify used shard keys.</param>
@@ -1354,10 +1355,12 @@ public async Task<IReadOnlyList<AliasDescription>> ListAliasesAsync(Cancellation
 	public async Task<UpdateResult> UpsertAsync(
 		string collectionName,
 		IReadOnlyList<PointStruct> points,
+		Filter updateFilter = null,
 		bool wait = true,
 		WriteOrderingType? ordering = null,
 		ShardKeySelector? shardKeySelector = null,
-		CancellationToken cancellationToken = default)
+		CancellationToken cancellationToken = default,
+	)
 	{
 		var request = new UpsertPoints
 		{
@@ -1372,6 +1375,9 @@ public async Task<UpdateResult> UpsertAsync(
 		if (shardKeySelector is not null)
 			request.ShardKeySelector = shardKeySelector;
 
+		if (updateFilter is not null)
+			request.UpdateFilter = updateFilter;
+
 		_logger.Upsert(collectionName, points.Count);
 
 		try
@@ -1779,6 +1785,7 @@ public async Task<IReadOnlyList<RetrievedPoint>> RetrieveAsync(
 	/// </summary>
 	/// <param name="collectionName">The name of the collection.</param>
 	/// <param name="points">The list of points and vectors to update.</param>
+	/// <param name="updateFilter">Conditional update filter.</param>
 	/// <param name="wait">Whether to wait until the changes have been applied. Defaults to <c>true</c>.</param>
 	/// <param name="ordering">Write ordering guarantees.</param>
 	/// <param name="shardKeySelector">Option for custom sharding to specify used shard keys.</param>
@@ -1788,6 +1795,7 @@ public async Task<IReadOnlyList<RetrievedPoint>> RetrieveAsync(
 	public async Task<UpdateResult> UpdateVectorsAsync(
 		string collectionName,
 		IReadOnlyList<PointVectors> points,
+		Filter updateFilter = null,
 		bool wait = true,
 		WriteOrderingType? ordering = null,
 		ShardKeySelector? shardKeySelector = null,
@@ -1806,6 +1814,9 @@ public async Task<UpdateResult> UpdateVectorsAsync(
 		if (shardKeySelector is not null)
 			request.ShardKeySelector = shardKeySelector;
 
+		if (updateFilter is not null)
+			request.UpdateFilter = updateFilter;
+
 		_logger.UpdateVectors(collectionName);
 
 		try
