diff --git a/crates/xline-client/README.md b/crates/xline-client/README.md index 9a7328c76..3147b51e8 100644 --- a/crates/xline-client/README.md +++ b/crates/xline-client/README.md @@ -81,7 +81,7 @@ To create a xline client: ```rust, no_run use xline_client::{ - types::kv::{PutRequest, RangeRequest}, + types::kv::{PutOptions, RangeRequest}, Client, ClientOptions, }; use anyhow::Result; @@ -95,7 +95,7 @@ To create a xline client: .await? .kv_client(); - client.put(PutRequest::new("key", "value")).await?; + client.put("key", "value", None).await?; let resp = client.range(RangeRequest::new("key")).await?; diff --git a/crates/xline-client/src/clients/auth.rs b/crates/xline-client/src/clients/auth.rs index 6a231ef39..6413ec9fe 100644 --- a/crates/xline-client/src/clients/auth.rs +++ b/crates/xline-client/src/clients/auth.rs @@ -170,7 +170,7 @@ impl AuthClient { /// # Examples /// /// ```no_run - /// use xline_client::{types::auth::AuthenticateRequest, Client, ClientOptions}; + /// use xline_client::{Client, ClientOptions}; /// use anyhow::Result; /// /// #[tokio::main] diff --git a/crates/xline-client/src/clients/kv.rs b/crates/xline-client/src/clients/kv.rs index 16f5ecaee..2ab36dbc6 100644 --- a/crates/xline-client/src/clients/kv.rs +++ b/crates/xline-client/src/clients/kv.rs @@ -77,7 +77,7 @@ impl KvClient { /// .kv_client(); /// /// client.put("key1", "value1", None).await?; - /// client.put("key1", "value1", PutOptions::default().with_prev_kv(true)).await?; + /// client.put("key2", "value2", Some(PutOptions::default().with_prev_kv(true))).await?; /// /// Ok(()) /// } @@ -191,7 +191,7 @@ impl KvClient { /// /// ```no_run /// use xline_client::{ - /// types::kv::{Compare, PutRequest, RangeRequest, TxnOp, TxnRequest, CompareResult}, + /// types::kv::{Compare, PutOptions, RangeRequest, TxnOp, TxnRequest, CompareResult}, /// Client, ClientOptions, /// }; /// use anyhow::Result; @@ -207,9 +207,7 @@ impl KvClient { /// let txn_req = TxnRequest::new() /// .when(&[Compare::value("key2", CompareResult::Equal, "value2")][..]) /// .and_then( - /// &[TxnOp::put( - /// PutRequest::new("key2", "value3").with_prev_kv(true), - /// )][..], + /// &[TxnOp::put("key2", "value3", Some(PutOptions::default().with_prev_kv(true)))][..], /// ) /// .or_else(&[TxnOp::range(RangeRequest::new("key2"))][..]); /// @@ -249,7 +247,7 @@ impl KvClient { /// ///```no_run /// use xline_client::{ - /// types::kv::{CompactionRequest, PutRequest}, + /// types::kv::{CompactionRequest}, /// Client, ClientOptions, /// }; /// use anyhow::Result; @@ -262,7 +260,7 @@ impl KvClient { /// .await? /// .kv_client(); /// - /// let resp_put = client.put(PutRequest::new("key", "val")).await?; + /// let resp_put = client.put("key", "val", None).await?; /// let rev = resp_put.header.unwrap().revision; /// /// let _resp = client.compact(CompactionRequest::new(rev)).await?; diff --git a/crates/xline-client/src/clients/lock.rs b/crates/xline-client/src/clients/lock.rs index ec7a55bd0..d5761f6ad 100644 --- a/crates/xline-client/src/clients/lock.rs +++ b/crates/xline-client/src/clients/lock.rs @@ -263,7 +263,7 @@ impl Xutex { /// use anyhow::Result; /// use xline_client::{ /// clients::Xutex, - /// types::kv::{Compare, CompareResult, PutRequest, TxnOp}, + /// types::kv::{Compare, CompareResult, PutOptions, TxnOp}, /// Client, ClientOptions, /// }; /// @@ -283,9 +283,7 @@ impl Xutex { /// let txn_req = xutex_guard /// .txn_check_locked_key() /// .when([Compare::value("key2", CompareResult::Equal, "value2")]) - /// .and_then([TxnOp::put( - /// PutRequest::new("key2", "value3").with_prev_kv(true), - /// )]) + /// .and_then([TxnOp::put("key2", "value3", Some(PutOptions::default().with_prev_kv(true)))]) /// .or_else(&[]); /// /// let _resp = kv_client.txn(txn_req).await?; diff --git a/crates/xline-client/src/clients/watch.rs b/crates/xline-client/src/clients/watch.rs index 98f399adb..f1d036802 100644 --- a/crates/xline-client/src/clients/watch.rs +++ b/crates/xline-client/src/clients/watch.rs @@ -54,7 +54,7 @@ impl WatchClient { /// /// ```no_run /// use xline_client::{ - /// types::{kv::PutRequest, watch::WatchRequest}, + /// types::watch::WatchRequest, /// Client, ClientOptions, /// }; /// use anyhow::Result; @@ -68,7 +68,7 @@ impl WatchClient { /// let mut kv_client = client.kv_client(); /// /// let (mut watcher, mut stream) = watch_client.watch(WatchRequest::new("key1")).await?; - /// kv_client.put(PutRequest::new("key1", "value1")).await?; + /// kv_client.put("key1", "value1", None).await?; /// /// let resp = stream.message().await?.unwrap(); /// let kv = resp.events[0].kv.as_ref().unwrap();