Struct kvproto::tikvpb_grpc::TikvClient[−][src]

pub struct TikvClient { /* fields omitted */ }

Implementations

impl TikvClient[src]

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

pub fn kv_get_opt(
    &self,
    req: &GetRequest,
    opt: CallOption
) -> Result<GetResponse>[src]

pub fn kv_get(&self, req: &GetRequest) -> Result<GetResponse>[src]

pub fn kv_get_async_opt(
    &self,
    req: &GetRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetResponse>>[src]

pub fn kv_get_async(
    &self,
    req: &GetRequest
) -> Result<ClientUnaryReceiver<GetResponse>>[src]

pub fn kv_scan_opt(
    &self,
    req: &ScanRequest,
    opt: CallOption
) -> Result<ScanResponse>[src]

pub fn kv_scan(&self, req: &ScanRequest) -> Result<ScanResponse>[src]

pub fn kv_scan_async_opt(
    &self,
    req: &ScanRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ScanResponse>>[src]

pub fn kv_scan_async(
    &self,
    req: &ScanRequest
) -> Result<ClientUnaryReceiver<ScanResponse>>[src]

pub fn kv_prewrite_opt(
    &self,
    req: &PrewriteRequest,
    opt: CallOption
) -> Result<PrewriteResponse>[src]

pub fn kv_prewrite(&self, req: &PrewriteRequest) -> Result<PrewriteResponse>[src]

pub fn kv_prewrite_async_opt(
    &self,
    req: &PrewriteRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PrewriteResponse>>[src]

pub fn kv_prewrite_async(
    &self,
    req: &PrewriteRequest
) -> Result<ClientUnaryReceiver<PrewriteResponse>>[src]

pub fn kv_pessimistic_lock_opt(
    &self,
    req: &PessimisticLockRequest,
    opt: CallOption
) -> Result<PessimisticLockResponse>[src]

pub fn kv_pessimistic_lock(
    &self,
    req: &PessimisticLockRequest
) -> Result<PessimisticLockResponse>[src]

pub fn kv_pessimistic_lock_async_opt(
    &self,
    req: &PessimisticLockRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PessimisticLockResponse>>[src]

pub fn kv_pessimistic_lock_async(
    &self,
    req: &PessimisticLockRequest
) -> Result<ClientUnaryReceiver<PessimisticLockResponse>>[src]

pub fn kv_pessimistic_rollback_opt(
    &self,
    req: &PessimisticRollbackRequest,
    opt: CallOption
) -> Result<PessimisticRollbackResponse>[src]

pub fn kv_pessimistic_rollback(
    &self,
    req: &PessimisticRollbackRequest
) -> Result<PessimisticRollbackResponse>[src]

pub fn kv_pessimistic_rollback_async_opt(
    &self,
    req: &PessimisticRollbackRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PessimisticRollbackResponse>>[src]

pub fn kv_pessimistic_rollback_async(
    &self,
    req: &PessimisticRollbackRequest
) -> Result<ClientUnaryReceiver<PessimisticRollbackResponse>>[src]

pub fn kv_txn_heart_beat_opt(
    &self,
    req: &TxnHeartBeatRequest,
    opt: CallOption
) -> Result<TxnHeartBeatResponse>[src]

pub fn kv_txn_heart_beat(
    &self,
    req: &TxnHeartBeatRequest
) -> Result<TxnHeartBeatResponse>[src]

pub fn kv_txn_heart_beat_async_opt(
    &self,
    req: &TxnHeartBeatRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<TxnHeartBeatResponse>>[src]

pub fn kv_txn_heart_beat_async(
    &self,
    req: &TxnHeartBeatRequest
) -> Result<ClientUnaryReceiver<TxnHeartBeatResponse>>[src]

pub fn kv_check_txn_status_opt(
    &self,
    req: &CheckTxnStatusRequest,
    opt: CallOption
) -> Result<CheckTxnStatusResponse>[src]

pub fn kv_check_txn_status(
    &self,
    req: &CheckTxnStatusRequest
) -> Result<CheckTxnStatusResponse>[src]

pub fn kv_check_txn_status_async_opt(
    &self,
    req: &CheckTxnStatusRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CheckTxnStatusResponse>>[src]

pub fn kv_check_txn_status_async(
    &self,
    req: &CheckTxnStatusRequest
) -> Result<ClientUnaryReceiver<CheckTxnStatusResponse>>[src]

pub fn kv_check_secondary_locks_opt(
    &self,
    req: &CheckSecondaryLocksRequest,
    opt: CallOption
) -> Result<CheckSecondaryLocksResponse>[src]

pub fn kv_check_secondary_locks(
    &self,
    req: &CheckSecondaryLocksRequest
) -> Result<CheckSecondaryLocksResponse>[src]

pub fn kv_check_secondary_locks_async_opt(
    &self,
    req: &CheckSecondaryLocksRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CheckSecondaryLocksResponse>>[src]

pub fn kv_check_secondary_locks_async(
    &self,
    req: &CheckSecondaryLocksRequest
) -> Result<ClientUnaryReceiver<CheckSecondaryLocksResponse>>[src]

pub fn kv_commit_opt(
    &self,
    req: &CommitRequest,
    opt: CallOption
) -> Result<CommitResponse>[src]

pub fn kv_commit(&self, req: &CommitRequest) -> Result<CommitResponse>[src]

pub fn kv_commit_async_opt(
    &self,
    req: &CommitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CommitResponse>>[src]

pub fn kv_commit_async(
    &self,
    req: &CommitRequest
) -> Result<ClientUnaryReceiver<CommitResponse>>[src]

pub fn kv_import_opt(
    &self,
    req: &ImportRequest,
    opt: CallOption
) -> Result<ImportResponse>[src]

pub fn kv_import(&self, req: &ImportRequest) -> Result<ImportResponse>[src]

pub fn kv_import_async_opt(
    &self,
    req: &ImportRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ImportResponse>>[src]

pub fn kv_import_async(
    &self,
    req: &ImportRequest
) -> Result<ClientUnaryReceiver<ImportResponse>>[src]

pub fn kv_cleanup_opt(
    &self,
    req: &CleanupRequest,
    opt: CallOption
) -> Result<CleanupResponse>[src]

pub fn kv_cleanup(&self, req: &CleanupRequest) -> Result<CleanupResponse>[src]

pub fn kv_cleanup_async_opt(
    &self,
    req: &CleanupRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CleanupResponse>>[src]

pub fn kv_cleanup_async(
    &self,
    req: &CleanupRequest
) -> Result<ClientUnaryReceiver<CleanupResponse>>[src]

pub fn kv_batch_get_opt(
    &self,
    req: &BatchGetRequest,
    opt: CallOption
) -> Result<BatchGetResponse>[src]

pub fn kv_batch_get(&self, req: &BatchGetRequest) -> Result<BatchGetResponse>[src]

pub fn kv_batch_get_async_opt(
    &self,
    req: &BatchGetRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<BatchGetResponse>>[src]

pub fn kv_batch_get_async(
    &self,
    req: &BatchGetRequest
) -> Result<ClientUnaryReceiver<BatchGetResponse>>[src]

pub fn kv_batch_rollback_opt(
    &self,
    req: &BatchRollbackRequest,
    opt: CallOption
) -> Result<BatchRollbackResponse>[src]

pub fn kv_batch_rollback(
    &self,
    req: &BatchRollbackRequest
) -> Result<BatchRollbackResponse>[src]

pub fn kv_batch_rollback_async_opt(
    &self,
    req: &BatchRollbackRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<BatchRollbackResponse>>[src]

pub fn kv_batch_rollback_async(
    &self,
    req: &BatchRollbackRequest
) -> Result<ClientUnaryReceiver<BatchRollbackResponse>>[src]

pub fn kv_scan_lock_opt(
    &self,
    req: &ScanLockRequest,
    opt: CallOption
) -> Result<ScanLockResponse>[src]

pub fn kv_scan_lock(&self, req: &ScanLockRequest) -> Result<ScanLockResponse>[src]

pub fn kv_scan_lock_async_opt(
    &self,
    req: &ScanLockRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ScanLockResponse>>[src]

pub fn kv_scan_lock_async(
    &self,
    req: &ScanLockRequest
) -> Result<ClientUnaryReceiver<ScanLockResponse>>[src]

pub fn kv_resolve_lock_opt(
    &self,
    req: &ResolveLockRequest,
    opt: CallOption
) -> Result<ResolveLockResponse>[src]

pub fn kv_resolve_lock(
    &self,
    req: &ResolveLockRequest
) -> Result<ResolveLockResponse>[src]

pub fn kv_resolve_lock_async_opt(
    &self,
    req: &ResolveLockRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ResolveLockResponse>>[src]

pub fn kv_resolve_lock_async(
    &self,
    req: &ResolveLockRequest
) -> Result<ClientUnaryReceiver<ResolveLockResponse>>[src]

pub fn kv_gc_opt(&self, req: &GcRequest, opt: CallOption) -> Result<GcResponse>[src]

pub fn kv_gc(&self, req: &GcRequest) -> Result<GcResponse>[src]

pub fn kv_gc_async_opt(
    &self,
    req: &GcRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GcResponse>>[src]

pub fn kv_gc_async(
    &self,
    req: &GcRequest
) -> Result<ClientUnaryReceiver<GcResponse>>[src]

pub fn kv_delete_range_opt(
    &self,
    req: &DeleteRangeRequest,
    opt: CallOption
) -> Result<DeleteRangeResponse>[src]

pub fn kv_delete_range(
    &self,
    req: &DeleteRangeRequest
) -> Result<DeleteRangeResponse>[src]

pub fn kv_delete_range_async_opt(
    &self,
    req: &DeleteRangeRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<DeleteRangeResponse>>[src]

pub fn kv_delete_range_async(
    &self,
    req: &DeleteRangeRequest
) -> Result<ClientUnaryReceiver<DeleteRangeResponse>>[src]

pub fn raw_get_opt(
    &self,
    req: &RawGetRequest,
    opt: CallOption
) -> Result<RawGetResponse>[src]

pub fn raw_get(&self, req: &RawGetRequest) -> Result<RawGetResponse>[src]

pub fn raw_get_async_opt(
    &self,
    req: &RawGetRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawGetResponse>>[src]

pub fn raw_get_async(
    &self,
    req: &RawGetRequest
) -> Result<ClientUnaryReceiver<RawGetResponse>>[src]

pub fn raw_batch_get_opt(
    &self,
    req: &RawBatchGetRequest,
    opt: CallOption
) -> Result<RawBatchGetResponse>[src]

pub fn raw_batch_get(
    &self,
    req: &RawBatchGetRequest
) -> Result<RawBatchGetResponse>[src]

pub fn raw_batch_get_async_opt(
    &self,
    req: &RawBatchGetRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawBatchGetResponse>>[src]

pub fn raw_batch_get_async(
    &self,
    req: &RawBatchGetRequest
) -> Result<ClientUnaryReceiver<RawBatchGetResponse>>[src]

pub fn raw_put_opt(
    &self,
    req: &RawPutRequest,
    opt: CallOption
) -> Result<RawPutResponse>[src]

pub fn raw_put(&self, req: &RawPutRequest) -> Result<RawPutResponse>[src]

pub fn raw_put_async_opt(
    &self,
    req: &RawPutRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawPutResponse>>[src]

pub fn raw_put_async(
    &self,
    req: &RawPutRequest
) -> Result<ClientUnaryReceiver<RawPutResponse>>[src]

pub fn raw_batch_put_opt(
    &self,
    req: &RawBatchPutRequest,
    opt: CallOption
) -> Result<RawBatchPutResponse>[src]

pub fn raw_batch_put(
    &self,
    req: &RawBatchPutRequest
) -> Result<RawBatchPutResponse>[src]

pub fn raw_batch_put_async_opt(
    &self,
    req: &RawBatchPutRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawBatchPutResponse>>[src]

pub fn raw_batch_put_async(
    &self,
    req: &RawBatchPutRequest
) -> Result<ClientUnaryReceiver<RawBatchPutResponse>>[src]

pub fn raw_delete_opt(
    &self,
    req: &RawDeleteRequest,
    opt: CallOption
) -> Result<RawDeleteResponse>[src]

pub fn raw_delete(&self, req: &RawDeleteRequest) -> Result<RawDeleteResponse>[src]

pub fn raw_delete_async_opt(
    &self,
    req: &RawDeleteRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawDeleteResponse>>[src]

pub fn raw_delete_async(
    &self,
    req: &RawDeleteRequest
) -> Result<ClientUnaryReceiver<RawDeleteResponse>>[src]

pub fn raw_batch_delete_opt(
    &self,
    req: &RawBatchDeleteRequest,
    opt: CallOption
) -> Result<RawBatchDeleteResponse>[src]

pub fn raw_batch_delete(
    &self,
    req: &RawBatchDeleteRequest
) -> Result<RawBatchDeleteResponse>[src]

pub fn raw_batch_delete_async_opt(
    &self,
    req: &RawBatchDeleteRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawBatchDeleteResponse>>[src]

pub fn raw_batch_delete_async(
    &self,
    req: &RawBatchDeleteRequest
) -> Result<ClientUnaryReceiver<RawBatchDeleteResponse>>[src]

pub fn raw_scan_opt(
    &self,
    req: &RawScanRequest,
    opt: CallOption
) -> Result<RawScanResponse>[src]

pub fn raw_scan(&self, req: &RawScanRequest) -> Result<RawScanResponse>[src]

pub fn raw_scan_async_opt(
    &self,
    req: &RawScanRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawScanResponse>>[src]

pub fn raw_scan_async(
    &self,
    req: &RawScanRequest
) -> Result<ClientUnaryReceiver<RawScanResponse>>[src]

pub fn raw_delete_range_opt(
    &self,
    req: &RawDeleteRangeRequest,
    opt: CallOption
) -> Result<RawDeleteRangeResponse>[src]

pub fn raw_delete_range(
    &self,
    req: &RawDeleteRangeRequest
) -> Result<RawDeleteRangeResponse>[src]

pub fn raw_delete_range_async_opt(
    &self,
    req: &RawDeleteRangeRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawDeleteRangeResponse>>[src]

pub fn raw_delete_range_async(
    &self,
    req: &RawDeleteRangeRequest
) -> Result<ClientUnaryReceiver<RawDeleteRangeResponse>>[src]

pub fn raw_batch_scan_opt(
    &self,
    req: &RawBatchScanRequest,
    opt: CallOption
) -> Result<RawBatchScanResponse>[src]

pub fn raw_batch_scan(
    &self,
    req: &RawBatchScanRequest
) -> Result<RawBatchScanResponse>[src]

pub fn raw_batch_scan_async_opt(
    &self,
    req: &RawBatchScanRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawBatchScanResponse>>[src]

pub fn raw_batch_scan_async(
    &self,
    req: &RawBatchScanRequest
) -> Result<ClientUnaryReceiver<RawBatchScanResponse>>[src]

pub fn raw_get_key_ttl_opt(
    &self,
    req: &RawGetKeyTtlRequest,
    opt: CallOption
) -> Result<RawGetKeyTtlResponse>[src]

pub fn raw_get_key_ttl(
    &self,
    req: &RawGetKeyTtlRequest
) -> Result<RawGetKeyTtlResponse>[src]

pub fn raw_get_key_ttl_async_opt(
    &self,
    req: &RawGetKeyTtlRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawGetKeyTtlResponse>>[src]

pub fn raw_get_key_ttl_async(
    &self,
    req: &RawGetKeyTtlRequest
) -> Result<ClientUnaryReceiver<RawGetKeyTtlResponse>>[src]

pub fn raw_compare_and_swap_opt(
    &self,
    req: &RawCasRequest,
    opt: CallOption
) -> Result<RawCasResponse>[src]

pub fn raw_compare_and_swap(
    &self,
    req: &RawCasRequest
) -> Result<RawCasResponse>[src]

pub fn raw_compare_and_swap_async_opt(
    &self,
    req: &RawCasRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawCasResponse>>[src]

pub fn raw_compare_and_swap_async(
    &self,
    req: &RawCasRequest
) -> Result<ClientUnaryReceiver<RawCasResponse>>[src]

pub fn unsafe_destroy_range_opt(
    &self,
    req: &UnsafeDestroyRangeRequest,
    opt: CallOption
) -> Result<UnsafeDestroyRangeResponse>[src]

pub fn unsafe_destroy_range(
    &self,
    req: &UnsafeDestroyRangeRequest
) -> Result<UnsafeDestroyRangeResponse>[src]

pub fn unsafe_destroy_range_async_opt(
    &self,
    req: &UnsafeDestroyRangeRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<UnsafeDestroyRangeResponse>>[src]

pub fn unsafe_destroy_range_async(
    &self,
    req: &UnsafeDestroyRangeRequest
) -> Result<ClientUnaryReceiver<UnsafeDestroyRangeResponse>>[src]

pub fn register_lock_observer_opt(
    &self,
    req: &RegisterLockObserverRequest,
    opt: CallOption
) -> Result<RegisterLockObserverResponse>[src]

pub fn register_lock_observer(
    &self,
    req: &RegisterLockObserverRequest
) -> Result<RegisterLockObserverResponse>[src]

pub fn register_lock_observer_async_opt(
    &self,
    req: &RegisterLockObserverRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RegisterLockObserverResponse>>[src]

pub fn register_lock_observer_async(
    &self,
    req: &RegisterLockObserverRequest
) -> Result<ClientUnaryReceiver<RegisterLockObserverResponse>>[src]

pub fn check_lock_observer_opt(
    &self,
    req: &CheckLockObserverRequest,
    opt: CallOption
) -> Result<CheckLockObserverResponse>[src]

pub fn check_lock_observer(
    &self,
    req: &CheckLockObserverRequest
) -> Result<CheckLockObserverResponse>[src]

pub fn check_lock_observer_async_opt(
    &self,
    req: &CheckLockObserverRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CheckLockObserverResponse>>[src]

pub fn check_lock_observer_async(
    &self,
    req: &CheckLockObserverRequest
) -> Result<ClientUnaryReceiver<CheckLockObserverResponse>>[src]

pub fn remove_lock_observer_opt(
    &self,
    req: &RemoveLockObserverRequest,
    opt: CallOption
) -> Result<RemoveLockObserverResponse>[src]

pub fn remove_lock_observer(
    &self,
    req: &RemoveLockObserverRequest
) -> Result<RemoveLockObserverResponse>[src]

pub fn remove_lock_observer_async_opt(
    &self,
    req: &RemoveLockObserverRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RemoveLockObserverResponse>>[src]

pub fn remove_lock_observer_async(
    &self,
    req: &RemoveLockObserverRequest
) -> Result<ClientUnaryReceiver<RemoveLockObserverResponse>>[src]

pub fn physical_scan_lock_opt(
    &self,
    req: &PhysicalScanLockRequest,
    opt: CallOption
) -> Result<PhysicalScanLockResponse>[src]

pub fn physical_scan_lock(
    &self,
    req: &PhysicalScanLockRequest
) -> Result<PhysicalScanLockResponse>[src]

pub fn physical_scan_lock_async_opt(
    &self,
    req: &PhysicalScanLockRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<PhysicalScanLockResponse>>[src]

pub fn physical_scan_lock_async(
    &self,
    req: &PhysicalScanLockRequest
) -> Result<ClientUnaryReceiver<PhysicalScanLockResponse>>[src]

pub fn coprocessor_opt(
    &self,
    req: &Request,
    opt: CallOption
) -> Result<Response>[src]

pub fn coprocessor(&self, req: &Request) -> Result<Response>[src]

pub fn coprocessor_async_opt(
    &self,
    req: &Request,
    opt: CallOption
) -> Result<ClientUnaryReceiver<Response>>[src]

pub fn coprocessor_async(
    &self,
    req: &Request
) -> Result<ClientUnaryReceiver<Response>>[src]

pub fn coprocessor_stream_opt(
    &self,
    req: &Request,
    opt: CallOption
) -> Result<ClientSStreamReceiver<Response>>[src]

pub fn coprocessor_stream(
    &self,
    req: &Request
) -> Result<ClientSStreamReceiver<Response>>[src]

pub fn batch_coprocessor_opt(
    &self,
    req: &BatchRequest,
    opt: CallOption
) -> Result<ClientSStreamReceiver<BatchResponse>>[src]

pub fn batch_coprocessor(
    &self,
    req: &BatchRequest
) -> Result<ClientSStreamReceiver<BatchResponse>>[src]

pub fn raw_coprocessor_opt(
    &self,
    req: &RawCoprocessorRequest,
    opt: CallOption
) -> Result<RawCoprocessorResponse>[src]

pub fn raw_coprocessor(
    &self,
    req: &RawCoprocessorRequest
) -> Result<RawCoprocessorResponse>[src]

pub fn raw_coprocessor_async_opt(
    &self,
    req: &RawCoprocessorRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<RawCoprocessorResponse>>[src]

pub fn raw_coprocessor_async(
    &self,
    req: &RawCoprocessorRequest
) -> Result<ClientUnaryReceiver<RawCoprocessorResponse>>[src]

pub fn raft_opt(
    &self,
    opt: CallOption
) -> Result<(ClientCStreamSender<RaftMessage>, ClientCStreamReceiver<Done>)>[src]

pub fn raft(
    &self
) -> Result<(ClientCStreamSender<RaftMessage>, ClientCStreamReceiver<Done>)>[src]

pub fn batch_raft_opt(
    &self,
    opt: CallOption
) -> Result<(ClientCStreamSender<BatchRaftMessage>, ClientCStreamReceiver<Done>)>[src]

pub fn batch_raft(
    &self
) -> Result<(ClientCStreamSender<BatchRaftMessage>, ClientCStreamReceiver<Done>)>[src]

pub fn snapshot_opt(
    &self,
    opt: CallOption
) -> Result<(ClientCStreamSender<SnapshotChunk>, ClientCStreamReceiver<Done>)>[src]

pub fn snapshot(
    &self
) -> Result<(ClientCStreamSender<SnapshotChunk>, ClientCStreamReceiver<Done>)>[src]

pub fn split_region_opt(
    &self,
    req: &SplitRegionRequest,
    opt: CallOption
) -> Result<SplitRegionResponse>[src]

pub fn split_region(
    &self,
    req: &SplitRegionRequest
) -> Result<SplitRegionResponse>[src]

pub fn split_region_async_opt(
    &self,
    req: &SplitRegionRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<SplitRegionResponse>>[src]

pub fn split_region_async(
    &self,
    req: &SplitRegionRequest
) -> Result<ClientUnaryReceiver<SplitRegionResponse>>[src]

pub fn read_index_opt(
    &self,
    req: &ReadIndexRequest,
    opt: CallOption
) -> Result<ReadIndexResponse>[src]

pub fn read_index(&self, req: &ReadIndexRequest) -> Result<ReadIndexResponse>[src]

pub fn read_index_async_opt(
    &self,
    req: &ReadIndexRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<ReadIndexResponse>>[src]

pub fn read_index_async(
    &self,
    req: &ReadIndexRequest
) -> Result<ClientUnaryReceiver<ReadIndexResponse>>[src]

pub fn mvcc_get_by_key_opt(
    &self,
    req: &MvccGetByKeyRequest,
    opt: CallOption
) -> Result<MvccGetByKeyResponse>[src]

pub fn mvcc_get_by_key(
    &self,
    req: &MvccGetByKeyRequest
) -> Result<MvccGetByKeyResponse>[src]

pub fn mvcc_get_by_key_async_opt(
    &self,
    req: &MvccGetByKeyRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<MvccGetByKeyResponse>>[src]

pub fn mvcc_get_by_key_async(
    &self,
    req: &MvccGetByKeyRequest
) -> Result<ClientUnaryReceiver<MvccGetByKeyResponse>>[src]

pub fn mvcc_get_by_start_ts_opt(
    &self,
    req: &MvccGetByStartTsRequest,
    opt: CallOption
) -> Result<MvccGetByStartTsResponse>[src]

pub fn mvcc_get_by_start_ts(
    &self,
    req: &MvccGetByStartTsRequest
) -> Result<MvccGetByStartTsResponse>[src]

pub fn mvcc_get_by_start_ts_async_opt(
    &self,
    req: &MvccGetByStartTsRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<MvccGetByStartTsResponse>>[src]

pub fn mvcc_get_by_start_ts_async(
    &self,
    req: &MvccGetByStartTsRequest
) -> Result<ClientUnaryReceiver<MvccGetByStartTsResponse>>[src]

pub fn batch_commands_opt(
    &self,
    opt: CallOption
) -> Result<(ClientDuplexSender<BatchCommandsRequest>, ClientDuplexReceiver<BatchCommandsResponse>)>[src]

pub fn batch_commands(
    &self
) -> Result<(ClientDuplexSender<BatchCommandsRequest>, ClientDuplexReceiver<BatchCommandsResponse>)>[src]

pub fn dispatch_mpp_task_opt(
    &self,
    req: &DispatchTaskRequest,
    opt: CallOption
) -> Result<DispatchTaskResponse>[src]

pub fn dispatch_mpp_task(
    &self,
    req: &DispatchTaskRequest
) -> Result<DispatchTaskResponse>[src]

pub fn dispatch_mpp_task_async_opt(
    &self,
    req: &DispatchTaskRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<DispatchTaskResponse>>[src]

pub fn dispatch_mpp_task_async(
    &self,
    req: &DispatchTaskRequest
) -> Result<ClientUnaryReceiver<DispatchTaskResponse>>[src]

pub fn cancel_mpp_task_opt(
    &self,
    req: &CancelTaskRequest,
    opt: CallOption
) -> Result<CancelTaskResponse>[src]

pub fn cancel_mpp_task(
    &self,
    req: &CancelTaskRequest
) -> Result<CancelTaskResponse>[src]

pub fn cancel_mpp_task_async_opt(
    &self,
    req: &CancelTaskRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CancelTaskResponse>>[src]

pub fn cancel_mpp_task_async(
    &self,
    req: &CancelTaskRequest
) -> Result<ClientUnaryReceiver<CancelTaskResponse>>[src]

pub fn establish_mpp_connection_opt(
    &self,
    req: &EstablishMppConnectionRequest,
    opt: CallOption
) -> Result<ClientSStreamReceiver<MppDataPacket>>[src]

pub fn establish_mpp_connection(
    &self,
    req: &EstablishMppConnectionRequest
) -> Result<ClientSStreamReceiver<MppDataPacket>>[src]

pub fn check_leader_opt(
    &self,
    req: &CheckLeaderRequest,
    opt: CallOption
) -> Result<CheckLeaderResponse>[src]

pub fn check_leader(
    &self,
    req: &CheckLeaderRequest
) -> Result<CheckLeaderResponse>[src]

pub fn check_leader_async_opt(
    &self,
    req: &CheckLeaderRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CheckLeaderResponse>>[src]

pub fn check_leader_async(
    &self,
    req: &CheckLeaderRequest
) -> Result<ClientUnaryReceiver<CheckLeaderResponse>>[src]

pub fn get_store_safe_ts_opt(
    &self,
    req: &StoreSafeTsRequest,
    opt: CallOption
) -> Result<StoreSafeTsResponse>[src]

pub fn get_store_safe_ts(
    &self,
    req: &StoreSafeTsRequest
) -> Result<StoreSafeTsResponse>[src]

pub fn get_store_safe_ts_async_opt(
    &self,
    req: &StoreSafeTsRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<StoreSafeTsResponse>>[src]

pub fn get_store_safe_ts_async(
    &self,
    req: &StoreSafeTsRequest
) -> Result<ClientUnaryReceiver<StoreSafeTsResponse>>[src]

pub fn get_lock_wait_info_opt(
    &self,
    req: &GetLockWaitInfoRequest,
    opt: CallOption
) -> Result<GetLockWaitInfoResponse>[src]

pub fn get_lock_wait_info(
    &self,
    req: &GetLockWaitInfoRequest
) -> Result<GetLockWaitInfoResponse>[src]

pub fn get_lock_wait_info_async_opt(
    &self,
    req: &GetLockWaitInfoRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<GetLockWaitInfoResponse>>[src]

pub fn get_lock_wait_info_async(
    &self,
    req: &GetLockWaitInfoRequest
) -> Result<ClientUnaryReceiver<GetLockWaitInfoResponse>>[src]

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

Trait Implementations

impl Clone for TikvClient[src]

Auto Trait Implementations

impl !RefUnwindSafe for TikvClient

impl Send for TikvClient

impl Sync for TikvClient

impl Unpin for TikvClient

impl !UnwindSafe for TikvClient

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.