Skip to content

Commit db38d95

Browse files
iosmanthusiosmanthus
committed
fix tests
Signed-off-by: iosmanthus <[email protected]>
1 parent 701964d commit db38d95

File tree

4 files changed

+36
-36
lines changed

4 files changed

+36
-36
lines changed

‎src/lib.rs

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

‎src/raw/client.rs

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ impl<C: RawCodec> Client<C> {
6262
/// ```rust,no_run
6363
/// # use tikv_client::RawClient;
6464
/// # use futures::prelude::*;
65-
/// use tikv_client::request::request_codec::RawApiV1;
65+
/// use tikv_client::request::codec::RawApiV1;
6666
/// # futures::executor::block_on(async {
6767
/// let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None)
6868
/// .await
@@ -89,7 +89,7 @@ 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::request_codec::RawApiV1;
92+
/// use tikv_client::request::codec::RawApiV1;
9393
/// # futures::executor::block_on(async {
9494
/// let client = RawClient::new_with_config(
9595
/// vec!["192.168.0.100"],
@@ -145,7 +145,7 @@ 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::request_codec::RawApiV1;
148+
/// use tikv_client::request::codec::RawApiV1;
149149
/// # futures::executor::block_on(async {
150150
/// let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None)
151151
/// .await
@@ -201,7 +201,7 @@ where
201201
/// ```rust,no_run
202202
/// # use tikv_client::{Value, Config, RawClient};
203203
/// # use futures::prelude::*;
204-
/// use tikv_client::request::request_codec::RawApiV1;
204+
/// use tikv_client::request::codec::RawApiV1;
205205
/// # futures::executor::block_on(async {
206206
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
207207
/// let key = "TiKV".to_owned();
@@ -236,7 +236,7 @@ where
236236
/// ```rust,no_run
237237
/// # use tikv_client::{KvPair, Config, RawClient};
238238
/// # use futures::prelude::*;
239-
/// use tikv_client::request::request_codec::RawApiV1;
239+
/// use tikv_client::request::codec::RawApiV1;
240240
/// # futures::executor::block_on(async {
241241
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
242242
/// let keys = vec!["TiKV".to_owned(), "TiDB".to_owned()];
@@ -276,7 +276,7 @@ where
276276
/// ```rust,no_run
277277
/// # use tikv_client::{Key, Value, Config, RawClient};
278278
/// # use futures::prelude::*;
279-
/// use tikv_client::request::request_codec::RawApiV1;
279+
/// use tikv_client::request::codec::RawApiV1;
280280
/// # futures::executor::block_on(async {
281281
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
282282
/// let key = "TiKV".to_owned();
@@ -315,7 +315,7 @@ 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::request_codec::RawApiV1;
318+
/// use tikv_client::request::codec::RawApiV1;
319319
/// # futures::executor::block_on(async {
320320
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
321321
/// let kvpair1 = ("PD".to_owned(), "Go".to_owned());
@@ -362,7 +362,7 @@ where
362362
/// ```rust,no_run
363363
/// # use tikv_client::{Key, Config, RawClient};
364364
/// # use futures::prelude::*;
365-
/// use tikv_client::request::request_codec::RawApiV1;
365+
/// use tikv_client::request::codec::RawApiV1;
366366
/// # futures::executor::block_on(async {
367367
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
368368
/// let key = "TiKV".to_owned();
@@ -397,7 +397,7 @@ where
397397
/// ```rust,no_run
398398
/// # use tikv_client::{Config, RawClient};
399399
/// # use futures::prelude::*;
400-
/// use tikv_client::request::request_codec::RawApiV1;
400+
/// use tikv_client::request::codec::RawApiV1;
401401
/// # futures::executor::block_on(async {
402402
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
403403
/// let keys = vec!["TiKV".to_owned(), "TiDB".to_owned()];
@@ -435,7 +435,7 @@ where
435435
/// ```rust,no_run
436436
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
437437
/// # use futures::prelude::*;
438-
/// use tikv_client::request::request_codec::RawApiV1;
438+
/// use tikv_client::request::codec::RawApiV1;
439439
/// # futures::executor::block_on(async {
440440
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
441441
/// let inclusive_range = "TiKV"..="TiDB";
@@ -476,7 +476,7 @@ where
476476
/// ```rust,no_run
477477
/// # use tikv_client::{KvPair, Config, RawClient, IntoOwnedRange};
478478
/// # use futures::prelude::*;
479-
/// use tikv_client::request::request_codec::RawApiV1;
479+
/// use tikv_client::request::codec::RawApiV1;
480480
/// # futures::executor::block_on(async {
481481
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
482482
/// let inclusive_range = "TiKV"..="TiDB";
@@ -511,7 +511,7 @@ where
511511
/// ```rust,no_run
512512
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
513513
/// # use futures::prelude::*;
514-
/// use tikv_client::request::request_codec::RawApiV1;
514+
/// use tikv_client::request::codec::RawApiV1;
515515
/// # futures::executor::block_on(async {
516516
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
517517
/// let inclusive_range = "TiKV"..="TiDB";
@@ -554,7 +554,7 @@ where
554554
/// ```rust,no_run
555555
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
556556
/// # use futures::prelude::*;
557-
/// use tikv_client::request::request_codec::RawApiV1;
557+
/// use tikv_client::request::codec::RawApiV1;
558558
/// # futures::executor::block_on(async {
559559
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
560560
/// let inclusive_range1 = "TiDB"..="TiKV";
@@ -599,7 +599,7 @@ where
599599
/// ```rust,no_run
600600
/// # use tikv_client::{Key, Config, RawClient, IntoOwnedRange};
601601
/// # use futures::prelude::*;
602-
/// use tikv_client::request::request_codec::RawApiV1;
602+
/// use tikv_client::request::codec::RawApiV1;
603603
/// # futures::executor::block_on(async {
604604
/// # let client = RawClient::new(vec!["192.168.0.100"], RawApiV1, None).await.unwrap();
605605
/// let inclusive_range1 = "TiDB"..="TiKV";

‎src/transaction/client.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ where
6868
/// ```rust,no_run
6969
/// # use tikv_client::{Config, TransactionClient};
7070
/// # use futures::prelude::*;
71-
/// use tikv_client::request::request_codec::TxnApiV1;
71+
/// use tikv_client::request::codec::TxnApiV1;
7272
/// # futures::executor::block_on(async {
7373
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
7474
/// .await
@@ -96,7 +96,7 @@ where
9696
/// # use tikv_client::{Config, TransactionClient};
9797
/// # use futures::prelude::*;
9898
/// # use std::time::Duration;
99-
/// use tikv_client::request::request_codec::TxnApiV1;
99+
/// use tikv_client::request::codec::TxnApiV1;
100100
/// # futures::executor::block_on(async {
101101
/// let client = TransactionClient::new_with_config(
102102
/// vec!["192.168.0.100"],
@@ -148,7 +148,7 @@ where
148148
/// ```rust,no_run
149149
/// # use tikv_client::{Config, TransactionClient};
150150
/// # use futures::prelude::*;
151-
/// use tikv_client::request::request_codec::TxnApiV1;
151+
/// use tikv_client::request::codec::TxnApiV1;
152152
/// # futures::executor::block_on(async {
153153
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
154154
/// .await
@@ -174,7 +174,7 @@ where
174174
/// ```rust,no_run
175175
/// # use tikv_client::{Config, TransactionClient};
176176
/// # use futures::prelude::*;
177-
/// use tikv_client::request::request_codec::TxnApiV1;
177+
/// use tikv_client::request::codec::TxnApiV1;
178178
/// # futures::executor::block_on(async {
179179
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
180180
/// .await
@@ -197,7 +197,7 @@ where
197197
/// ```rust,no_run
198198
/// # use tikv_client::{Config, TransactionClient, TransactionOptions};
199199
/// # use futures::prelude::*;
200-
/// use tikv_client::request::request_codec::TxnApiV1;
200+
/// use tikv_client::request::codec::TxnApiV1;
201201
/// # futures::executor::block_on(async {
202202
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
203203
/// .await
@@ -237,7 +237,7 @@ where
237237
/// ```rust,no_run
238238
/// # use tikv_client::{Config, TransactionClient};
239239
/// # use futures::prelude::*;
240-
/// use tikv_client::request::request_codec::TxnApiV1;
240+
/// use tikv_client::request::codec::TxnApiV1;
241241
/// # futures::executor::block_on(async {
242242
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
243243
/// .await

‎src/transaction/transaction.rs

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ use crate::{
5151
/// ```rust,no_run
5252
/// # use tikv_client::{Config, TransactionClient};
5353
/// # use futures::prelude::*;
54-
/// use tikv_client::request::request_codec::TxnApiV1;
54+
/// use tikv_client::request::codec::TxnApiV1;
5555
/// # futures::executor::block_on(async {
5656
/// let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None)
5757
/// .await
@@ -108,7 +108,7 @@ impl<PdC: PdClient> Transaction<PdC> {
108108
/// ```rust,no_run
109109
/// # use tikv_client::{Value, Config, TransactionClient};
110110
/// # use futures::prelude::*;
111-
/// use tikv_client::request::request_codec::TxnApiV1;
111+
/// use tikv_client::request::codec::TxnApiV1;
112112
/// # futures::executor::block_on(async {
113113
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
114114
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -170,7 +170,7 @@ impl<PdC: PdClient> Transaction<PdC> {
170170
/// ```rust,no_run
171171
/// # use tikv_client::{Value, Config, TransactionClient};
172172
/// # use futures::prelude::*;
173-
/// use tikv_client::request::request_codec::TxnApiV1;
173+
/// use tikv_client::request::codec::TxnApiV1;
174174
/// # futures::executor::block_on(async {
175175
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
176176
/// let mut txn = client.begin_pessimistic().await.unwrap();
@@ -205,7 +205,7 @@ impl<PdC: PdClient> Transaction<PdC> {
205205
/// ```rust,no_run
206206
/// # use tikv_client::{Value, Config, TransactionClient};
207207
/// # use futures::prelude::*;
208-
/// use tikv_client::request::request_codec::TxnApiV1;
208+
/// use tikv_client::request::codec::TxnApiV1;
209209
/// # futures::executor::block_on(async {
210210
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
211211
/// let mut txn = client.begin_pessimistic().await.unwrap();
@@ -233,7 +233,7 @@ impl<PdC: PdClient> Transaction<PdC> {
233233
/// # use tikv_client::{Key, Value, Config, TransactionClient};
234234
/// # use futures::prelude::*;
235235
/// # use std::collections::HashMap;
236-
/// use tikv_client::request::request_codec::TxnApiV1;
236+
/// use tikv_client::request::codec::TxnApiV1;
237237
/// # futures::executor::block_on(async {
238238
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
239239
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -287,7 +287,7 @@ impl<PdC: PdClient> Transaction<PdC> {
287287
/// # use tikv_client::{Key, Value, Config, TransactionClient, KvPair};
288288
/// # use futures::prelude::*;
289289
/// # use std::collections::HashMap;
290-
/// use tikv_client::request::request_codec::TxnApiV1;
290+
/// use tikv_client::request::codec::TxnApiV1;
291291
/// # futures::executor::block_on(async {
292292
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
293293
/// let mut txn = client.begin_pessimistic().await.unwrap();
@@ -333,7 +333,7 @@ impl<PdC: PdClient> Transaction<PdC> {
333333
/// # use tikv_client::{Key, KvPair, Value, Config, TransactionClient};
334334
/// # use futures::prelude::*;
335335
/// # use std::collections::HashMap;
336-
/// use tikv_client::request::request_codec::TxnApiV1;
336+
/// use tikv_client::request::codec::TxnApiV1;
337337
/// # futures::executor::block_on(async {
338338
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
339339
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -370,7 +370,7 @@ impl<PdC: PdClient> Transaction<PdC> {
370370
/// # use tikv_client::{Key, KvPair, Value, Config, TransactionClient};
371371
/// # use futures::prelude::*;
372372
/// # use std::collections::HashMap;
373-
/// use tikv_client::request::request_codec::TxnApiV1;
373+
/// use tikv_client::request::codec::TxnApiV1;
374374
/// # futures::executor::block_on(async {
375375
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
376376
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -412,7 +412,7 @@ impl<PdC: PdClient> Transaction<PdC> {
412412
/// ```rust,no_run
413413
/// # use tikv_client::{Key, Value, Config, TransactionClient};
414414
/// # use futures::prelude::*;
415-
/// use tikv_client::request::request_codec::TxnApiV1;
415+
/// use tikv_client::request::codec::TxnApiV1;
416416
/// # futures::executor::block_on(async {
417417
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
418418
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -444,7 +444,7 @@ impl<PdC: PdClient> Transaction<PdC> {
444444
/// ```rust,no_run
445445
/// # use tikv_client::{Key, Value, Config, TransactionClient};
446446
/// # use futures::prelude::*;
447-
/// use tikv_client::request::request_codec::TxnApiV1;
447+
/// use tikv_client::request::codec::TxnApiV1;
448448
/// # futures::executor::block_on(async {
449449
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
450450
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -481,7 +481,7 @@ impl<PdC: PdClient> Transaction<PdC> {
481481
/// ```rust,no_run
482482
/// # use tikv_client::{Key, Config, TransactionClient};
483483
/// # use futures::prelude::*;
484-
/// use tikv_client::request::request_codec::TxnApiV1;
484+
/// use tikv_client::request::codec::TxnApiV1;
485485
/// # futures::executor::block_on(async {
486486
/// # let client = TransactionClient::new(vec!["192.168.0.100", "192.168.0.101"], TxnApiV1, None).await.unwrap();
487487
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -517,7 +517,7 @@ impl<PdC: PdClient> Transaction<PdC> {
517517
/// ```rust,no_run
518518
/// # use tikv_client::{Config, TransactionClient};
519519
/// # use futures::prelude::*;
520-
/// use tikv_client::request::request_codec::TxnApiV1;
520+
/// use tikv_client::request::codec::TxnApiV1;
521521
/// # futures::executor::block_on(async {
522522
/// # let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None).await.unwrap();
523523
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -554,7 +554,7 @@ impl<PdC: PdClient> Transaction<PdC> {
554554
/// ```rust,no_run
555555
/// # use tikv_client::{Config, Timestamp, TransactionClient};
556556
/// # use futures::prelude::*;
557-
/// use tikv_client::request::request_codec::TxnApiV1;
557+
/// use tikv_client::request::codec::TxnApiV1;
558558
/// # futures::executor::block_on(async {
559559
/// # let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None).await.unwrap();
560560
/// let mut txn = client.begin_optimistic().await.unwrap();
@@ -613,7 +613,7 @@ impl<PdC: PdClient> Transaction<PdC> {
613613
/// ```rust,no_run
614614
/// # use tikv_client::{Config, Timestamp, TransactionClient};
615615
/// # use futures::prelude::*;
616-
/// use tikv_client::request::request_codec::TxnApiV1;
616+
/// use tikv_client::request::codec::TxnApiV1;
617617
/// # futures::executor::block_on(async {
618618
/// # let client = TransactionClient::new(vec!["192.168.0.100"], TxnApiV1, None).await.unwrap();
619619
/// let mut txn = client.begin_optimistic().await.unwrap();

0 commit comments

Comments
 (0)