Struct tikv_client_proto::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]

fn clone(&self) -> PdClient[src]

Returns a copy of the value. Read more

fn clone_from(&mut self, source: &Self)1.0.0[src]

Performs copy-assignment from source. Read more

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]

pub fn type_id(&self) -> TypeId[src]

Gets the TypeId of self. Read more

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

pub fn borrow(&self) -> &T[src]

Immutably borrows from an owned value. Read more

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

pub fn borrow_mut(&mut self) -> &mut T[src]

Mutably borrows from an owned value. Read more

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

pub fn from(t: T) -> T[src]

Performs the conversion.

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

pub fn into(self) -> U[src]

Performs the conversion.

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

type Owned = T

The resulting type after obtaining ownership.

pub fn to_owned(&self) -> T[src]

Creates owned data from borrowed data, usually by cloning. Read more

pub fn clone_into(&self, target: &mut T)[src]

🔬 This is a nightly-only experimental API. (toowned_clone_into)

recently added

Uses borrowed data to replace owned data, usually by cloning. Read more

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.

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

Performs the conversion.

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.

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

Performs the conversion.