Struct test_pd::server::PdMock

[+] Show declaration

struct PdMock<C: PdMocker> {
    default_handler: Arc<Service>,
    case: Option<Arc<C>>,
}

Fields

default_handler: Arc<Service>

case: Option<Arc<C>>

Trait Implementations

impl<C: PdMocker> Clone for PdMock<C>[+]

[+] Show hidden undocumented items

fn clone(&self) -> Self[−]

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.

impl<C: Debug + PdMocker> Debug for PdMock<C>[+]

[+] Show hidden undocumented items

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

Formats the value using the given formatter.

impl<C: PdMocker + Send + Sync + 'static> Pd for PdMock<C>[+]

[+] Show hidden undocumented items

fn get_members(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetMembersRequest,
    sink: UnarySink<GetMembersResponse>
)

fn tso(
    &mut self,
    ctx: RpcContext<'_>,
    req: RequestStream<TsoRequest>,
    resp: DuplexSink<TsoResponse>
)

fn bootstrap(
    &mut self,
    ctx: RpcContext<'_>,
    req: BootstrapRequest,
    sink: UnarySink<BootstrapResponse>
)

fn is_bootstrapped(
    &mut self,
    ctx: RpcContext<'_>,
    req: IsBootstrappedRequest,
    sink: UnarySink<IsBootstrappedResponse>
)

fn alloc_id(
    &mut self,
    ctx: RpcContext<'_>,
    req: AllocIdRequest,
    sink: UnarySink<AllocIdResponse>
)

fn get_store(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetStoreRequest,
    sink: UnarySink<GetStoreResponse>
)

fn put_store(
    &mut self,
    ctx: RpcContext<'_>,
    req: PutStoreRequest,
    sink: UnarySink<PutStoreResponse>
)

fn get_all_stores(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetAllStoresRequest,
    sink: UnarySink<GetAllStoresResponse>
)

fn store_heartbeat(
    &mut self,
    ctx: RpcContext<'_>,
    req: StoreHeartbeatRequest,
    sink: UnarySink<StoreHeartbeatResponse>
)

fn region_heartbeat(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<RegionHeartbeatRequest>,
    sink: DuplexSink<RegionHeartbeatResponse>
)

fn get_region(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetRegionRequest,
    sink: UnarySink<GetRegionResponse>
)

fn get_region_by_id(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetRegionByIdRequest,
    sink: UnarySink<GetRegionResponse>
)

fn ask_split(
    &mut self,
    ctx: RpcContext<'_>,
    req: AskSplitRequest,
    sink: UnarySink<AskSplitResponse>
)

fn report_split(
    &mut self,
    _: RpcContext<'_>,
    _: ReportSplitRequest,
    _: UnarySink<ReportSplitResponse>
)

fn ask_batch_split(
    &mut self,
    ctx: RpcContext<'_>,
    req: AskBatchSplitRequest,
    sink: UnarySink<AskBatchSplitResponse>
)

fn report_batch_split(
    &mut self,
    ctx: RpcContext<'_>,
    req: ReportBatchSplitRequest,
    sink: UnarySink<ReportBatchSplitResponse>
)

fn get_cluster_config(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetClusterConfigRequest,
    sink: UnarySink<GetClusterConfigResponse>
)

fn put_cluster_config(
    &mut self,
    ctx: RpcContext<'_>,
    req: PutClusterConfigRequest,
    sink: UnarySink<PutClusterConfigResponse>
)

fn scatter_region(
    &mut self,
    ctx: RpcContext<'_>,
    req: ScatterRegionRequest,
    sink: UnarySink<ScatterRegionResponse>
)

fn get_prev_region(
    &mut self,
    _: RpcContext<'_>,
    _: GetRegionRequest,
    _: UnarySink<GetRegionResponse>
)

fn get_gc_safe_point(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetGcSafePointRequest,
    sink: UnarySink<GetGcSafePointResponse>
)

fn update_gc_safe_point(
    &mut self,
    ctx: RpcContext<'_>,
    req: UpdateGcSafePointRequest,
    sink: UnarySink<UpdateGcSafePointResponse>
)

fn sync_regions(
    &mut self,
    _ctx: RpcContext<'_>,
    _stream: RequestStream<SyncRegionRequest>,
    _sink: DuplexSink<SyncRegionResponse>
)

fn get_operator(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetOperatorRequest,
    sink: UnarySink<GetOperatorResponse>
)

fn scan_regions(
    &mut self,
    _ctx: RpcContext<'_>,
    _req: ScanRegionsRequest,
    _sink: UnarySink<ScanRegionsResponse>
)

fn update_service_gc_safe_point(
    &mut self,
    _ctx: RpcContext<'_>,
    _req: UpdateServiceGcSafePointRequest,
    _sink: UnarySink<UpdateServiceGcSafePointResponse>
)

fn sync_max_ts(
    &mut self,
    _ctx: RpcContext<'_>,
    _req: SyncMaxTsRequest,
    _sink: UnarySink<SyncMaxTsResponse>
)

fn split_regions(
    &mut self,
    _: RpcContext<'_>,
    _: SplitRegionsRequest,
    _: UnarySink<SplitRegionsResponse>
)

fn get_dc_location_info(
    &mut self,
    _: RpcContext<'_>,
    _: GetDcLocationInfoRequest,
    _: UnarySink<GetDcLocationInfoResponse>
)