Struct kvproto::pdpb::PdClient[−][src]

pub struct PdClient { /* fields omitted */ }

Implementations

impl PdClient[src]

pub fn new(channel: Channel) -> Self[src]

pub fn get_members_opt(
    &self,
    req: &GetMembersRequest,
    opt: CallOption
) -> Result<GetMembersResponse>[src]

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

pub fn get_members_async_opt(
    &self,
    req: &GetMembersRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetMembersResponse>>[src]

pub fn get_members_async(
    &self,
    req: &GetMembersRequest
) -> Result<ClientUnaryReceiver<GetMembersResponse>>[src]

pub fn tso_opt(
    &self,
    opt: CallOption
) -> Result<(ClientDuplexSender<TsoRequest>, ClientDuplexReceiver<TsoResponse>)>[src]

pub fn tso(
    &self
) -> Result<(ClientDuplexSender<TsoRequest>, ClientDuplexReceiver<TsoResponse>)>[src]

pub fn bootstrap_opt(
    &self,
    req: &BootstrapRequest,
    opt: CallOption
) -> Result<BootstrapResponse>[src]

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

pub fn bootstrap_async_opt(
    &self,
    req: &BootstrapRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<BootstrapResponse>>[src]

pub fn bootstrap_async(
    &self,
    req: &BootstrapRequest
) -> Result<ClientUnaryReceiver<BootstrapResponse>>[src]

pub fn is_bootstrapped_opt(
    &self,
    req: &IsBootstrappedRequest,
    opt: CallOption
) -> Result<IsBootstrappedResponse>[src]

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

pub fn is_bootstrapped_async_opt(
    &self,
    req: &IsBootstrappedRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<IsBootstrappedResponse>>[src]

pub fn is_bootstrapped_async(
    &self,
    req: &IsBootstrappedRequest
) -> Result<ClientUnaryReceiver<IsBootstrappedResponse>>[src]

pub fn alloc_id_opt(
    &self,
    req: &AllocIdRequest,
    opt: CallOption
) -> Result<AllocIdResponse>[src]

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

pub fn alloc_id_async_opt(
    &self,
    req: &AllocIdRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<AllocIdResponse>>[src]

pub fn alloc_id_async(
    &self,
    req: &AllocIdRequest
) -> Result<ClientUnaryReceiver<AllocIdResponse>>[src]

pub fn get_store_opt(
    &self,
    req: &GetStoreRequest,
    opt: CallOption
) -> Result<GetStoreResponse>[src]

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

pub fn get_store_async_opt(
    &self,
    req: &GetStoreRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetStoreResponse>>[src]

pub fn get_store_async(
    &self,
    req: &GetStoreRequest
) -> Result<ClientUnaryReceiver<GetStoreResponse>>[src]

pub fn put_store_opt(
    &self,
    req: &PutStoreRequest,
    opt: CallOption
) -> Result<PutStoreResponse>[src]

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

pub fn put_store_async_opt(
    &self,
    req: &PutStoreRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PutStoreResponse>>[src]

pub fn put_store_async(
    &self,
    req: &PutStoreRequest
) -> Result<ClientUnaryReceiver<PutStoreResponse>>[src]

pub fn get_all_stores_opt(
    &self,
    req: &GetAllStoresRequest,
    opt: CallOption
) -> Result<GetAllStoresResponse>[src]

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

pub fn get_all_stores_async_opt(
    &self,
    req: &GetAllStoresRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetAllStoresResponse>>[src]

pub fn get_all_stores_async(
    &self,
    req: &GetAllStoresRequest
) -> Result<ClientUnaryReceiver<GetAllStoresResponse>>[src]

pub fn store_heartbeat_opt(
    &self,
    req: &StoreHeartbeatRequest,
    opt: CallOption
) -> Result<StoreHeartbeatResponse>[src]

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

pub fn store_heartbeat_async_opt(
    &self,
    req: &StoreHeartbeatRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<StoreHeartbeatResponse>>[src]

pub fn store_heartbeat_async(
    &self,
    req: &StoreHeartbeatRequest
) -> Result<ClientUnaryReceiver<StoreHeartbeatResponse>>[src]

pub fn region_heartbeat_opt(
    &self,
    opt: CallOption
) -> Result<(ClientDuplexSender<RegionHeartbeatRequest>, ClientDuplexReceiver<RegionHeartbeatResponse>)>[src]

pub fn region_heartbeat(
    &self
) -> Result<(ClientDuplexSender<RegionHeartbeatRequest>, ClientDuplexReceiver<RegionHeartbeatResponse>)>[src]

pub fn get_region_opt(
    &self,
    req: &GetRegionRequest,
    opt: CallOption
) -> Result<GetRegionResponse>[src]

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

pub fn get_region_async_opt(
    &self,
    req: &GetRegionRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn get_region_async(
    &self,
    req: &GetRegionRequest
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn get_prev_region_opt(
    &self,
    req: &GetRegionRequest,
    opt: CallOption
) -> Result<GetRegionResponse>[src]

pub fn get_prev_region(
    &self,
    req: &GetRegionRequest
) -> Result<GetRegionResponse>[src]

pub fn get_prev_region_async_opt(
    &self,
    req: &GetRegionRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn get_prev_region_async(
    &self,
    req: &GetRegionRequest
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn get_region_by_id_opt(
    &self,
    req: &GetRegionByIdRequest,
    opt: CallOption
) -> Result<GetRegionResponse>[src]

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

pub fn get_region_by_id_async_opt(
    &self,
    req: &GetRegionByIdRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn get_region_by_id_async(
    &self,
    req: &GetRegionByIdRequest
) -> Result<ClientUnaryReceiver<GetRegionResponse>>[src]

pub fn scan_regions_opt(
    &self,
    req: &ScanRegionsRequest,
    opt: CallOption
) -> Result<ScanRegionsResponse>[src]

pub fn scan_regions(
    &self,
    req: &ScanRegionsRequest
) -> Result<ScanRegionsResponse>[src]

pub fn scan_regions_async_opt(
    &self,
    req: &ScanRegionsRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ScanRegionsResponse>>[src]

pub fn scan_regions_async(
    &self,
    req: &ScanRegionsRequest
) -> Result<ClientUnaryReceiver<ScanRegionsResponse>>[src]

pub fn ask_split_opt(
    &self,
    req: &AskSplitRequest,
    opt: CallOption
) -> Result<AskSplitResponse>[src]

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

pub fn ask_split_async_opt(
    &self,
    req: &AskSplitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<AskSplitResponse>>[src]

pub fn ask_split_async(
    &self,
    req: &AskSplitRequest
) -> Result<ClientUnaryReceiver<AskSplitResponse>>[src]

pub fn report_split_opt(
    &self,
    req: &ReportSplitRequest,
    opt: CallOption
) -> Result<ReportSplitResponse>[src]

pub fn report_split(
    &self,
    req: &ReportSplitRequest
) -> Result<ReportSplitResponse>[src]

pub fn report_split_async_opt(
    &self,
    req: &ReportSplitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ReportSplitResponse>>[src]

pub fn report_split_async(
    &self,
    req: &ReportSplitRequest
) -> Result<ClientUnaryReceiver<ReportSplitResponse>>[src]

pub fn ask_batch_split_opt(
    &self,
    req: &AskBatchSplitRequest,
    opt: CallOption
) -> Result<AskBatchSplitResponse>[src]

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

pub fn ask_batch_split_async_opt(
    &self,
    req: &AskBatchSplitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<AskBatchSplitResponse>>[src]

pub fn ask_batch_split_async(
    &self,
    req: &AskBatchSplitRequest
) -> Result<ClientUnaryReceiver<AskBatchSplitResponse>>[src]

pub fn report_batch_split_opt(
    &self,
    req: &ReportBatchSplitRequest,
    opt: CallOption
) -> Result<ReportBatchSplitResponse>[src]

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

pub fn report_batch_split_async_opt(
    &self,
    req: &ReportBatchSplitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ReportBatchSplitResponse>>[src]

pub fn report_batch_split_async(
    &self,
    req: &ReportBatchSplitRequest
) -> Result<ClientUnaryReceiver<ReportBatchSplitResponse>>[src]

pub fn get_cluster_config_opt(
    &self,
    req: &GetClusterConfigRequest,
    opt: CallOption
) -> Result<GetClusterConfigResponse>[src]

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

pub fn get_cluster_config_async_opt(
    &self,
    req: &GetClusterConfigRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetClusterConfigResponse>>[src]

pub fn get_cluster_config_async(
    &self,
    req: &GetClusterConfigRequest
) -> Result<ClientUnaryReceiver<GetClusterConfigResponse>>[src]

pub fn put_cluster_config_opt(
    &self,
    req: &PutClusterConfigRequest,
    opt: CallOption
) -> Result<PutClusterConfigResponse>[src]

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

pub fn put_cluster_config_async_opt(
    &self,
    req: &PutClusterConfigRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PutClusterConfigResponse>>[src]

pub fn put_cluster_config_async(
    &self,
    req: &PutClusterConfigRequest
) -> Result<ClientUnaryReceiver<PutClusterConfigResponse>>[src]

pub fn scatter_region_opt(
    &self,
    req: &ScatterRegionRequest,
    opt: CallOption
) -> Result<ScatterRegionResponse>[src]

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

pub fn scatter_region_async_opt(
    &self,
    req: &ScatterRegionRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ScatterRegionResponse>>[src]

pub fn scatter_region_async(
    &self,
    req: &ScatterRegionRequest
) -> Result<ClientUnaryReceiver<ScatterRegionResponse>>[src]

pub fn get_gc_safe_point_opt(
    &self,
    req: &GetGcSafePointRequest,
    opt: CallOption
) -> Result<GetGcSafePointResponse>[src]

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

pub fn get_gc_safe_point_async_opt(
    &self,
    req: &GetGcSafePointRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetGcSafePointResponse>>[src]

pub fn get_gc_safe_point_async(
    &self,
    req: &GetGcSafePointRequest
) -> Result<ClientUnaryReceiver<GetGcSafePointResponse>>[src]

pub fn update_gc_safe_point_opt(
    &self,
    req: &UpdateGcSafePointRequest,
    opt: CallOption
) -> Result<UpdateGcSafePointResponse>[src]

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

pub fn update_gc_safe_point_async_opt(
    &self,
    req: &UpdateGcSafePointRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<UpdateGcSafePointResponse>>[src]

pub fn update_gc_safe_point_async(
    &self,
    req: &UpdateGcSafePointRequest
) -> Result<ClientUnaryReceiver<UpdateGcSafePointResponse>>[src]

pub fn update_service_gc_safe_point_opt(
    &self,
    req: &UpdateServiceGcSafePointRequest,
    opt: CallOption
) -> Result<UpdateServiceGcSafePointResponse>[src]

pub fn update_service_gc_safe_point(
    &self,
    req: &UpdateServiceGcSafePointRequest
) -> Result<UpdateServiceGcSafePointResponse>[src]

pub fn update_service_gc_safe_point_async_opt(
    &self,
    req: &UpdateServiceGcSafePointRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<UpdateServiceGcSafePointResponse>>[src]

pub fn update_service_gc_safe_point_async(
    &self,
    req: &UpdateServiceGcSafePointRequest
) -> Result<ClientUnaryReceiver<UpdateServiceGcSafePointResponse>>[src]

pub fn sync_regions_opt(
    &self,
    opt: CallOption
) -> Result<(ClientDuplexSender<SyncRegionRequest>, ClientDuplexReceiver<SyncRegionResponse>)>[src]

pub fn sync_regions(
    &self
) -> Result<(ClientDuplexSender<SyncRegionRequest>, ClientDuplexReceiver<SyncRegionResponse>)>[src]

pub fn get_operator_opt(
    &self,
    req: &GetOperatorRequest,
    opt: CallOption
) -> Result<GetOperatorResponse>[src]

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

pub fn get_operator_async_opt(
    &self,
    req: &GetOperatorRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetOperatorResponse>>[src]

pub fn get_operator_async(
    &self,
    req: &GetOperatorRequest
) -> Result<ClientUnaryReceiver<GetOperatorResponse>>[src]

pub fn sync_max_ts_opt(
    &self,
    req: &SyncMaxTsRequest,
    opt: CallOption
) -> Result<SyncMaxTsResponse>[src]

pub fn sync_max_ts(&self, req: &SyncMaxTsRequest) -> Result<SyncMaxTsResponse>[src]

pub fn sync_max_ts_async_opt(
    &self,
    req: &SyncMaxTsRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<SyncMaxTsResponse>>[src]

pub fn sync_max_ts_async(
    &self,
    req: &SyncMaxTsRequest
) -> Result<ClientUnaryReceiver<SyncMaxTsResponse>>[src]

pub fn split_regions_opt(
    &self,
    req: &SplitRegionsRequest,
    opt: CallOption
) -> Result<SplitRegionsResponse>[src]

pub fn split_regions(
    &self,
    req: &SplitRegionsRequest
) -> Result<SplitRegionsResponse>[src]

pub fn split_regions_async_opt(
    &self,
    req: &SplitRegionsRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<SplitRegionsResponse>>[src]

pub fn split_regions_async(
    &self,
    req: &SplitRegionsRequest
) -> Result<ClientUnaryReceiver<SplitRegionsResponse>>[src]

pub fn get_dc_location_info_opt(
    &self,
    req: &GetDcLocationInfoRequest,
    opt: CallOption
) -> Result<GetDcLocationInfoResponse>[src]

pub fn get_dc_location_info(
    &self,
    req: &GetDcLocationInfoRequest
) -> Result<GetDcLocationInfoResponse>[src]

pub fn get_dc_location_info_async_opt(
    &self,
    req: &GetDcLocationInfoRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetDcLocationInfoResponse>>[src]

pub fn get_dc_location_info_async(
    &self,
    req: &GetDcLocationInfoRequest
) -> Result<ClientUnaryReceiver<GetDcLocationInfoResponse>>[src]

pub fn spawn<F>(&self, f: F) where
    F: Future<Output = ()> + Send + 'static, [src]

Trait Implementations

impl Clone for PdClient[src]

Auto Trait Implementations

impl !RefUnwindSafe for PdClient

impl Send for PdClient

impl Sync for PdClient

impl Unpin for PdClient

impl !UnwindSafe for PdClient

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T> ToOwned for T where
    T: Clone, [src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.