Struct test_pd::mocker::service::Service

[+] Show declaration

pub struct Service {
    id_allocator: AtomicUsize,
    members_resp: Mutex<Option<GetMembersResponse>>,
    is_bootstrapped: AtomicBool,
    stores: Mutex<HashMap<u64, Store>>,
    regions: Mutex<HashMap<u64, Region>>,
    leaders: Mutex<HashMap<u64, Peer>>,
    feature_gate: Mutex<String>,
}

Fields

id_allocator: AtomicUsize

members_resp: Mutex<Option<GetMembersResponse>>

is_bootstrapped: AtomicBool

stores: Mutex<HashMap<u64, Store>>

regions: Mutex<HashMap<u64, Region>>

leaders: Mutex<HashMap<u64, Peer>>

feature_gate: Mutex<String>

Implementations

impl Service[−]

pub fn new() -> Service

pub fn header() -> ResponseHeader

pub fn add_store(&self, store: Store)[−]

Add an arbitrary store.

pub fn set_cluster_version(&self, version: String)

Trait Implementations

impl Debug for Service[+]

[+] Show hidden undocumented items

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

Formats the value using the given formatter.

impl PdMocker for Service[+]

[+] Show hidden undocumented items

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

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

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

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

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

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

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

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

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

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

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 scatter_region(
    &self,
    _: &ScatterRegionRequest
) -> Option<Result<ScatterRegionResponse>>

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

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

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

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

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

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

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

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