Move region and store from common to store crate

Signed-off-by: Nick Cameron <nrc@ncameron.org>
This commit is contained in:
Nick Cameron 2020-07-23 21:05:50 +12:00
parent a70aa203b0
commit d110ad1ecb
9 changed files with 21 additions and 21 deletions

View File

@ -100,3 +100,5 @@ pub use crate::transaction::{Client as TransactionClient, Snapshot, Transaction}
pub use tikv_client_common::{ pub use tikv_client_common::{
BoundRange, Config, Error, ErrorKind, Key, KvPair, Result, Timestamp, ToOwnedRange, Value, BoundRange, Config, Error, ErrorKind, Key, KvPair, Result, Timestamp, ToOwnedRange, Value,
}; };
#[doc(inline)]
pub use tikv_client_store::region::{Region, RegionId, RegionVerId, StoreId};

View File

@ -15,8 +15,7 @@ use futures::future::{ready, BoxFuture, FutureExt};
use grpcio::CallOption; use grpcio::CallOption;
use kvproto::{errorpb, kvrpcpb, metapb, tikvpb::TikvClient}; use kvproto::{errorpb, kvrpcpb, metapb, tikvpb::TikvClient};
use std::{future::Future, sync::Arc, time::Duration}; use std::{future::Future, sync::Arc, time::Duration};
use tikv_client_common::{Region, RegionId}; use tikv_client_store::{HasError, KvClient, KvConnect, Region, RegionId, Store};
use tikv_client_store::{HasError, KvClient, KvConnect, Store};
/// Create a `PdRpcClient` with it's internals replaced with mocks so that the /// Create a `PdRpcClient` with it's internals replaced with mocks so that the
/// client can be tested without doing any RPC calls. /// client can be tested without doing any RPC calls.

View File

@ -1,6 +1,6 @@
// Copyright 2018 TiKV Project Authors. Licensed under Apache-2.0. // Copyright 2018 TiKV Project Authors. Licensed under Apache-2.0.
use crate::{pd::RetryClient, Config, Key}; use crate::{pd::RetryClient, Config, Key, Region, RegionId};
use futures::{ use futures::{
future::{ready, BoxFuture, Either}, future::{ready, BoxFuture, Either},
prelude::*, prelude::*,
@ -15,7 +15,7 @@ use std::{
use tikv_client_common::{ use tikv_client_common::{
compat::{stream_fn, ClientFutureExt}, compat::{stream_fn, ClientFutureExt},
security::SecurityManager, security::SecurityManager,
BoundRange, Region, RegionId, Result, Timestamp, BoundRange, Result, Timestamp,
}; };
use tikv_client_pd::Cluster; use tikv_client_pd::Cluster;
use tikv_client_store::{KvClient, KvConnect, Store, TikvConnect}; use tikv_client_store::{KvClient, KvConnect, Store, TikvConnect};

View File

@ -2,6 +2,8 @@
//! A utility module for managing and retrying PD requests. //! A utility module for managing and retrying PD requests.
use crate::{Region, RegionId, StoreId};
use async_trait::async_trait; use async_trait::async_trait;
use futures_timer::Delay; use futures_timer::Delay;
use grpcio::Environment; use grpcio::Environment;
@ -11,9 +13,7 @@ use std::{
sync::Arc, sync::Arc,
time::{Duration, Instant}, time::{Duration, Instant},
}; };
use tikv_client_common::{ use tikv_client_common::{security::SecurityManager, stats::pd_stats, Error, Result, Timestamp};
security::SecurityManager, stats::pd_stats, Error, Region, RegionId, Result, StoreId, Timestamp,
};
use tikv_client_pd::cluster::{Cluster, Connection}; use tikv_client_pd::cluster::{Cluster, Connection};
use tokio::sync::RwLock; use tokio::sync::RwLock;

View File

@ -1,10 +1,10 @@
use crate::{pd::PdClient, request::KvRequest, transaction::requests}; use crate::{pd::PdClient, request::KvRequest, transaction::requests, RegionVerId};
use kvproto::kvrpcpb; use kvproto::kvrpcpb;
use std::{ use std::{
collections::{HashMap, HashSet}, collections::{HashMap, HashSet},
sync::Arc, sync::Arc,
}; };
use tikv_client_common::{timestamp::TimestampExt, ErrorKind, Key, RegionVerId, Result, Timestamp}; use tikv_client_common::{timestamp::TimestampExt, ErrorKind, Key, Result, Timestamp};
const RESOLVE_LOCK_RETRY_LIMIT: usize = 10; const RESOLVE_LOCK_RETRY_LIMIT: usize = 10;

View File

@ -4,10 +4,8 @@ pub mod compat;
pub mod config; pub mod config;
pub mod errors; pub mod errors;
pub mod kv; pub mod kv;
pub mod region;
pub mod security; pub mod security;
pub mod stats; pub mod stats;
pub mod store_builder;
pub mod timestamp; pub mod timestamp;
#[macro_use] #[macro_use]
@ -28,8 +26,4 @@ pub use crate::errors::Result;
#[doc(inline)] #[doc(inline)]
pub use crate::kv::{BoundRange, Key, KvPair, ToOwnedRange, Value}; pub use crate::kv::{BoundRange, Key, KvPair, ToOwnedRange, Value};
#[doc(inline)] #[doc(inline)]
pub use crate::region::{Region, RegionId, RegionVerId, StoreId};
#[doc(inline)]
pub use crate::store_builder::StoreBuilder;
#[doc(inline)]
pub use crate::timestamp::Timestamp; pub use crate::timestamp::Timestamp;

View File

@ -4,16 +4,21 @@
extern crate log; extern crate log;
mod errors; mod errors;
pub mod region;
mod store_builder;
pub use crate::errors::{HasError, HasRegionError};
#[doc(inline)]
pub use crate::region::{Region, RegionId, RegionVerId, StoreId};
#[doc(inline)]
pub use crate::store_builder::StoreBuilder;
pub use kvproto::tikvpb::TikvClient;
pub use self::errors::{HasError, HasRegionError};
use derive_new::new; use derive_new::new;
use futures::{future::BoxFuture, prelude::*}; use futures::{future::BoxFuture, prelude::*};
use grpcio::{CallOption, Environment}; use grpcio::{CallOption, Environment};
pub use kvproto::tikvpb::TikvClient;
use std::{sync::Arc, time::Duration}; use std::{sync::Arc, time::Duration};
use tikv_client_common::{ use tikv_client_common::{security::SecurityManager, stats::tikv_stats, ErrorKind, Result};
security::SecurityManager, stats::tikv_stats, ErrorKind, Region, Result, StoreBuilder,
};
/// A trait for connecting to TiKV stores. /// A trait for connecting to TiKV stores.
pub trait KvConnect: Sized + Send + Sync + 'static { pub trait KvConnect: Sized + Send + Sync + 'static {

View File

@ -1,6 +1,6 @@
use crate::{Error, Key, Result};
use derive_new::new; use derive_new::new;
use kvproto::{kvrpcpb, metapb}; use kvproto::{kvrpcpb, metapb};
use tikv_client_common::{Error, Key, Result};
pub type RegionId = u64; pub type RegionId = u64;
pub type StoreId = u64; pub type StoreId = u64;