Skip to content

Commit 5bd0f6e

Browse files
iosmanthusiosmanthus
committed
fix doc test
Signed-off-by: iosmanthus <[email protected]>
1 parent 81cbddd commit 5bd0f6e

File tree

4 files changed

+72
-72
lines changed

4 files changed

+72
-72
lines changed

‎src/lib.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,9 @@
6666
//! # use tikv_client::{RawClient, Result};
6767
//! # use futures::prelude::*;
6868
//! # fn main() -> Result<()> {
69-
//! # use tikv_client::request::codec::RawApiV1;
69+
//! # use tikv_client::raw::ApiV1;
7070
//! futures::executor::block_on(async {
71-
//! let client = RawClient::new(vec!["127.0.0.1:2379"], RawApiV1, None).await?;
71+
//! let client = RawClient::new(vec!["127.0.0.1:2379"], ApiV1, None).await?;
7272
//! client.put("key".to_owned(), "value".to_owned()).await?;
7373
//! let value = client.get("key".to_owned()).await?;
7474
//! # Ok(())
@@ -81,9 +81,9 @@
8181
//! # use tikv_client::{TransactionClient, Result};
8282
//! # use futures::prelude::*;
8383
//! # fn main() -> Result<()> {
84-
//! # use tikv_client::request::codec::TxnApiV1;
84+
//! # use tikv_client::transaction::ApiV1;
8585
//! futures::executor::block_on(async {
86-
//! let txn_client = TransactionClient::new(vec!["127.0.0.1:2379"], TxnApiV1, None).await?;
86+
//! let txn_client = TransactionClient::new(vec!["127.0.0.1:2379"], ApiV1, None).await?;
8787
//! let mut txn = txn_client.begin_optimistic().await?;
8888
//! txn.put("key".to_owned(), "value".to_owned()).await?;
8989
//! let value = txn.get("key".to_owned()).await?;

‎src/raw/client.rs

