Trait test_pd::mocker::PdMocker[−][src]

pub trait PdMocker {
    fn get_members(
        &self, 
        _: &GetMembersRequest
    ) -> Option<Result<GetMembersResponse>> { ... }

    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 get_region_by_id(
        &self, 
        _: &GetRegionByIdRequest
    ) -> 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 set_endpoints(&self, _: Vec<String>) { ... }

    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>> { ... }
}

Provided methods

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

fn set_endpoints(&self, _: Vec<String>)[src]

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

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

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

Loading content...

Implementors

impl PdMocker for AlreadyBootstrapped[src]

impl PdMocker for Incompatible[src]

impl PdMocker for LeaderChange[src]

impl PdMocker for NotRetry[src]

impl PdMocker for Retry[src]

impl PdMocker for Service[src]

impl PdMocker for Split[src]

Loading content...