Struct pd_client::DummyPdClient

pub struct DummyPdClient {
    pub next_ts: TimeStamp,
}

Fields

next_ts: TimeStamp

Implementations

impl DummyPdClient

pub fn new() -> DummyPdClient

Trait Implementations

impl PdClient for DummyPdClient

fn get_tso(&self) -> PdFuture<TimeStamp>

Gets a timestamp from PD.

fn get_cluster_id(&self) -> Result<u64>

Returns the cluster ID.

fn bootstrap_cluster(
    &self,
    _stores: Store,
    _region: Region
) -> Result<Option<ReplicationStatus>>

Creates the cluster with cluster ID, node, stores and first Region. If the cluster is already bootstrapped, return ClusterBootstrapped error. When a node starts, if it finds nothing in the node and cluster is not bootstrapped, it begins to create node, stores, first Region and then call bootstrap_cluster to let PD know it. It may happen that multi nodes start at same time to try to bootstrap, but only one can succeed, while others will fail and must remove their created local Region data themselves.

fn is_cluster_bootstrapped(&self) -> Result<bool>

Returns whether the cluster is bootstrapped or not.

fn alloc_id(&self) -> Result<u64>

Allocates a unique positive id.

fn put_store(&self, _store: Store) -> Result<Option<ReplicationStatus>>

Informs PD when the store starts or some store information changes.

fn get_store(&self, _store_id: u64) -> Result<Store>

We don’t need to support Region and Peer put/delete, because PD knows all Region and Peers itself:

fn get_store_async(&self, _store_id: u64) -> PdFuture<Store>

Gets store information if it is not a tombstone store asynchronously

fn get_all_stores(&self, _exclude_tombstone: bool) -> Result<Vec<Store>>

Gets all stores information.

fn get_cluster_config(&self) -> Result<Cluster>

Gets cluster meta information.

fn get_region(&self, _key: &[u8]) -> Result<Region>

For route. Gets Region which the key belongs to.

fn get_region_async<'k>(
    &'k self,
    _key: &'k [u8]
) -> BoxFuture<'k, Result<Region>>

Gets Region which the key belongs to asynchronously.

fn get_region_info(&self, _key: &[u8]) -> Result<RegionInfo>

Gets Region info which the key belongs to.

fn get_region_info_async<'k>(
    &'k self,
    _key: &'k [u8]
) -> BoxFuture<'k, Result<RegionInfo>>

Gets Region info which the key belongs to asynchronously.

fn get_region_by_id(&self, _region_id: u64) -> PdFuture<Option<Region>>

Gets Region by Region id.

fn get_region_leader_by_id(
    &self,
    _region_id: u64
) -> PdFuture<Option<(Region, Peer)>>

Gets Region and its leader by Region id.

fn region_heartbeat(
    &self,
    _term: u64,
    _region: Region,
    _leader: Peer,
    _region_stat: RegionStat,
    _replication_status: Option<RegionReplicationStatus>
) -> PdFuture<()>

Region’s Leader uses this to heartbeat PD.

fn handle_region_heartbeat_response<F>(
    &self,
    _store_id: u64,
    _f: F
) -> PdFuture<()> where
    Self: Sized,
    F: Fn(RegionHeartbeatResponse) + Send + 'static, 

Gets a stream of Region heartbeat response.

fn ask_split(&self, _region: Region) -> PdFuture<AskSplitResponse>

Asks PD for split. PD returns the newly split Region id.

fn ask_batch_split(
    &self,
    _region: Region,
    _count: usize
) -> PdFuture<AskBatchSplitResponse>

Asks PD for batch split. PD returns the newly split Region ids.

fn store_heartbeat(
    &self,
    _stats: StoreStats
) -> PdFuture<StoreHeartbeatResponse>

Sends store statistics regularly.

fn report_batch_split(&self, _regions: Vec<Region>) -> PdFuture<()>

Reports PD the split Region.

fn scatter_region(&self, _: RegionInfo) -> Result<()>

Scatters the Region across the cluster.

fn handle_reconnect<F: Fn() + Sync + Send + 'static>(&self, _: F) where
    Self: Sized, 

Registers a handler to the client, which will be invoked after reconnecting to PD.

fn get_gc_safe_point(&self) -> PdFuture<u64>

fn get_store_stats_async(
    &self,
    _store_id: u64
) -> BoxFuture<'_, Result<StoreStats>>

Gets store state if it is not a tombstone store asynchronously.

fn get_operator(&self, _region_id: u64) -> Result<GetOperatorResponse>

Gets current operator of the region

fn feature_gate(&self) -> &FeatureGate

Gets the internal FeatureGate.