GetDocument::into_future

Author: rylev

sdk/data_cosmos/examples/collection.rs

@@ -49,7 +49,8 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
         let db = client
             .clone()
             .into_database_client(db.id.clone())
-            .get_database(Context::new(), GetDatabaseOptions::default())
+            .get_database()
+            .into_future()
             .await?;
         println!("db {} found == {:?}", &db.database.id, &db);
     }
@@ -77,7 +78,8 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
             let collection_response = database_client
                 .clone()
                 .into_collection_client(collection.id)
-                .get_collection(Context::new(), GetCollectionOptions::new())
+                .get_collection()
+                .into_future()
                 .await?;
 
             println!("\tcollection_response {:?}", collection_response);

sdk/data_cosmos/examples/create_delete_database.rs

@@ -58,9 +58,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
 
         let db_collection = db_client.clone().into_collection_client("panzadoro");
 
-        let get_collection_response = db_collection
-            .get_collection(Context::new(), GetCollectionOptions::new())
-            .await?;
+        let get_collection_response = db_collection.get_collection().into_future().await?;
         println!("get_collection_response == {:#?}", get_collection_response);
 
         let stream = db_client.list_collections(Context::new(), ListCollectionsOptions::new());

sdk/data_cosmos/examples/database_01.rs

@@ -26,9 +26,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     println!("collections == {:#?}", collections);
 
     let collection_client = database_client.into_collection_client("cnt");
-    let collection = collection_client
-        .get_collection(Context::new(), GetCollectionOptions::new())
-        .await?;
+    let collection = collection_client.get_collection().into_future().await?;
     println!("collection == {:#?}", collection);
 
     Ok(())

sdk/data_cosmos/examples/document_00.rs

@@ -156,7 +156,8 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let get_document_response = collection_client
         .clone()
         .into_document_client(doc.id.clone(), &doc.id)?
-        .get_document::<MySampleStruct>(Context::new(), GetDocumentOptions::new())
+        .get_document()
+        .into_future::<MySampleStruct>()
         .await?;
     println!("get_document_response == {:#?}", get_document_response);
 

sdk/data_cosmos/examples/document_entries_00.rs

@@ -115,13 +115,11 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let id = format!("unique_id{}", 3);
     let partition_key = &id;
 
-    let response = client
+    let response: GetDocumentResponse<MySampleStruct> = client
         .clone()
         .into_document_client(id.clone(), partition_key)?
-        .get_document::<MySampleStruct>(
-            Context::new(),
-            GetDocumentOptions::new().consistency_level(session_token),
-        )
+        .get_document()
+        .into_future()
         .await?;
 
     assert!(matches!(response, GetDocumentResponse::Found(_)));
@@ -155,14 +153,12 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     // has_been_found == false
     println!("\n\nLooking for non-existing item");
     let id = format!("unique_id{}", 100);
-
-    let response = client
+    let response: GetDocumentResponse<MySampleStruct> = client
         .clone()
         .into_document_client(id.clone(), &id)?
-        .get_document::<MySampleStruct>(
-            Context::new(),
-            GetDocumentOptions::new().consistency_level(&response),
-        )
+        .get_document()
+        .consistency_level(&response)
+        .into_future()
         .await?;
 
     assert!(matches!(response, GetDocumentResponse::NotFound(_)));

sdk/data_cosmos/examples/document_entries_01.rs

@@ -62,20 +62,18 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let get_document_response = client
         .clone()
         .into_document_client(doc.id.clone(), &doc.id)?
-        .get_document::<serde_json::Value>(
-            Context::new(),
-            GetDocumentOptions::new().consistency_level(&create_document_response),
-        )
+        .get_document()
+        .consistency_level(&create_document_response)
+        .into_future::<serde_json::Value>()
         .await?;
     println!("get_document_response == {:#?}", get_document_response);
 
     let get_document_response = client
         .clone()
         .into_document_client("ciccia", &doc.id)?
-        .get_document::<serde_json::Value>(
-            Context::new(),
-            GetDocumentOptions::new().consistency_level(&create_document_response),
-        )
+        .get_document()
+        .consistency_level(&create_document_response)
+        .into_future::<serde_json::Value>()
         .await?;
     println!(
         "get_document_response == {:#?}\n\n\n",

sdk/data_cosmos/examples/get_database.rs

@@ -38,7 +38,9 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     context.insert(custom_headers);
 
     let response = database_client
-        .get_database(context, GetDatabaseOptions::new())
+        .get_database()
+        .context(context)
+        .into_future()
         .await?;
     println!("response == {:?}", response);
 

sdk/data_cosmos/examples/permission_00.rs

@@ -40,19 +40,13 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
         .into_collection_client(collection_name2);
     let user_client = database_client.clone().into_user_client(user_name);
 
-    let get_database_response = database_client
-        .get_database(Context::new(), GetDatabaseOptions::new())
-        .await?;
+    let get_database_response = database_client.get_database().into_future().await?;
     println!("get_database_response == {:#?}", get_database_response);
 
-    let get_collection_response = collection_client
-        .get_collection(Context::new(), GetCollectionOptions::new())
-        .await?;
+    let get_collection_response = collection_client.get_collection().into_future().await?;
     println!("get_collection_response == {:#?}", get_collection_response);
 
-    let get_collection2_response = collection2_client
-        .get_collection(Context::new(), GetCollectionOptions::new())
-        .await?;
+    let get_collection2_response = collection2_client.get_collection().into_future().await?;
     println!(
         "get_collection2_response == {:#?}",
         get_collection2_response
@@ -152,12 +146,11 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     );
 
     let delete_user_response = user_client
-        .delete_user(
-            Context::new(),
-            DeleteUserOptions::new().consistency_level(ConsistencyLevel::Session(
-                delete_permission_response.session_token,
-            )),
-        )
+        .delete_user()
+        .consistency_level(ConsistencyLevel::Session(
+            delete_permission_response.session_token,
+        ))
+        .into_future()
         .await?;
     println!("delete_user_response == {:#?}", delete_user_response);
 

sdk/data_cosmos/examples/user_00.rs

@@ -53,9 +53,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
 
     let user_client = database_client.into_user_client(new_user);
 
-    let delete_user_response = user_client
-        .delete_user(Context::new(), DeleteUserOptions::new())
-        .await?;
+    let delete_user_response = user_client.delete_user().into_future().await?;
     println!("delete_user_response == {:#?}", delete_user_response);
 
     Ok(())

sdk/data_cosmos/examples/user_permission_token.rs

@@ -1,4 +1,3 @@
-use azure_core::Context;
 use azure_data_cosmos::prelude::*;
 use std::error::Error;
 
@@ -34,9 +33,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
         .into_collection_client(collection_name.clone());
     let user_client = database_client.into_user_client(user_name);
 
-    let get_collection_response = collection_client
-        .get_collection(Context::new(), GetCollectionOptions::new())
-        .await?;
+    let get_collection_response = collection_client.get_collection().into_future().await?;
     println!("get_collection_response == {:#?}", get_collection_response);
 
     let create_user_response = user_client.create_user().into_future().await?;
@@ -168,9 +165,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     );
 
     println!("Cleaning up user.");
-    let delete_user_response = user_client
-        .delete_user(Context::new(), DeleteUserOptions::new())
-        .await?;
+    let delete_user_response = user_client.delete_user().into_future().await?;
     println!("delete_user_response == {:#?}", delete_user_response);
 
     Ok(())