Struct test_pd::mocker::leader_change::LeaderChange

[+] Show declaration

pub struct LeaderChange {
    inner: Mutex<Inner>,
}

Fields

inner: Mutex<Inner>

Implementations

impl LeaderChange[−]

pub fn new() -> LeaderChange

pub fn get_leader_interval() -> Duration

Trait Implementations

impl Debug for LeaderChange[+]

[+] Show hidden undocumented items

fn fmt(&self, f: &mut Formatter<'_>) -> Result[−]

Formats the value using the given formatter.

impl PdMocker for LeaderChange[+]

[+] Show hidden undocumented items

fn get_members(
    &self,
    _: &GetMembersRequest
) -> Option<Result<GetMembersResponse>>

fn get_region_by_id(
    &self,
    _: &GetRegionByIdRequest
) -> Option<Result<GetRegionResponse>>

fn set_endpoints(&self, eps: Vec<String>)

fn tso(&self, _: &TsoRequest) -> Option<Result<TsoResponse>>

fn bootstrap(&self, _: &BootstrapRequest) -> Option<Result<BootstrapResponse>>

fn is_bootstrapped(
    &self,
    _: &IsBootstrappedRequest
) -> Option<Result<IsBootstrappedResponse>>

fn alloc_id(&self, _: &AllocIdRequest) -> Option<Result<AllocIdResponse>>

fn get_store(&self, _: &GetStoreRequest) -> Option<Result<GetStoreResponse>>

fn put_store(&self, _: &PutStoreRequest) -> Option<Result<PutStoreResponse>>

fn get_all_stores(
    &self,
    _: &GetAllStoresRequest
) -> Option<Result<GetAllStoresResponse>>

fn store_heartbeat(
    &self,
    _: &StoreHeartbeatRequest
) -> Option<Result<StoreHeartbeatResponse>>

fn region_heartbeat(
    &self,
    _: &RegionHeartbeatRequest
) -> Option<Result<RegionHeartbeatResponse>>

fn get_region(&self, _: &GetRegionRequest) -> Option<Result<GetRegionResponse>>

fn ask_split(&self, _: &AskSplitRequest) -> Option<Result<AskSplitResponse>>

fn ask_batch_split(
    &self,
    _: &AskBatchSplitRequest
) -> Option<Result<AskBatchSplitResponse>>

fn report_batch_split(
    &self,
    _: &ReportBatchSplitRequest
) -> Option<Result<ReportBatchSplitResponse>>

fn get_cluster_config(
    &self,
    _: &GetClusterConfigRequest
) -> Option<Result<GetClusterConfigResponse>>

fn put_cluster_config(
    &self,
    _: &PutClusterConfigRequest
) -> Option<Result<PutClusterConfigResponse>>

fn scatter_region(
    &self,
    _: &ScatterRegionRequest
) -> Option<Result<ScatterRegionResponse>>

fn update_gc_safe_point(
    &self,
    _: &UpdateGcSafePointRequest
) -> Option<Result<UpdateGcSafePointResponse>>

fn get_gc_safe_point(
    &self,
    _: &GetGcSafePointRequest
) -> Option<Result<GetGcSafePointResponse>>

fn get_operator(
    &self,
    _: &GetOperatorRequest
) -> Option<Result<GetOperatorResponse>>