Lines changed: 28 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -62,9 +62,9 @@ impl<C: RawCodec> Client<C> {
6262
/// ```rust,no_run
6363
/// # use tikv_client::RawClient;
6464
/// # use futures::prelude::*;
65-
/// use tikv_client::request::codec::RawApiV1;
65+
/// use tikv_client::raw::ApiV1;
6666
/// # futures::executor::block_on(async {
67-
/// let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None)
67+
/// let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None)
6868
/// .await
6969
/// .unwrap();
7070
/// # });
@@ -89,12 +89,12 @@ impl<C: RawCodec> Client<C> {
8989
/// # use tikv_client::{Config, RawClient};
9090
/// # use futures::prelude::*;
9191
/// # use std::time::Duration;
92-
/// use tikv_client::request::codec::RawApiV1;
92+
/// use tikv_client::raw::ApiV1;
9393
/// # futures::executor::block_on(async {
9494
/// let client = RawClient::new_with_config(
9595
/// vec!["192.168.0.100"],
9696
/// Config::default().with_timeout(Duration::from_secs(60)),
97-
/// RawApiV1,
97+
/// ApiV1,
9898
/// None,
9999
/// )
100100
/// .await
@@ -145,9 +145,9 @@ impl<C: RawCodec> Client<C> {
145145
/// # use tikv_client::{Config, RawClient, ColumnFamily};
146146
/// # use futures::prelude::*;
147147
/// # use std::convert::TryInto;
148-
/// use tikv_client::request::codec::RawApiV1;
148+
/// use tikv_client::raw::ApiV1;
149149
/// # futures::executor::block_on(async {
150-
/// let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None)
150+
/// let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None)
151151
/// .await
152152
/// .unwrap()
153153
/// .with_cf(ColumnFamily::Write);
@@ -201,9 +201,9 @@ where
201201
/// ```rust,no_run
202202
/// # use tikv_client::{Value, Config, RawClient};
203203
/// # use futures::prelude::*;
204-
/// use tikv_client::request::codec::RawApiV1;
204+
/// use tikv_client::raw::ApiV1;
205205
/// # futures::executor::block_on(async {
206-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
206+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
207207
/// let key = "TiKV".to_owned();
208208
/// let req = client.get(key);
209209
/// let result: Option<Value> = req.await.unwrap();
@@ -236,9 +236,9 @@ where
236236
/// ```rust,no_run
237237
/// # use tikv_client::{KvPair, Config, RawClient};
238238
/// # use futures::prelude::*;
239-
/// use tikv_client::request::codec::RawApiV1;
239+
/// use tikv_client::raw::ApiV1;
240240
/// # futures::executor::block_on(async {
241-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
241+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
242242
/// let keys = vec!["TiKV".to_owned(), "TiDB".to_owned()];
243243
/// let req = client.batch_get(keys);
244244
/// let result: Vec<KvPair> = req.await.unwrap();
@@ -276,9 +276,9 @@ where
276276
/// ```rust,no_run
277277
/// # use tikv_client::{Key, Value, Config, RawClient};
278278
/// # use futures::prelude::*;
279-
/// use tikv_client::request::codec::RawApiV1;
279+
/// use tikv_client::raw::ApiV1;
280280
/// # futures::executor::block_on(async {
281-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
281+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
282282
/// let key = "TiKV".to_owned();
283283
/// let val = "TiKV".to_owned();
284284
/// let req = client.put(key, val);
@@ -315,9 +315,9 @@ where
315315
/// ```rust,no_run
316316
/// # use tikv_client::{Result, KvPair, Key, Value, Config, RawClient, IntoOwnedRange};
317317
/// # use futures::prelude::*;
318-
/// use tikv_client::request::codec::RawApiV1;
318+
/// use tikv_client::raw::ApiV1;
319319
/// # futures::executor::block_on(async {
320-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
320+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
321321
/// let kvpair1 = ("PD".to_owned(), "Go".to_owned());
322322
/// let kvpair2 = ("TiKV".to_owned(), "Rust".to_owned());
323323
/// let iterable = vec![kvpair1, kvpair2];
@@ -362,9 +362,9 @@ where
362362
/// ```rust,no_run
363363
/// # use tikv_client::{Key, Config, RawClient};
364364
/// # use futures::prelude::*;
365-
/// use tikv_client::request::codec::RawApiV1;
365+
/// use tikv_client::raw::ApiV1;
366366
/// # futures::executor::block_on(async {
367-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
367+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
368368
/// let key = "TiKV".to_owned();
369369
/// let req = client.delete(key);
370370
/// let result: () = req.await.unwrap();
@@ -397,9 +397,9 @@ where
397397
/// ```rust,no_run
398398
/// # use tikv_client::{Config, RawClient};
399399
/// # use futures::prelude::*;
400-
/// use tikv_client::request::codec::RawApiV1;
400+
/// use tikv_client::raw::ApiV1;
401401
/// # futures::executor::block_on(async {
402-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
402+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
403403
/// let keys = vec!["TiKV".to_owned(), "TiDB".to_owned()];
404404
/// let req = client.batch_delete(keys);
405405
/// let result: () = req.await.unwrap();
@@ -435,9 +435,9 @@ where
435435
/// ```rust,no_run
436436
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
437437
/// # use futures::prelude::*;
438-
/// use tikv_client::request::codec::RawApiV1;
438+
/// use tikv_client::raw::ApiV1;
439439
/// # futures::executor::block_on(async {
440-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
440+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
441441
/// let inclusive_range = "TiKV"..="TiDB";
442442
/// let req = client.delete_range(inclusive_range.into_owned());
443443
/// let result: () = req.await.unwrap();
@@ -476,9 +476,9 @@ where
476476
/// ```rust,no_run
477477
/// # use tikv_client::{KvPair, Config, RawClient, IntoOwnedRange};
478478
/// # use futures::prelude::*;
479-
/// use tikv_client::request::codec::RawApiV1;
479+
/// use tikv_client::raw::ApiV1;
480480
/// # futures::executor::block_on(async {
481-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
481+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
482482
/// let inclusive_range = "TiKV"..="TiDB";
483483
/// let req = client.scan(inclusive_range.into_owned(), 2);
484484
/// let result: Vec<KvPair> = req.await.unwrap();
@@ -511,9 +511,9 @@ where
511511
/// ```rust,no_run
512512
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
513513
/// # use futures::prelude::*;
514-
/// use tikv_client::request::codec::RawApiV1;
514+
/// use tikv_client::raw::ApiV1;
515515
/// # futures::executor::block_on(async {
516-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
516+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
517517
/// let inclusive_range = "TiKV"..="TiDB";
518518
/// let req = client.scan_keys(inclusive_range.into_owned(), 2);
519519
/// let result: Vec<Key> = req.await.unwrap();
@@ -554,9 +554,9 @@ where
554554
/// ```rust,no_run
555555
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
556556
/// # use futures::prelude::*;
557-
/// use tikv_client::request::codec::RawApiV1;
557+
/// use tikv_client::raw::ApiV1;
558558
/// # futures::executor::block_on(async {
559-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
559+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
560560
/// let inclusive_range1 = "TiDB"..="TiKV";
561561
/// let inclusive_range2 = "TiKV"..="TiSpark";
562562
/// let iterable = vec![inclusive_range1.into_owned(), inclusive_range2.into_owned()];
@@ -599,9 +599,9 @@ where
599599
/// ```rust,no_run
600600
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
601601
/// # use futures::prelude::*;
602-
/// use tikv_client::request::codec::RawApiV1;
602+
/// use tikv_client::raw::ApiV1;
603603
/// # futures::executor::block_on(async {
604-
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
604+
/// # let client = RawClient::new(vec!["192.168.0.100"], ApiV1, None).await.unwrap();
605605
/// let inclusive_range1 = "TiDB"..="TiKV";
606606
/// let inclusive_range2 = "TiKV"..="TiSpark";
607607
/// let iterable = vec![inclusive_range1.into_owned(), inclusive_range2.into_owned()];

‎src/transaction/client.rs

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,9 @@ where
6868
/// ```rust,no_run
6969
/// # use tikv_client::{Config, TransactionClient};
7070
/// # use futures::prelude::*;
71-
/// use tikv_client::request::codec::TxnApiV1;
71+
/// use tikv_client::transaction::ApiV1;
7272
/// # futures::executor::block_on(async {
73-
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
73+
/// let client = TransactionClient::new(vec!["192.168.0.100"], ApiV1, None)
7474
/// .await
7575
/// .unwrap();
7676
/// # });
@@ -96,12 +96,12 @@ where
9696
/// # use tikv_client::{Config, TransactionClient};
9797
/// # use futures::prelude::*;
9898
/// # use std::time::Duration;
99-
/// use tikv_client::request::codec::TxnApiV1;
99+
/// use tikv_client::transaction::ApiV1;
100100
/// # futures::executor::block_on(async {
101101
/// let client = TransactionClient::new_with_config(
102102
/// vec!["192.168.0.100"],
103103
/// Config::default().with_timeout(Duration::from_secs(60)),
104-
/// TxnApiV1,
104+
/// ApiV1,
105105
/// None,
106106
/// )
107107
/// .await
@@ -148,9 +148,9 @@ where
148148
/// ```rust,no_run
149149
/// # use tikv_client::{Config, TransactionClient};
150150
/// # use futures::prelude::*;
151-
/// use tikv_client::request::codec::TxnApiV1;
151+
/// use tikv_client::transaction::ApiV1;
152152
/// # futures::executor::block_on(async {
153-
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
153+
/// let client = TransactionClient::new(vec!["192.168.0.100"], ApiV1, None)
154154
/// .await
155155
/// .unwrap();
156156
/// let mut transaction = client.begin_optimistic().await.unwrap();
@@ -174,9 +174,9 @@ where
174174
/// ```rust,no_run
175175
/// # use tikv_client::{Config, TransactionClient};
176176
/// # use futures::prelude::*;
177-
/// use tikv_client::request::codec::TxnApiV1;
177+
/// use tikv_client::transaction::ApiV1;
178178
/// # futures::executor::block_on(async {
179-
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
179+
/// let client = TransactionClient::new(vec!["192.168.0.100"], ApiV1, None)
180180
/// .await
181181
/// .unwrap();
182182
/// let mut transaction = client.begin_pessimistic().await.unwrap();
@@ -197,9 +197,9 @@ where
197197
/// ```rust,no_run
198198
/// # use tikv_client::{Config, TransactionClient, TransactionOptions};
199199
/// # use futures::prelude::*;
200-
/// use tikv_client::request::codec::TxnApiV1;
200+
/// use tikv_client::transaction::ApiV1;
201201
/// # futures::executor::block_on(async {
202-
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
202+
/// let client = TransactionClient::new(vec!["192.168.0.100"], ApiV1, None)
203203
/// .await
204204
/// .unwrap();
205205
/// let mut transaction = client
@@ -237,9 +237,9 @@ where
237237
/// ```rust,no_run
238238
/// # use tikv_client::{Config, TransactionClient};
239239
/// # use futures::prelude::*;
240-
/// use tikv_client::request::codec::TxnApiV1;
240+
/// use tikv_client::transaction::ApiV1;
241241
/// # futures::executor::block_on(async {
242-
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
242+
/// let client = TransactionClient::new(vec!["192.168.0.100"], ApiV1, None)
243243
/// .await
244244
/// .unwrap();
245245
/// let timestamp = client.current_timestamp().await.unwrap();

0 commit comments

Comments
 (0)