qdrant-client 1.17.0

Rust client for Qdrant Vector Search Engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35


#[tokio::test]
async fn test_replicate_points() {
    async fn replicate_points() -> Result<(), Box<dyn std::error::Error>> {
      // WARNING: This is a generated test snippet.
      // Please, modify the snippet in the `../snippets/replicate_points.rs` file
        use qdrant_client::qdrant::{
            update_collection_cluster_setup_request::Operation, Condition, Filter,
            ReplicatePointsBuilder, ShardKey, UpdateCollectionClusterSetupRequest,
        };
        use qdrant_client::Qdrant;
        
        let client = Qdrant::from_url("http://localhost:6334").build()?;
        
        client
            .update_collection_cluster_setup(UpdateCollectionClusterSetupRequest {
                collection_name: "{collection_name}".to_string(),
                operation: Some(Operation::ReplicatePoints(
                    ReplicatePointsBuilder::new(
                        ShardKey::from("source_shard"),
                        ShardKey::from("target_shard"),
                    )
                    .filter(Filter::must([Condition::matches(
                        "user",
                        "tenant-123".to_string(),
                    )]))
                    .build(),
                )),
                timeout: None,
            })
            .await?;
        Ok(())
    }
    let _ = replicate_points().await;
}