Trait kvproto::pdpb::Pd[−][src]

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

    fn tso(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<TsoRequest>, 
        sink: 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_prev_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 scan_regions(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: ScanRegionsRequest, 
        sink: UnarySink<ScanRegionsResponse>
    );

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

    fn report_split(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: ReportSplitRequest, 
        sink: 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_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 update_service_gc_safe_point(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: UpdateServiceGcSafePointRequest, 
        sink: UnarySink<UpdateServiceGcSafePointResponse>
    );

    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 sync_max_ts(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: SyncMaxTsRequest, 
        sink: UnarySink<SyncMaxTsResponse>
    );

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

    fn get_dc_location_info(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: GetDcLocationInfoRequest, 
        sink: UnarySink<GetDcLocationInfoResponse>
    );
}

Required methods

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

fn tso(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<TsoRequest>,
    sink: DuplexSink<TsoResponse>
)[src]

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

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

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

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

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

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

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

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

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

fn get_prev_region(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetRegionRequest,
    sink: UnarySink<GetRegionResponse>
)[src]

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

fn scan_regions(
    &mut self,
    ctx: RpcContext<'_>,
    req: ScanRegionsRequest,
    sink: UnarySink<ScanRegionsResponse>
)[src]

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

fn report_split(
    &mut self,
    ctx: RpcContext<'_>,
    req: ReportSplitRequest,
    sink: UnarySink<ReportSplitResponse>
)[src]

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

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

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

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

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

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

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

fn update_service_gc_safe_point(
    &mut self,
    ctx: RpcContext<'_>,
    req: UpdateServiceGcSafePointRequest,
    sink: UnarySink<UpdateServiceGcSafePointResponse>
)[src]

fn sync_regions(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<SyncRegionRequest>,
    sink: DuplexSink<SyncRegionResponse>
)[src]

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

fn sync_max_ts(
    &mut self,
    ctx: RpcContext<'_>,
    req: SyncMaxTsRequest,
    sink: UnarySink<SyncMaxTsResponse>
)[src]

fn split_regions(
    &mut self,
    ctx: RpcContext<'_>,
    req: SplitRegionsRequest,
    sink: UnarySink<SplitRegionsResponse>
)[src]

fn get_dc_location_info(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetDcLocationInfoRequest,
    sink: UnarySink<GetDcLocationInfoResponse>
)[src]

Loading content...

Implementors

Loading content...