Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowTikvpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTikvpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTikvpb = fmt.Errorf("proto: unexpected end of group") + func RegisterTikvServer(s *grpc.Server, srv TikvServer) + type BatchCommandsEmptyRequest struct + DelayTime uint64 + TestId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsEmptyRequest) Descriptor() ([]byte, []int) + func (*BatchCommandsEmptyRequest) ProtoMessage() + func (m *BatchCommandsEmptyRequest) GetDelayTime() uint64 + func (m *BatchCommandsEmptyRequest) GetTestId() uint64 + func (m *BatchCommandsEmptyRequest) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsEmptyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsEmptyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsEmptyRequest) Reset() + func (m *BatchCommandsEmptyRequest) Size() (n int) + func (m *BatchCommandsEmptyRequest) String() string + func (m *BatchCommandsEmptyRequest) Unmarshal(dAtA []byte) error + func (m *BatchCommandsEmptyRequest) XXX_DiscardUnknown() + func (m *BatchCommandsEmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsEmptyRequest) XXX_Merge(src proto.Message) + func (m *BatchCommandsEmptyRequest) XXX_Size() int + func (m *BatchCommandsEmptyRequest) XXX_Unmarshal(b []byte) error + type BatchCommandsEmptyResponse struct + TestId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsEmptyResponse) Descriptor() ([]byte, []int) + func (*BatchCommandsEmptyResponse) ProtoMessage() + func (m *BatchCommandsEmptyResponse) GetTestId() uint64 + func (m *BatchCommandsEmptyResponse) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsEmptyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsEmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsEmptyResponse) Reset() + func (m *BatchCommandsEmptyResponse) Size() (n int) + func (m *BatchCommandsEmptyResponse) String() string + func (m *BatchCommandsEmptyResponse) Unmarshal(dAtA []byte) error + func (m *BatchCommandsEmptyResponse) XXX_DiscardUnknown() + func (m *BatchCommandsEmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsEmptyResponse) XXX_Merge(src proto.Message) + func (m *BatchCommandsEmptyResponse) XXX_Size() int + func (m *BatchCommandsEmptyResponse) XXX_Unmarshal(b []byte) error + type BatchCommandsRequest struct + RequestIds []uint64 + Requests []*BatchCommandsRequest_Request + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsRequest) Descriptor() ([]byte, []int) + func (*BatchCommandsRequest) ProtoMessage() + func (m *BatchCommandsRequest) GetRequestIds() []uint64 + func (m *BatchCommandsRequest) GetRequests() []*BatchCommandsRequest_Request + func (m *BatchCommandsRequest) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest) Reset() + func (m *BatchCommandsRequest) Size() (n int) + func (m *BatchCommandsRequest) String() string + func (m *BatchCommandsRequest) Unmarshal(dAtA []byte) error + func (m *BatchCommandsRequest) XXX_DiscardUnknown() + func (m *BatchCommandsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsRequest) XXX_Merge(src proto.Message) + func (m *BatchCommandsRequest) XXX_Size() int + func (m *BatchCommandsRequest) XXX_Unmarshal(b []byte) error + type BatchCommandsRequest_Request struct + Cmd isBatchCommandsRequest_Request_Cmd + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsRequest_Request) Descriptor() ([]byte, []int) + func (*BatchCommandsRequest_Request) ProtoMessage() + func (*BatchCommandsRequest_Request) XXX_OneofWrappers() []interface{} + func (m *BatchCommandsRequest_Request) GetBatchGet() *kvrpcpb.BatchGetRequest + func (m *BatchCommandsRequest_Request) GetBatchRollback() *kvrpcpb.BatchRollbackRequest + func (m *BatchCommandsRequest_Request) GetCheckSecondaryLocks() *kvrpcpb.CheckSecondaryLocksRequest + func (m *BatchCommandsRequest_Request) GetCheckTxnStatus() *kvrpcpb.CheckTxnStatusRequest + func (m *BatchCommandsRequest_Request) GetCleanup() *kvrpcpb.CleanupRequest + func (m *BatchCommandsRequest_Request) GetCmd() isBatchCommandsRequest_Request_Cmd + func (m *BatchCommandsRequest_Request) GetCommit() *kvrpcpb.CommitRequest + func (m *BatchCommandsRequest_Request) GetCoprocessor() *coprocessor.Request + func (m *BatchCommandsRequest_Request) GetDeleteRange() *kvrpcpb.DeleteRangeRequest + func (m *BatchCommandsRequest_Request) GetEmpty() *BatchCommandsEmptyRequest + func (m *BatchCommandsRequest_Request) GetFlashbackToVersion() *kvrpcpb.FlashbackToVersionRequest + func (m *BatchCommandsRequest_Request) GetGC() *kvrpcpb.GCRequest + func (m *BatchCommandsRequest_Request) GetGet() *kvrpcpb.GetRequest + func (m *BatchCommandsRequest_Request) GetImport() *kvrpcpb.ImportRequest + func (m *BatchCommandsRequest_Request) GetPessimisticLock() *kvrpcpb.PessimisticLockRequest + func (m *BatchCommandsRequest_Request) GetPessimisticRollback() *kvrpcpb.PessimisticRollbackRequest + func (m *BatchCommandsRequest_Request) GetPrepareFlashbackToVersion() *kvrpcpb.PrepareFlashbackToVersionRequest + func (m *BatchCommandsRequest_Request) GetPrewrite() *kvrpcpb.PrewriteRequest + func (m *BatchCommandsRequest_Request) GetRawBatchDelete() *kvrpcpb.RawBatchDeleteRequest + func (m *BatchCommandsRequest_Request) GetRawBatchGet() *kvrpcpb.RawBatchGetRequest + func (m *BatchCommandsRequest_Request) GetRawBatchPut() *kvrpcpb.RawBatchPutRequest + func (m *BatchCommandsRequest_Request) GetRawBatchScan() *kvrpcpb.RawBatchScanRequest + func (m *BatchCommandsRequest_Request) GetRawCoprocessor() *kvrpcpb.RawCoprocessorRequest + func (m *BatchCommandsRequest_Request) GetRawDelete() *kvrpcpb.RawDeleteRequest + func (m *BatchCommandsRequest_Request) GetRawDeleteRange() *kvrpcpb.RawDeleteRangeRequest + func (m *BatchCommandsRequest_Request) GetRawGet() *kvrpcpb.RawGetRequest + func (m *BatchCommandsRequest_Request) GetRawPut() *kvrpcpb.RawPutRequest + func (m *BatchCommandsRequest_Request) GetRawScan() *kvrpcpb.RawScanRequest + func (m *BatchCommandsRequest_Request) GetResolveLock() *kvrpcpb.ResolveLockRequest + func (m *BatchCommandsRequest_Request) GetScan() *kvrpcpb.ScanRequest + func (m *BatchCommandsRequest_Request) GetScanLock() *kvrpcpb.ScanLockRequest + func (m *BatchCommandsRequest_Request) GetTxnHeartBeat() *kvrpcpb.TxnHeartBeatRequest + func (m *BatchCommandsRequest_Request) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsRequest_Request) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request) Reset() + func (m *BatchCommandsRequest_Request) Size() (n int) + func (m *BatchCommandsRequest_Request) String() string + func (m *BatchCommandsRequest_Request) Unmarshal(dAtA []byte) error + func (m *BatchCommandsRequest_Request) XXX_DiscardUnknown() + func (m *BatchCommandsRequest_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsRequest_Request) XXX_Merge(src proto.Message) + func (m *BatchCommandsRequest_Request) XXX_Size() int + func (m *BatchCommandsRequest_Request) XXX_Unmarshal(b []byte) error + type BatchCommandsRequest_Request_BatchGet struct + BatchGet *kvrpcpb.BatchGetRequest + func (m *BatchCommandsRequest_Request_BatchGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_BatchGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_BatchGet) Size() (n int) + type BatchCommandsRequest_Request_BatchRollback struct + BatchRollback *kvrpcpb.BatchRollbackRequest + func (m *BatchCommandsRequest_Request_BatchRollback) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_BatchRollback) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_BatchRollback) Size() (n int) + type BatchCommandsRequest_Request_CheckSecondaryLocks struct + CheckSecondaryLocks *kvrpcpb.CheckSecondaryLocksRequest + func (m *BatchCommandsRequest_Request_CheckSecondaryLocks) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_CheckSecondaryLocks) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_CheckSecondaryLocks) Size() (n int) + type BatchCommandsRequest_Request_CheckTxnStatus struct + CheckTxnStatus *kvrpcpb.CheckTxnStatusRequest + func (m *BatchCommandsRequest_Request_CheckTxnStatus) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_CheckTxnStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_CheckTxnStatus) Size() (n int) + type BatchCommandsRequest_Request_Cleanup struct + Cleanup *kvrpcpb.CleanupRequest + func (m *BatchCommandsRequest_Request_Cleanup) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Cleanup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Cleanup) Size() (n int) + type BatchCommandsRequest_Request_Commit struct + Commit *kvrpcpb.CommitRequest + func (m *BatchCommandsRequest_Request_Commit) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Commit) Size() (n int) + type BatchCommandsRequest_Request_Coprocessor struct + Coprocessor *coprocessor.Request + func (m *BatchCommandsRequest_Request_Coprocessor) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Coprocessor) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Coprocessor) Size() (n int) + type BatchCommandsRequest_Request_DeleteRange struct + DeleteRange *kvrpcpb.DeleteRangeRequest + func (m *BatchCommandsRequest_Request_DeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_DeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_DeleteRange) Size() (n int) + type BatchCommandsRequest_Request_Empty struct + Empty *BatchCommandsEmptyRequest + func (m *BatchCommandsRequest_Request_Empty) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Empty) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Empty) Size() (n int) + type BatchCommandsRequest_Request_FlashbackToVersion struct + FlashbackToVersion *kvrpcpb.FlashbackToVersionRequest + func (m *BatchCommandsRequest_Request_FlashbackToVersion) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_FlashbackToVersion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_FlashbackToVersion) Size() (n int) + type BatchCommandsRequest_Request_GC struct + GC *kvrpcpb.GCRequest + func (m *BatchCommandsRequest_Request_GC) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_GC) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_GC) Size() (n int) + type BatchCommandsRequest_Request_Get struct + Get *kvrpcpb.GetRequest + func (m *BatchCommandsRequest_Request_Get) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Get) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Get) Size() (n int) + type BatchCommandsRequest_Request_Import struct + Import *kvrpcpb.ImportRequest + func (m *BatchCommandsRequest_Request_Import) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Import) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Import) Size() (n int) + type BatchCommandsRequest_Request_PessimisticLock struct + PessimisticLock *kvrpcpb.PessimisticLockRequest + func (m *BatchCommandsRequest_Request_PessimisticLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PessimisticLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PessimisticLock) Size() (n int) + type BatchCommandsRequest_Request_PessimisticRollback struct + PessimisticRollback *kvrpcpb.PessimisticRollbackRequest + func (m *BatchCommandsRequest_Request_PessimisticRollback) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PessimisticRollback) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PessimisticRollback) Size() (n int) + type BatchCommandsRequest_Request_PrepareFlashbackToVersion struct + PrepareFlashbackToVersion *kvrpcpb.PrepareFlashbackToVersionRequest + func (m *BatchCommandsRequest_Request_PrepareFlashbackToVersion) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PrepareFlashbackToVersion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_PrepareFlashbackToVersion) Size() (n int) + type BatchCommandsRequest_Request_Prewrite struct + Prewrite *kvrpcpb.PrewriteRequest + func (m *BatchCommandsRequest_Request_Prewrite) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Prewrite) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Prewrite) Size() (n int) + type BatchCommandsRequest_Request_RawBatchDelete struct + RawBatchDelete *kvrpcpb.RawBatchDeleteRequest + func (m *BatchCommandsRequest_Request_RawBatchDelete) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchDelete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchDelete) Size() (n int) + type BatchCommandsRequest_Request_RawBatchGet struct + RawBatchGet *kvrpcpb.RawBatchGetRequest + func (m *BatchCommandsRequest_Request_RawBatchGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchGet) Size() (n int) + type BatchCommandsRequest_Request_RawBatchPut struct + RawBatchPut *kvrpcpb.RawBatchPutRequest + func (m *BatchCommandsRequest_Request_RawBatchPut) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchPut) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchPut) Size() (n int) + type BatchCommandsRequest_Request_RawBatchScan struct + RawBatchScan *kvrpcpb.RawBatchScanRequest + func (m *BatchCommandsRequest_Request_RawBatchScan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchScan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawBatchScan) Size() (n int) + type BatchCommandsRequest_Request_RawCoprocessor struct + RawCoprocessor *kvrpcpb.RawCoprocessorRequest + func (m *BatchCommandsRequest_Request_RawCoprocessor) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawCoprocessor) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawCoprocessor) Size() (n int) + type BatchCommandsRequest_Request_RawDelete struct + RawDelete *kvrpcpb.RawDeleteRequest + func (m *BatchCommandsRequest_Request_RawDelete) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawDelete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawDelete) Size() (n int) + type BatchCommandsRequest_Request_RawDeleteRange struct + RawDeleteRange *kvrpcpb.RawDeleteRangeRequest + func (m *BatchCommandsRequest_Request_RawDeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawDeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawDeleteRange) Size() (n int) + type BatchCommandsRequest_Request_RawGet struct + RawGet *kvrpcpb.RawGetRequest + func (m *BatchCommandsRequest_Request_RawGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawGet) Size() (n int) + type BatchCommandsRequest_Request_RawPut struct + RawPut *kvrpcpb.RawPutRequest + func (m *BatchCommandsRequest_Request_RawPut) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawPut) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawPut) Size() (n int) + type BatchCommandsRequest_Request_RawScan struct + RawScan *kvrpcpb.RawScanRequest + func (m *BatchCommandsRequest_Request_RawScan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawScan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_RawScan) Size() (n int) + type BatchCommandsRequest_Request_ResolveLock struct + ResolveLock *kvrpcpb.ResolveLockRequest + func (m *BatchCommandsRequest_Request_ResolveLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_ResolveLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_ResolveLock) Size() (n int) + type BatchCommandsRequest_Request_Scan struct + Scan *kvrpcpb.ScanRequest + func (m *BatchCommandsRequest_Request_Scan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Scan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_Scan) Size() (n int) + type BatchCommandsRequest_Request_ScanLock struct + ScanLock *kvrpcpb.ScanLockRequest + func (m *BatchCommandsRequest_Request_ScanLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_ScanLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_ScanLock) Size() (n int) + type BatchCommandsRequest_Request_TxnHeartBeat struct + TxnHeartBeat *kvrpcpb.TxnHeartBeatRequest + func (m *BatchCommandsRequest_Request_TxnHeartBeat) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_TxnHeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsRequest_Request_TxnHeartBeat) Size() (n int) + type BatchCommandsResponse struct + RequestIds []uint64 + Responses []*BatchCommandsResponse_Response + TransportLayerLoad uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsResponse) Descriptor() ([]byte, []int) + func (*BatchCommandsResponse) ProtoMessage() + func (m *BatchCommandsResponse) GetRequestIds() []uint64 + func (m *BatchCommandsResponse) GetResponses() []*BatchCommandsResponse_Response + func (m *BatchCommandsResponse) GetTransportLayerLoad() uint64 + func (m *BatchCommandsResponse) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse) Reset() + func (m *BatchCommandsResponse) Size() (n int) + func (m *BatchCommandsResponse) String() string + func (m *BatchCommandsResponse) Unmarshal(dAtA []byte) error + func (m *BatchCommandsResponse) XXX_DiscardUnknown() + func (m *BatchCommandsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsResponse) XXX_Merge(src proto.Message) + func (m *BatchCommandsResponse) XXX_Size() int + func (m *BatchCommandsResponse) XXX_Unmarshal(b []byte) error + type BatchCommandsResponse_Response struct + Cmd isBatchCommandsResponse_Response_Cmd + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchCommandsResponse_Response) Descriptor() ([]byte, []int) + func (*BatchCommandsResponse_Response) ProtoMessage() + func (*BatchCommandsResponse_Response) XXX_OneofWrappers() []interface{} + func (m *BatchCommandsResponse_Response) GetBatchGet() *kvrpcpb.BatchGetResponse + func (m *BatchCommandsResponse_Response) GetBatchRollback() *kvrpcpb.BatchRollbackResponse + func (m *BatchCommandsResponse_Response) GetCheckSecondaryLocks() *kvrpcpb.CheckSecondaryLocksResponse + func (m *BatchCommandsResponse_Response) GetCheckTxnStatus() *kvrpcpb.CheckTxnStatusResponse + func (m *BatchCommandsResponse_Response) GetCleanup() *kvrpcpb.CleanupResponse + func (m *BatchCommandsResponse_Response) GetCmd() isBatchCommandsResponse_Response_Cmd + func (m *BatchCommandsResponse_Response) GetCommit() *kvrpcpb.CommitResponse + func (m *BatchCommandsResponse_Response) GetCoprocessor() *coprocessor.Response + func (m *BatchCommandsResponse_Response) GetDeleteRange() *kvrpcpb.DeleteRangeResponse + func (m *BatchCommandsResponse_Response) GetEmpty() *BatchCommandsEmptyResponse + func (m *BatchCommandsResponse_Response) GetFlashbackToVersion() *kvrpcpb.FlashbackToVersionResponse + func (m *BatchCommandsResponse_Response) GetGC() *kvrpcpb.GCResponse + func (m *BatchCommandsResponse_Response) GetGet() *kvrpcpb.GetResponse + func (m *BatchCommandsResponse_Response) GetImport() *kvrpcpb.ImportResponse + func (m *BatchCommandsResponse_Response) GetPessimisticLock() *kvrpcpb.PessimisticLockResponse + func (m *BatchCommandsResponse_Response) GetPessimisticRollback() *kvrpcpb.PessimisticRollbackResponse + func (m *BatchCommandsResponse_Response) GetPrepareFlashbackToVersion() *kvrpcpb.PrepareFlashbackToVersionResponse + func (m *BatchCommandsResponse_Response) GetPrewrite() *kvrpcpb.PrewriteResponse + func (m *BatchCommandsResponse_Response) GetRawBatchDelete() *kvrpcpb.RawBatchDeleteResponse + func (m *BatchCommandsResponse_Response) GetRawBatchGet() *kvrpcpb.RawBatchGetResponse + func (m *BatchCommandsResponse_Response) GetRawBatchPut() *kvrpcpb.RawBatchPutResponse + func (m *BatchCommandsResponse_Response) GetRawBatchScan() *kvrpcpb.RawBatchScanResponse + func (m *BatchCommandsResponse_Response) GetRawCoprocessor() *kvrpcpb.RawCoprocessorResponse + func (m *BatchCommandsResponse_Response) GetRawDelete() *kvrpcpb.RawDeleteResponse + func (m *BatchCommandsResponse_Response) GetRawDeleteRange() *kvrpcpb.RawDeleteRangeResponse + func (m *BatchCommandsResponse_Response) GetRawGet() *kvrpcpb.RawGetResponse + func (m *BatchCommandsResponse_Response) GetRawPut() *kvrpcpb.RawPutResponse + func (m *BatchCommandsResponse_Response) GetRawScan() *kvrpcpb.RawScanResponse + func (m *BatchCommandsResponse_Response) GetResolveLock() *kvrpcpb.ResolveLockResponse + func (m *BatchCommandsResponse_Response) GetScan() *kvrpcpb.ScanResponse + func (m *BatchCommandsResponse_Response) GetScanLock() *kvrpcpb.ScanLockResponse + func (m *BatchCommandsResponse_Response) GetTxnHeartBeat() *kvrpcpb.TxnHeartBeatResponse + func (m *BatchCommandsResponse_Response) Marshal() (dAtA []byte, err error) + func (m *BatchCommandsResponse_Response) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response) Reset() + func (m *BatchCommandsResponse_Response) Size() (n int) + func (m *BatchCommandsResponse_Response) String() string + func (m *BatchCommandsResponse_Response) Unmarshal(dAtA []byte) error + func (m *BatchCommandsResponse_Response) XXX_DiscardUnknown() + func (m *BatchCommandsResponse_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchCommandsResponse_Response) XXX_Merge(src proto.Message) + func (m *BatchCommandsResponse_Response) XXX_Size() int + func (m *BatchCommandsResponse_Response) XXX_Unmarshal(b []byte) error + type BatchCommandsResponse_Response_BatchGet struct + BatchGet *kvrpcpb.BatchGetResponse + func (m *BatchCommandsResponse_Response_BatchGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_BatchGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_BatchGet) Size() (n int) + type BatchCommandsResponse_Response_BatchRollback struct + BatchRollback *kvrpcpb.BatchRollbackResponse + func (m *BatchCommandsResponse_Response_BatchRollback) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_BatchRollback) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_BatchRollback) Size() (n int) + type BatchCommandsResponse_Response_CheckSecondaryLocks struct + CheckSecondaryLocks *kvrpcpb.CheckSecondaryLocksResponse + func (m *BatchCommandsResponse_Response_CheckSecondaryLocks) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_CheckSecondaryLocks) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_CheckSecondaryLocks) Size() (n int) + type BatchCommandsResponse_Response_CheckTxnStatus struct + CheckTxnStatus *kvrpcpb.CheckTxnStatusResponse + func (m *BatchCommandsResponse_Response_CheckTxnStatus) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_CheckTxnStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_CheckTxnStatus) Size() (n int) + type BatchCommandsResponse_Response_Cleanup struct + Cleanup *kvrpcpb.CleanupResponse + func (m *BatchCommandsResponse_Response_Cleanup) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Cleanup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Cleanup) Size() (n int) + type BatchCommandsResponse_Response_Commit struct + Commit *kvrpcpb.CommitResponse + func (m *BatchCommandsResponse_Response_Commit) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Commit) Size() (n int) + type BatchCommandsResponse_Response_Coprocessor struct + Coprocessor *coprocessor.Response + func (m *BatchCommandsResponse_Response_Coprocessor) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Coprocessor) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Coprocessor) Size() (n int) + type BatchCommandsResponse_Response_DeleteRange struct + DeleteRange *kvrpcpb.DeleteRangeResponse + func (m *BatchCommandsResponse_Response_DeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_DeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_DeleteRange) Size() (n int) + type BatchCommandsResponse_Response_Empty struct + Empty *BatchCommandsEmptyResponse + func (m *BatchCommandsResponse_Response_Empty) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Empty) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Empty) Size() (n int) + type BatchCommandsResponse_Response_FlashbackToVersion struct + FlashbackToVersion *kvrpcpb.FlashbackToVersionResponse + func (m *BatchCommandsResponse_Response_FlashbackToVersion) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_FlashbackToVersion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_FlashbackToVersion) Size() (n int) + type BatchCommandsResponse_Response_GC struct + GC *kvrpcpb.GCResponse + func (m *BatchCommandsResponse_Response_GC) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_GC) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_GC) Size() (n int) + type BatchCommandsResponse_Response_Get struct + Get *kvrpcpb.GetResponse + func (m *BatchCommandsResponse_Response_Get) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Get) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Get) Size() (n int) + type BatchCommandsResponse_Response_Import struct + Import *kvrpcpb.ImportResponse + func (m *BatchCommandsResponse_Response_Import) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Import) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Import) Size() (n int) + type BatchCommandsResponse_Response_PessimisticLock struct + PessimisticLock *kvrpcpb.PessimisticLockResponse + func (m *BatchCommandsResponse_Response_PessimisticLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PessimisticLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PessimisticLock) Size() (n int) + type BatchCommandsResponse_Response_PessimisticRollback struct + PessimisticRollback *kvrpcpb.PessimisticRollbackResponse + func (m *BatchCommandsResponse_Response_PessimisticRollback) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PessimisticRollback) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PessimisticRollback) Size() (n int) + type BatchCommandsResponse_Response_PrepareFlashbackToVersion struct + PrepareFlashbackToVersion *kvrpcpb.PrepareFlashbackToVersionResponse + func (m *BatchCommandsResponse_Response_PrepareFlashbackToVersion) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PrepareFlashbackToVersion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_PrepareFlashbackToVersion) Size() (n int) + type BatchCommandsResponse_Response_Prewrite struct + Prewrite *kvrpcpb.PrewriteResponse + func (m *BatchCommandsResponse_Response_Prewrite) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Prewrite) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Prewrite) Size() (n int) + type BatchCommandsResponse_Response_RawBatchDelete struct + RawBatchDelete *kvrpcpb.RawBatchDeleteResponse + func (m *BatchCommandsResponse_Response_RawBatchDelete) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchDelete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchDelete) Size() (n int) + type BatchCommandsResponse_Response_RawBatchGet struct + RawBatchGet *kvrpcpb.RawBatchGetResponse + func (m *BatchCommandsResponse_Response_RawBatchGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchGet) Size() (n int) + type BatchCommandsResponse_Response_RawBatchPut struct + RawBatchPut *kvrpcpb.RawBatchPutResponse + func (m *BatchCommandsResponse_Response_RawBatchPut) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchPut) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchPut) Size() (n int) + type BatchCommandsResponse_Response_RawBatchScan struct + RawBatchScan *kvrpcpb.RawBatchScanResponse + func (m *BatchCommandsResponse_Response_RawBatchScan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchScan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawBatchScan) Size() (n int) + type BatchCommandsResponse_Response_RawCoprocessor struct + RawCoprocessor *kvrpcpb.RawCoprocessorResponse + func (m *BatchCommandsResponse_Response_RawCoprocessor) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawCoprocessor) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawCoprocessor) Size() (n int) + type BatchCommandsResponse_Response_RawDelete struct + RawDelete *kvrpcpb.RawDeleteResponse + func (m *BatchCommandsResponse_Response_RawDelete) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawDelete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawDelete) Size() (n int) + type BatchCommandsResponse_Response_RawDeleteRange struct + RawDeleteRange *kvrpcpb.RawDeleteRangeResponse + func (m *BatchCommandsResponse_Response_RawDeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawDeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawDeleteRange) Size() (n int) + type BatchCommandsResponse_Response_RawGet struct + RawGet *kvrpcpb.RawGetResponse + func (m *BatchCommandsResponse_Response_RawGet) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawGet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawGet) Size() (n int) + type BatchCommandsResponse_Response_RawPut struct + RawPut *kvrpcpb.RawPutResponse + func (m *BatchCommandsResponse_Response_RawPut) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawPut) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawPut) Size() (n int) + type BatchCommandsResponse_Response_RawScan struct + RawScan *kvrpcpb.RawScanResponse + func (m *BatchCommandsResponse_Response_RawScan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawScan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_RawScan) Size() (n int) + type BatchCommandsResponse_Response_ResolveLock struct + ResolveLock *kvrpcpb.ResolveLockResponse + func (m *BatchCommandsResponse_Response_ResolveLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_ResolveLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_ResolveLock) Size() (n int) + type BatchCommandsResponse_Response_Scan struct + Scan *kvrpcpb.ScanResponse + func (m *BatchCommandsResponse_Response_Scan) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Scan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_Scan) Size() (n int) + type BatchCommandsResponse_Response_ScanLock struct + ScanLock *kvrpcpb.ScanLockResponse + func (m *BatchCommandsResponse_Response_ScanLock) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_ScanLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_ScanLock) Size() (n int) + type BatchCommandsResponse_Response_TxnHeartBeat struct + TxnHeartBeat *kvrpcpb.TxnHeartBeatResponse + func (m *BatchCommandsResponse_Response_TxnHeartBeat) MarshalTo(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_TxnHeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchCommandsResponse_Response_TxnHeartBeat) Size() (n int) + type BatchRaftMessage struct + Msgs []*raft_serverpb.RaftMessage + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchRaftMessage) Descriptor() ([]byte, []int) + func (*BatchRaftMessage) ProtoMessage() + func (m *BatchRaftMessage) GetMsgs() []*raft_serverpb.RaftMessage + func (m *BatchRaftMessage) Marshal() (dAtA []byte, err error) + func (m *BatchRaftMessage) MarshalTo(dAtA []byte) (int, error) + func (m *BatchRaftMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchRaftMessage) Reset() + func (m *BatchRaftMessage) Size() (n int) + func (m *BatchRaftMessage) String() string + func (m *BatchRaftMessage) Unmarshal(dAtA []byte) error + func (m *BatchRaftMessage) XXX_DiscardUnknown() + func (m *BatchRaftMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchRaftMessage) XXX_Merge(src proto.Message) + func (m *BatchRaftMessage) XXX_Size() int + func (m *BatchRaftMessage) XXX_Unmarshal(b []byte) error + type TikvClient interface + BatchCommands func(ctx context.Context, opts ...grpc.CallOption) (Tikv_BatchCommandsClient, error) + BatchCoprocessor func(ctx context.Context, in *coprocessor.BatchRequest, opts ...grpc.CallOption) (Tikv_BatchCoprocessorClient, error) + BatchRaft func(ctx context.Context, opts ...grpc.CallOption) (Tikv_BatchRaftClient, error) + CancelDisaggTask func(ctx context.Context, in *disaggregated.CancelDisaggTaskRequest, ...) (*disaggregated.CancelDisaggTaskResponse, error) + CancelMPPTask func(ctx context.Context, in *mpp.CancelTaskRequest, opts ...grpc.CallOption) (*mpp.CancelTaskResponse, error) + CheckLeader func(ctx context.Context, in *kvrpcpb.CheckLeaderRequest, opts ...grpc.CallOption) (*kvrpcpb.CheckLeaderResponse, error) + CheckLockObserver func(ctx context.Context, in *kvrpcpb.CheckLockObserverRequest, ...) (*kvrpcpb.CheckLockObserverResponse, error) + Compact func(ctx context.Context, in *kvrpcpb.CompactRequest, opts ...grpc.CallOption) (*kvrpcpb.CompactResponse, error) + Coprocessor func(ctx context.Context, in *coprocessor.Request, opts ...grpc.CallOption) (*coprocessor.Response, error) + CoprocessorStream func(ctx context.Context, in *coprocessor.Request, opts ...grpc.CallOption) (Tikv_CoprocessorStreamClient, error) + DispatchMPPTask func(ctx context.Context, in *mpp.DispatchTaskRequest, opts ...grpc.CallOption) (*mpp.DispatchTaskResponse, error) + EstablishDisaggTask func(ctx context.Context, in *disaggregated.EstablishDisaggTaskRequest, ...) (*disaggregated.EstablishDisaggTaskResponse, error) + EstablishMPPConnection func(ctx context.Context, in *mpp.EstablishMPPConnectionRequest, ...) (Tikv_EstablishMPPConnectionClient, error) + FetchDisaggPages func(ctx context.Context, in *disaggregated.FetchDisaggPagesRequest, ...) (Tikv_FetchDisaggPagesClient, error) + GetDisaggConfig func(ctx context.Context, in *disaggregated.GetDisaggConfigRequest, ...) (*disaggregated.GetDisaggConfigResponse, error) + GetLockWaitHistory func(ctx context.Context, in *kvrpcpb.GetLockWaitHistoryRequest, ...) (*kvrpcpb.GetLockWaitHistoryResponse, error) + GetLockWaitInfo func(ctx context.Context, in *kvrpcpb.GetLockWaitInfoRequest, ...) (*kvrpcpb.GetLockWaitInfoResponse, error) + GetStoreSafeTS func(ctx context.Context, in *kvrpcpb.StoreSafeTSRequest, opts ...grpc.CallOption) (*kvrpcpb.StoreSafeTSResponse, error) + GetTiFlashSystemTable func(ctx context.Context, in *kvrpcpb.TiFlashSystemTableRequest, ...) (*kvrpcpb.TiFlashSystemTableResponse, error) + IsAlive func(ctx context.Context, in *mpp.IsAliveRequest, opts ...grpc.CallOption) (*mpp.IsAliveResponse, error) + KVPessimisticRollback func(ctx context.Context, in *kvrpcpb.PessimisticRollbackRequest, ...) (*kvrpcpb.PessimisticRollbackResponse, error) + KvBatchGet func(ctx context.Context, in *kvrpcpb.BatchGetRequest, opts ...grpc.CallOption) (*kvrpcpb.BatchGetResponse, error) + KvBatchRollback func(ctx context.Context, in *kvrpcpb.BatchRollbackRequest, opts ...grpc.CallOption) (*kvrpcpb.BatchRollbackResponse, error) + KvCheckSecondaryLocks func(ctx context.Context, in *kvrpcpb.CheckSecondaryLocksRequest, ...) (*kvrpcpb.CheckSecondaryLocksResponse, error) + KvCheckTxnStatus func(ctx context.Context, in *kvrpcpb.CheckTxnStatusRequest, ...) (*kvrpcpb.CheckTxnStatusResponse, error) + KvCleanup func(ctx context.Context, in *kvrpcpb.CleanupRequest, opts ...grpc.CallOption) (*kvrpcpb.CleanupResponse, error) + KvCommit func(ctx context.Context, in *kvrpcpb.CommitRequest, opts ...grpc.CallOption) (*kvrpcpb.CommitResponse, error) + KvDeleteRange func(ctx context.Context, in *kvrpcpb.DeleteRangeRequest, opts ...grpc.CallOption) (*kvrpcpb.DeleteRangeResponse, error) + KvFlashbackToVersion func(ctx context.Context, in *kvrpcpb.FlashbackToVersionRequest, ...) (*kvrpcpb.FlashbackToVersionResponse, error) + KvGC func(ctx context.Context, in *kvrpcpb.GCRequest, opts ...grpc.CallOption) (*kvrpcpb.GCResponse, error) + KvGet func(ctx context.Context, in *kvrpcpb.GetRequest, opts ...grpc.CallOption) (*kvrpcpb.GetResponse, error) + KvImport func(ctx context.Context, in *kvrpcpb.ImportRequest, opts ...grpc.CallOption) (*kvrpcpb.ImportResponse, error) + KvPessimisticLock func(ctx context.Context, in *kvrpcpb.PessimisticLockRequest, ...) (*kvrpcpb.PessimisticLockResponse, error) + KvPrepareFlashbackToVersion func(ctx context.Context, in *kvrpcpb.PrepareFlashbackToVersionRequest, ...) (*kvrpcpb.PrepareFlashbackToVersionResponse, error) + KvPrewrite func(ctx context.Context, in *kvrpcpb.PrewriteRequest, opts ...grpc.CallOption) (*kvrpcpb.PrewriteResponse, error) + KvResolveLock func(ctx context.Context, in *kvrpcpb.ResolveLockRequest, opts ...grpc.CallOption) (*kvrpcpb.ResolveLockResponse, error) + KvScan func(ctx context.Context, in *kvrpcpb.ScanRequest, opts ...grpc.CallOption) (*kvrpcpb.ScanResponse, error) + KvScanLock func(ctx context.Context, in *kvrpcpb.ScanLockRequest, opts ...grpc.CallOption) (*kvrpcpb.ScanLockResponse, error) + KvTxnHeartBeat func(ctx context.Context, in *kvrpcpb.TxnHeartBeatRequest, opts ...grpc.CallOption) (*kvrpcpb.TxnHeartBeatResponse, error) + MvccGetByKey func(ctx context.Context, in *kvrpcpb.MvccGetByKeyRequest, opts ...grpc.CallOption) (*kvrpcpb.MvccGetByKeyResponse, error) + MvccGetByStartTs func(ctx context.Context, in *kvrpcpb.MvccGetByStartTsRequest, ...) (*kvrpcpb.MvccGetByStartTsResponse, error) + PhysicalScanLock func(ctx context.Context, in *kvrpcpb.PhysicalScanLockRequest, ...) (*kvrpcpb.PhysicalScanLockResponse, error) + Raft func(ctx context.Context, opts ...grpc.CallOption) (Tikv_RaftClient, error) + RawBatchDelete func(ctx context.Context, in *kvrpcpb.RawBatchDeleteRequest, ...) (*kvrpcpb.RawBatchDeleteResponse, error) + RawBatchGet func(ctx context.Context, in *kvrpcpb.RawBatchGetRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchGetResponse, error) + RawBatchPut func(ctx context.Context, in *kvrpcpb.RawBatchPutRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchPutResponse, error) + RawBatchScan func(ctx context.Context, in *kvrpcpb.RawBatchScanRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchScanResponse, error) + RawChecksum func(ctx context.Context, in *kvrpcpb.RawChecksumRequest, opts ...grpc.CallOption) (*kvrpcpb.RawChecksumResponse, error) + RawCompareAndSwap func(ctx context.Context, in *kvrpcpb.RawCASRequest, opts ...grpc.CallOption) (*kvrpcpb.RawCASResponse, error) + RawCoprocessor func(ctx context.Context, in *kvrpcpb.RawCoprocessorRequest, ...) (*kvrpcpb.RawCoprocessorResponse, error) + RawDelete func(ctx context.Context, in *kvrpcpb.RawDeleteRequest, opts ...grpc.CallOption) (*kvrpcpb.RawDeleteResponse, error) + RawDeleteRange func(ctx context.Context, in *kvrpcpb.RawDeleteRangeRequest, ...) (*kvrpcpb.RawDeleteRangeResponse, error) + RawGet func(ctx context.Context, in *kvrpcpb.RawGetRequest, opts ...grpc.CallOption) (*kvrpcpb.RawGetResponse, error) + RawGetKeyTTL func(ctx context.Context, in *kvrpcpb.RawGetKeyTTLRequest, opts ...grpc.CallOption) (*kvrpcpb.RawGetKeyTTLResponse, error) + RawPut func(ctx context.Context, in *kvrpcpb.RawPutRequest, opts ...grpc.CallOption) (*kvrpcpb.RawPutResponse, error) + RawScan func(ctx context.Context, in *kvrpcpb.RawScanRequest, opts ...grpc.CallOption) (*kvrpcpb.RawScanResponse, error) + ReadIndex func(ctx context.Context, in *kvrpcpb.ReadIndexRequest, opts ...grpc.CallOption) (*kvrpcpb.ReadIndexResponse, error) + RegisterLockObserver func(ctx context.Context, in *kvrpcpb.RegisterLockObserverRequest, ...) (*kvrpcpb.RegisterLockObserverResponse, error) + RemoveLockObserver func(ctx context.Context, in *kvrpcpb.RemoveLockObserverRequest, ...) (*kvrpcpb.RemoveLockObserverResponse, error) + ReportMPPTaskStatus func(ctx context.Context, in *mpp.ReportTaskStatusRequest, opts ...grpc.CallOption) (*mpp.ReportTaskStatusResponse, error) + Snapshot func(ctx context.Context, opts ...grpc.CallOption) (Tikv_SnapshotClient, error) + SplitRegion func(ctx context.Context, in *kvrpcpb.SplitRegionRequest, opts ...grpc.CallOption) (*kvrpcpb.SplitRegionResponse, error) + TabletSnapshot func(ctx context.Context, opts ...grpc.CallOption) (Tikv_TabletSnapshotClient, error) + TryAddLock func(ctx context.Context, in *disaggregated.TryAddLockRequest, ...) (*disaggregated.TryAddLockResponse, error) + TryMarkDelete func(ctx context.Context, in *disaggregated.TryMarkDeleteRequest, ...) (*disaggregated.TryMarkDeleteResponse, error) + UnsafeDestroyRange func(ctx context.Context, in *kvrpcpb.UnsafeDestroyRangeRequest, ...) (*kvrpcpb.UnsafeDestroyRangeResponse, error) + func NewTikvClient(cc *grpc.ClientConn) TikvClient + type TikvServer interface + BatchCommands func(Tikv_BatchCommandsServer) error + BatchCoprocessor func(*coprocessor.BatchRequest, Tikv_BatchCoprocessorServer) error + BatchRaft func(Tikv_BatchRaftServer) error + CancelDisaggTask func(context.Context, *disaggregated.CancelDisaggTaskRequest) (*disaggregated.CancelDisaggTaskResponse, error) + CancelMPPTask func(context.Context, *mpp.CancelTaskRequest) (*mpp.CancelTaskResponse, error) + CheckLeader func(context.Context, *kvrpcpb.CheckLeaderRequest) (*kvrpcpb.CheckLeaderResponse, error) + CheckLockObserver func(context.Context, *kvrpcpb.CheckLockObserverRequest) (*kvrpcpb.CheckLockObserverResponse, error) + Compact func(context.Context, *kvrpcpb.CompactRequest) (*kvrpcpb.CompactResponse, error) + Coprocessor func(context.Context, *coprocessor.Request) (*coprocessor.Response, error) + CoprocessorStream func(*coprocessor.Request, Tikv_CoprocessorStreamServer) error + DispatchMPPTask func(context.Context, *mpp.DispatchTaskRequest) (*mpp.DispatchTaskResponse, error) + EstablishDisaggTask func(context.Context, *disaggregated.EstablishDisaggTaskRequest) (*disaggregated.EstablishDisaggTaskResponse, error) + EstablishMPPConnection func(*mpp.EstablishMPPConnectionRequest, Tikv_EstablishMPPConnectionServer) error + FetchDisaggPages func(*disaggregated.FetchDisaggPagesRequest, Tikv_FetchDisaggPagesServer) error + GetDisaggConfig func(context.Context, *disaggregated.GetDisaggConfigRequest) (*disaggregated.GetDisaggConfigResponse, error) + GetLockWaitHistory func(context.Context, *kvrpcpb.GetLockWaitHistoryRequest) (*kvrpcpb.GetLockWaitHistoryResponse, error) + GetLockWaitInfo func(context.Context, *kvrpcpb.GetLockWaitInfoRequest) (*kvrpcpb.GetLockWaitInfoResponse, error) + GetStoreSafeTS func(context.Context, *kvrpcpb.StoreSafeTSRequest) (*kvrpcpb.StoreSafeTSResponse, error) + GetTiFlashSystemTable func(context.Context, *kvrpcpb.TiFlashSystemTableRequest) (*kvrpcpb.TiFlashSystemTableResponse, error) + IsAlive func(context.Context, *mpp.IsAliveRequest) (*mpp.IsAliveResponse, error) + KVPessimisticRollback func(context.Context, *kvrpcpb.PessimisticRollbackRequest) (*kvrpcpb.PessimisticRollbackResponse, error) + KvBatchGet func(context.Context, *kvrpcpb.BatchGetRequest) (*kvrpcpb.BatchGetResponse, error) + KvBatchRollback func(context.Context, *kvrpcpb.BatchRollbackRequest) (*kvrpcpb.BatchRollbackResponse, error) + KvCheckSecondaryLocks func(context.Context, *kvrpcpb.CheckSecondaryLocksRequest) (*kvrpcpb.CheckSecondaryLocksResponse, error) + KvCheckTxnStatus func(context.Context, *kvrpcpb.CheckTxnStatusRequest) (*kvrpcpb.CheckTxnStatusResponse, error) + KvCleanup func(context.Context, *kvrpcpb.CleanupRequest) (*kvrpcpb.CleanupResponse, error) + KvCommit func(context.Context, *kvrpcpb.CommitRequest) (*kvrpcpb.CommitResponse, error) + KvDeleteRange func(context.Context, *kvrpcpb.DeleteRangeRequest) (*kvrpcpb.DeleteRangeResponse, error) + KvFlashbackToVersion func(context.Context, *kvrpcpb.FlashbackToVersionRequest) (*kvrpcpb.FlashbackToVersionResponse, error) + KvGC func(context.Context, *kvrpcpb.GCRequest) (*kvrpcpb.GCResponse, error) + KvGet func(context.Context, *kvrpcpb.GetRequest) (*kvrpcpb.GetResponse, error) + KvImport func(context.Context, *kvrpcpb.ImportRequest) (*kvrpcpb.ImportResponse, error) + KvPessimisticLock func(context.Context, *kvrpcpb.PessimisticLockRequest) (*kvrpcpb.PessimisticLockResponse, error) + KvPrepareFlashbackToVersion func(context.Context, *kvrpcpb.PrepareFlashbackToVersionRequest) (*kvrpcpb.PrepareFlashbackToVersionResponse, error) + KvPrewrite func(context.Context, *kvrpcpb.PrewriteRequest) (*kvrpcpb.PrewriteResponse, error) + KvResolveLock func(context.Context, *kvrpcpb.ResolveLockRequest) (*kvrpcpb.ResolveLockResponse, error) + KvScan func(context.Context, *kvrpcpb.ScanRequest) (*kvrpcpb.ScanResponse, error) + KvScanLock func(context.Context, *kvrpcpb.ScanLockRequest) (*kvrpcpb.ScanLockResponse, error) + KvTxnHeartBeat func(context.Context, *kvrpcpb.TxnHeartBeatRequest) (*kvrpcpb.TxnHeartBeatResponse, error) + MvccGetByKey func(context.Context, *kvrpcpb.MvccGetByKeyRequest) (*kvrpcpb.MvccGetByKeyResponse, error) + MvccGetByStartTs func(context.Context, *kvrpcpb.MvccGetByStartTsRequest) (*kvrpcpb.MvccGetByStartTsResponse, error) + PhysicalScanLock func(context.Context, *kvrpcpb.PhysicalScanLockRequest) (*kvrpcpb.PhysicalScanLockResponse, error) + Raft func(Tikv_RaftServer) error + RawBatchDelete func(context.Context, *kvrpcpb.RawBatchDeleteRequest) (*kvrpcpb.RawBatchDeleteResponse, error) + RawBatchGet func(context.Context, *kvrpcpb.RawBatchGetRequest) (*kvrpcpb.RawBatchGetResponse, error) + RawBatchPut func(context.Context, *kvrpcpb.RawBatchPutRequest) (*kvrpcpb.RawBatchPutResponse, error) + RawBatchScan func(context.Context, *kvrpcpb.RawBatchScanRequest) (*kvrpcpb.RawBatchScanResponse, error) + RawChecksum func(context.Context, *kvrpcpb.RawChecksumRequest) (*kvrpcpb.RawChecksumResponse, error) + RawCompareAndSwap func(context.Context, *kvrpcpb.RawCASRequest) (*kvrpcpb.RawCASResponse, error) + RawCoprocessor func(context.Context, *kvrpcpb.RawCoprocessorRequest) (*kvrpcpb.RawCoprocessorResponse, error) + RawDelete func(context.Context, *kvrpcpb.RawDeleteRequest) (*kvrpcpb.RawDeleteResponse, error) + RawDeleteRange func(context.Context, *kvrpcpb.RawDeleteRangeRequest) (*kvrpcpb.RawDeleteRangeResponse, error) + RawGet func(context.Context, *kvrpcpb.RawGetRequest) (*kvrpcpb.RawGetResponse, error) + RawGetKeyTTL func(context.Context, *kvrpcpb.RawGetKeyTTLRequest) (*kvrpcpb.RawGetKeyTTLResponse, error) + RawPut func(context.Context, *kvrpcpb.RawPutRequest) (*kvrpcpb.RawPutResponse, error) + RawScan func(context.Context, *kvrpcpb.RawScanRequest) (*kvrpcpb.RawScanResponse, error) + ReadIndex func(context.Context, *kvrpcpb.ReadIndexRequest) (*kvrpcpb.ReadIndexResponse, error) + RegisterLockObserver func(context.Context, *kvrpcpb.RegisterLockObserverRequest) (*kvrpcpb.RegisterLockObserverResponse, error) + RemoveLockObserver func(context.Context, *kvrpcpb.RemoveLockObserverRequest) (*kvrpcpb.RemoveLockObserverResponse, error) + ReportMPPTaskStatus func(context.Context, *mpp.ReportTaskStatusRequest) (*mpp.ReportTaskStatusResponse, error) + Snapshot func(Tikv_SnapshotServer) error + SplitRegion func(context.Context, *kvrpcpb.SplitRegionRequest) (*kvrpcpb.SplitRegionResponse, error) + TabletSnapshot func(Tikv_TabletSnapshotServer) error + TryAddLock func(context.Context, *disaggregated.TryAddLockRequest) (*disaggregated.TryAddLockResponse, error) + TryMarkDelete func(context.Context, *disaggregated.TryMarkDeleteRequest) (*disaggregated.TryMarkDeleteResponse, error) + UnsafeDestroyRange func(context.Context, *kvrpcpb.UnsafeDestroyRangeRequest) (*kvrpcpb.UnsafeDestroyRangeResponse, error) + type Tikv_BatchCommandsClient interface + Recv func() (*BatchCommandsResponse, error) + Send func(*BatchCommandsRequest) error + type Tikv_BatchCommandsServer interface + Recv func() (*BatchCommandsRequest, error) + Send func(*BatchCommandsResponse) error + type Tikv_BatchCoprocessorClient interface + Recv func() (*coprocessor.BatchResponse, error) + type Tikv_BatchCoprocessorServer interface + Send func(*coprocessor.BatchResponse) error + type Tikv_BatchRaftClient interface + CloseAndRecv func() (*raft_serverpb.Done, error) + Send func(*BatchRaftMessage) error + type Tikv_BatchRaftServer interface + Recv func() (*BatchRaftMessage, error) + SendAndClose func(*raft_serverpb.Done) error + type Tikv_CoprocessorStreamClient interface + Recv func() (*coprocessor.Response, error) + type Tikv_CoprocessorStreamServer interface + Send func(*coprocessor.Response) error + type Tikv_EstablishMPPConnectionClient interface + Recv func() (*mpp.MPPDataPacket, error) + type Tikv_EstablishMPPConnectionServer interface + Send func(*mpp.MPPDataPacket) error + type Tikv_FetchDisaggPagesClient interface + Recv func() (*disaggregated.PagesPacket, error) + type Tikv_FetchDisaggPagesServer interface + Send func(*disaggregated.PagesPacket) error + type Tikv_RaftClient interface + CloseAndRecv func() (*raft_serverpb.Done, error) + Send func(*raft_serverpb.RaftMessage) error + type Tikv_RaftServer interface + Recv func() (*raft_serverpb.RaftMessage, error) + SendAndClose func(*raft_serverpb.Done) error + type Tikv_SnapshotClient interface + CloseAndRecv func() (*raft_serverpb.Done, error) + Send func(*raft_serverpb.SnapshotChunk) error + type Tikv_SnapshotServer interface + Recv func() (*raft_serverpb.SnapshotChunk, error) + SendAndClose func(*raft_serverpb.Done) error + type Tikv_TabletSnapshotClient interface + Recv func() (*raft_serverpb.TabletSnapshotResponse, error) + Send func(*raft_serverpb.TabletSnapshotRequest) error + type Tikv_TabletSnapshotServer interface + Recv func() (*raft_serverpb.TabletSnapshotRequest, error) + Send func(*raft_serverpb.TabletSnapshotResponse) error + type UnimplementedTikvServer struct + func (*UnimplementedTikvServer) BatchCommands(srv Tikv_BatchCommandsServer) error + func (*UnimplementedTikvServer) BatchCoprocessor(req *coprocessor.BatchRequest, srv Tikv_BatchCoprocessorServer) error + func (*UnimplementedTikvServer) BatchRaft(srv Tikv_BatchRaftServer) error + func (*UnimplementedTikvServer) CancelDisaggTask(ctx context.Context, req *disaggregated.CancelDisaggTaskRequest) (*disaggregated.CancelDisaggTaskResponse, error) + func (*UnimplementedTikvServer) CancelMPPTask(ctx context.Context, req *mpp.CancelTaskRequest) (*mpp.CancelTaskResponse, error) + func (*UnimplementedTikvServer) CheckLeader(ctx context.Context, req *kvrpcpb.CheckLeaderRequest) (*kvrpcpb.CheckLeaderResponse, error) + func (*UnimplementedTikvServer) CheckLockObserver(ctx context.Context, req *kvrpcpb.CheckLockObserverRequest) (*kvrpcpb.CheckLockObserverResponse, error) + func (*UnimplementedTikvServer) Compact(ctx context.Context, req *kvrpcpb.CompactRequest) (*kvrpcpb.CompactResponse, error) + func (*UnimplementedTikvServer) Coprocessor(ctx context.Context, req *coprocessor.Request) (*coprocessor.Response, error) + func (*UnimplementedTikvServer) CoprocessorStream(req *coprocessor.Request, srv Tikv_CoprocessorStreamServer) error + func (*UnimplementedTikvServer) DispatchMPPTask(ctx context.Context, req *mpp.DispatchTaskRequest) (*mpp.DispatchTaskResponse, error) + func (*UnimplementedTikvServer) EstablishDisaggTask(ctx context.Context, req *disaggregated.EstablishDisaggTaskRequest) (*disaggregated.EstablishDisaggTaskResponse, error) + func (*UnimplementedTikvServer) EstablishMPPConnection(req *mpp.EstablishMPPConnectionRequest, srv Tikv_EstablishMPPConnectionServer) error + func (*UnimplementedTikvServer) FetchDisaggPages(req *disaggregated.FetchDisaggPagesRequest, srv Tikv_FetchDisaggPagesServer) error + func (*UnimplementedTikvServer) GetDisaggConfig(ctx context.Context, req *disaggregated.GetDisaggConfigRequest) (*disaggregated.GetDisaggConfigResponse, error) + func (*UnimplementedTikvServer) GetLockWaitHistory(ctx context.Context, req *kvrpcpb.GetLockWaitHistoryRequest) (*kvrpcpb.GetLockWaitHistoryResponse, error) + func (*UnimplementedTikvServer) GetLockWaitInfo(ctx context.Context, req *kvrpcpb.GetLockWaitInfoRequest) (*kvrpcpb.GetLockWaitInfoResponse, error) + func (*UnimplementedTikvServer) GetStoreSafeTS(ctx context.Context, req *kvrpcpb.StoreSafeTSRequest) (*kvrpcpb.StoreSafeTSResponse, error) + func (*UnimplementedTikvServer) GetTiFlashSystemTable(ctx context.Context, req *kvrpcpb.TiFlashSystemTableRequest) (*kvrpcpb.TiFlashSystemTableResponse, error) + func (*UnimplementedTikvServer) IsAlive(ctx context.Context, req *mpp.IsAliveRequest) (*mpp.IsAliveResponse, error) + func (*UnimplementedTikvServer) KVPessimisticRollback(ctx context.Context, req *kvrpcpb.PessimisticRollbackRequest) (*kvrpcpb.PessimisticRollbackResponse, error) + func (*UnimplementedTikvServer) KvBatchGet(ctx context.Context, req *kvrpcpb.BatchGetRequest) (*kvrpcpb.BatchGetResponse, error) + func (*UnimplementedTikvServer) KvBatchRollback(ctx context.Context, req *kvrpcpb.BatchRollbackRequest) (*kvrpcpb.BatchRollbackResponse, error) + func (*UnimplementedTikvServer) KvCheckSecondaryLocks(ctx context.Context, req *kvrpcpb.CheckSecondaryLocksRequest) (*kvrpcpb.CheckSecondaryLocksResponse, error) + func (*UnimplementedTikvServer) KvCheckTxnStatus(ctx context.Context, req *kvrpcpb.CheckTxnStatusRequest) (*kvrpcpb.CheckTxnStatusResponse, error) + func (*UnimplementedTikvServer) KvCleanup(ctx context.Context, req *kvrpcpb.CleanupRequest) (*kvrpcpb.CleanupResponse, error) + func (*UnimplementedTikvServer) KvCommit(ctx context.Context, req *kvrpcpb.CommitRequest) (*kvrpcpb.CommitResponse, error) + func (*UnimplementedTikvServer) KvDeleteRange(ctx context.Context, req *kvrpcpb.DeleteRangeRequest) (*kvrpcpb.DeleteRangeResponse, error) + func (*UnimplementedTikvServer) KvFlashbackToVersion(ctx context.Context, req *kvrpcpb.FlashbackToVersionRequest) (*kvrpcpb.FlashbackToVersionResponse, error) + func (*UnimplementedTikvServer) KvGC(ctx context.Context, req *kvrpcpb.GCRequest) (*kvrpcpb.GCResponse, error) + func (*UnimplementedTikvServer) KvGet(ctx context.Context, req *kvrpcpb.GetRequest) (*kvrpcpb.GetResponse, error) + func (*UnimplementedTikvServer) KvImport(ctx context.Context, req *kvrpcpb.ImportRequest) (*kvrpcpb.ImportResponse, error) + func (*UnimplementedTikvServer) KvPessimisticLock(ctx context.Context, req *kvrpcpb.PessimisticLockRequest) (*kvrpcpb.PessimisticLockResponse, error) + func (*UnimplementedTikvServer) KvPrepareFlashbackToVersion(ctx context.Context, req *kvrpcpb.PrepareFlashbackToVersionRequest) (*kvrpcpb.PrepareFlashbackToVersionResponse, error) + func (*UnimplementedTikvServer) KvPrewrite(ctx context.Context, req *kvrpcpb.PrewriteRequest) (*kvrpcpb.PrewriteResponse, error) + func (*UnimplementedTikvServer) KvResolveLock(ctx context.Context, req *kvrpcpb.ResolveLockRequest) (*kvrpcpb.ResolveLockResponse, error) + func (*UnimplementedTikvServer) KvScan(ctx context.Context, req *kvrpcpb.ScanRequest) (*kvrpcpb.ScanResponse, error) + func (*UnimplementedTikvServer) KvScanLock(ctx context.Context, req *kvrpcpb.ScanLockRequest) (*kvrpcpb.ScanLockResponse, error) + func (*UnimplementedTikvServer) KvTxnHeartBeat(ctx context.Context, req *kvrpcpb.TxnHeartBeatRequest) (*kvrpcpb.TxnHeartBeatResponse, error) + func (*UnimplementedTikvServer) MvccGetByKey(ctx context.Context, req *kvrpcpb.MvccGetByKeyRequest) (*kvrpcpb.MvccGetByKeyResponse, error) + func (*UnimplementedTikvServer) MvccGetByStartTs(ctx context.Context, req *kvrpcpb.MvccGetByStartTsRequest) (*kvrpcpb.MvccGetByStartTsResponse, error) + func (*UnimplementedTikvServer) PhysicalScanLock(ctx context.Context, req *kvrpcpb.PhysicalScanLockRequest) (*kvrpcpb.PhysicalScanLockResponse, error) + func (*UnimplementedTikvServer) Raft(srv Tikv_RaftServer) error + func (*UnimplementedTikvServer) RawBatchDelete(ctx context.Context, req *kvrpcpb.RawBatchDeleteRequest) (*kvrpcpb.RawBatchDeleteResponse, error) + func (*UnimplementedTikvServer) RawBatchGet(ctx context.Context, req *kvrpcpb.RawBatchGetRequest) (*kvrpcpb.RawBatchGetResponse, error) + func (*UnimplementedTikvServer) RawBatchPut(ctx context.Context, req *kvrpcpb.RawBatchPutRequest) (*kvrpcpb.RawBatchPutResponse, error) + func (*UnimplementedTikvServer) RawBatchScan(ctx context.Context, req *kvrpcpb.RawBatchScanRequest) (*kvrpcpb.RawBatchScanResponse, error) + func (*UnimplementedTikvServer) RawChecksum(ctx context.Context, req *kvrpcpb.RawChecksumRequest) (*kvrpcpb.RawChecksumResponse, error) + func (*UnimplementedTikvServer) RawCompareAndSwap(ctx context.Context, req *kvrpcpb.RawCASRequest) (*kvrpcpb.RawCASResponse, error) + func (*UnimplementedTikvServer) RawCoprocessor(ctx context.Context, req *kvrpcpb.RawCoprocessorRequest) (*kvrpcpb.RawCoprocessorResponse, error) + func (*UnimplementedTikvServer) RawDelete(ctx context.Context, req *kvrpcpb.RawDeleteRequest) (*kvrpcpb.RawDeleteResponse, error) + func (*UnimplementedTikvServer) RawDeleteRange(ctx context.Context, req *kvrpcpb.RawDeleteRangeRequest) (*kvrpcpb.RawDeleteRangeResponse, error) + func (*UnimplementedTikvServer) RawGet(ctx context.Context, req *kvrpcpb.RawGetRequest) (*kvrpcpb.RawGetResponse, error) + func (*UnimplementedTikvServer) RawGetKeyTTL(ctx context.Context, req *kvrpcpb.RawGetKeyTTLRequest) (*kvrpcpb.RawGetKeyTTLResponse, error) + func (*UnimplementedTikvServer) RawPut(ctx context.Context, req *kvrpcpb.RawPutRequest) (*kvrpcpb.RawPutResponse, error) + func (*UnimplementedTikvServer) RawScan(ctx context.Context, req *kvrpcpb.RawScanRequest) (*kvrpcpb.RawScanResponse, error) + func (*UnimplementedTikvServer) ReadIndex(ctx context.Context, req *kvrpcpb.ReadIndexRequest) (*kvrpcpb.ReadIndexResponse, error) + func (*UnimplementedTikvServer) RegisterLockObserver(ctx context.Context, req *kvrpcpb.RegisterLockObserverRequest) (*kvrpcpb.RegisterLockObserverResponse, error) + func (*UnimplementedTikvServer) RemoveLockObserver(ctx context.Context, req *kvrpcpb.RemoveLockObserverRequest) (*kvrpcpb.RemoveLockObserverResponse, error) + func (*UnimplementedTikvServer) ReportMPPTaskStatus(ctx context.Context, req *mpp.ReportTaskStatusRequest) (*mpp.ReportTaskStatusResponse, error) + func (*UnimplementedTikvServer) Snapshot(srv Tikv_SnapshotServer) error + func (*UnimplementedTikvServer) SplitRegion(ctx context.Context, req *kvrpcpb.SplitRegionRequest) (*kvrpcpb.SplitRegionResponse, error) + func (*UnimplementedTikvServer) TabletSnapshot(srv Tikv_TabletSnapshotServer) error + func (*UnimplementedTikvServer) TryAddLock(ctx context.Context, req *disaggregated.TryAddLockRequest) (*disaggregated.TryAddLockResponse, error) + func (*UnimplementedTikvServer) TryMarkDelete(ctx context.Context, req *disaggregated.TryMarkDeleteRequest) (*disaggregated.TryMarkDeleteResponse, error) + func (*UnimplementedTikvServer) UnsafeDestroyRange(ctx context.Context, req *kvrpcpb.UnsafeDestroyRangeRequest) (*kvrpcpb.UnsafeDestroyRangeResponse, error)