tikvpb

package
v0.0.0-...-98b0a12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 26, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTikvpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTikvpb   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTikvServer 

func RegisterTikvServer(s *grpc.Server, srv TikvServer)

Types

type BatchCommandsEmptyRequest 

type BatchCommandsEmptyRequest struct {
	// ID of the test request.
	TestId uint64 `protobuf:"varint,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	// TiKV needs to delay at least such a time to response the client.
	DelayTime            uint64   `protobuf:"varint,2,opt,name=delay_time,json=delayTime,proto3" json:"delay_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchCommandsEmptyRequest) Descriptor 

func (*BatchCommandsEmptyRequest) Descriptor() ([]byte, []int)

func (*BatchCommandsEmptyRequest) GetDelayTime 

func (m *BatchCommandsEmptyRequest) GetDelayTime() uint64

func (*BatchCommandsEmptyRequest) GetTestId 

func (m *BatchCommandsEmptyRequest) GetTestId() uint64

func (*BatchCommandsEmptyRequest) Marshal 

func (m *BatchCommandsEmptyRequest) Marshal() (dAtA []byte, err error)

func (*BatchCommandsEmptyRequest) MarshalTo 

func (m *BatchCommandsEmptyRequest) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsEmptyRequest) ProtoMessage 

func (*BatchCommandsEmptyRequest) ProtoMessage()

func (*BatchCommandsEmptyRequest) Reset 

func (m *BatchCommandsEmptyRequest) Reset()

func (*BatchCommandsEmptyRequest) Size 

func (m *BatchCommandsEmptyRequest) Size() (n int)

func (*BatchCommandsEmptyRequest) String 

func (m *BatchCommandsEmptyRequest) String() string

func (*BatchCommandsEmptyRequest) Unmarshal 

func (m *BatchCommandsEmptyRequest) Unmarshal(dAtA []byte) error

func (*BatchCommandsEmptyRequest) XXX_DiscardUnknown 

func (m *BatchCommandsEmptyRequest) XXX_DiscardUnknown()

func (*BatchCommandsEmptyRequest) XXX_Marshal 

func (m *BatchCommandsEmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsEmptyRequest) XXX_Merge 

func (dst *BatchCommandsEmptyRequest) XXX_Merge(src proto.Message)

func (*BatchCommandsEmptyRequest) XXX_Size 

func (m *BatchCommandsEmptyRequest) XXX_Size() int

func (*BatchCommandsEmptyRequest) XXX_Unmarshal 

func (m *BatchCommandsEmptyRequest) XXX_Unmarshal(b []byte) error

type BatchCommandsEmptyResponse 

type BatchCommandsEmptyResponse struct {
	// ID of the test request.
	TestId               uint64   `protobuf:"varint,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchCommandsEmptyResponse) Descriptor 

func (*BatchCommandsEmptyResponse) Descriptor() ([]byte, []int)

func (*BatchCommandsEmptyResponse) GetTestId 

func (m *BatchCommandsEmptyResponse) GetTestId() uint64

func (*BatchCommandsEmptyResponse) Marshal 

func (m *BatchCommandsEmptyResponse) Marshal() (dAtA []byte, err error)

func (*BatchCommandsEmptyResponse) MarshalTo 

func (m *BatchCommandsEmptyResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsEmptyResponse) ProtoMessage 

func (*BatchCommandsEmptyResponse) ProtoMessage()

func (*BatchCommandsEmptyResponse) Reset 

func (m *BatchCommandsEmptyResponse) Reset()

func (*BatchCommandsEmptyResponse) Size 

func (m *BatchCommandsEmptyResponse) Size() (n int)

func (*BatchCommandsEmptyResponse) String 

func (m *BatchCommandsEmptyResponse) String() string

func (*BatchCommandsEmptyResponse) Unmarshal 

func (m *BatchCommandsEmptyResponse) Unmarshal(dAtA []byte) error

func (*BatchCommandsEmptyResponse) XXX_DiscardUnknown 

func (m *BatchCommandsEmptyResponse) XXX_DiscardUnknown()

func (*BatchCommandsEmptyResponse) XXX_Marshal 

func (m *BatchCommandsEmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsEmptyResponse) XXX_Merge 

func (dst *BatchCommandsEmptyResponse) XXX_Merge(src proto.Message)

func (*BatchCommandsEmptyResponse) XXX_Size 

func (m *BatchCommandsEmptyResponse) XXX_Size() int

func (*BatchCommandsEmptyResponse) XXX_Unmarshal 

func (m *BatchCommandsEmptyResponse) XXX_Unmarshal(b []byte) error

type BatchCommandsRequest 

type BatchCommandsRequest struct {
	Requests             []*BatchCommandsRequest_Request `protobuf:"bytes,1,rep,name=requests" json:"requests,omitempty"`
	RequestIds           []uint64                        `protobuf:"varint,2,rep,packed,name=request_ids,json=requestIds" json:"request_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*BatchCommandsRequest) Descriptor 

func (*BatchCommandsRequest) Descriptor() ([]byte, []int)

func (*BatchCommandsRequest) GetRequestIds 

func (m *BatchCommandsRequest) GetRequestIds() []uint64

func (*BatchCommandsRequest) GetRequests 

func (m *BatchCommandsRequest) GetRequests() []*BatchCommandsRequest_Request

func (*BatchCommandsRequest) Marshal 

func (m *BatchCommandsRequest) Marshal() (dAtA []byte, err error)

func (*BatchCommandsRequest) MarshalTo 

func (m *BatchCommandsRequest) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest) ProtoMessage 

func (*BatchCommandsRequest) ProtoMessage()

func (*BatchCommandsRequest) Reset 

func (m *BatchCommandsRequest) Reset()

func (*BatchCommandsRequest) Size 

func (m *BatchCommandsRequest) Size() (n int)

func (*BatchCommandsRequest) String 

func (m *BatchCommandsRequest) String() string

func (*BatchCommandsRequest) Unmarshal 

func (m *BatchCommandsRequest) Unmarshal(dAtA []byte) error

func (*BatchCommandsRequest) XXX_DiscardUnknown 

func (m *BatchCommandsRequest) XXX_DiscardUnknown()

func (*BatchCommandsRequest) XXX_Marshal 

func (m *BatchCommandsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsRequest) XXX_Merge 

func (dst *BatchCommandsRequest) XXX_Merge(src proto.Message)

func (*BatchCommandsRequest) XXX_Size 

func (m *BatchCommandsRequest) XXX_Size() int

func (*BatchCommandsRequest) XXX_Unmarshal 

func (m *BatchCommandsRequest) XXX_Unmarshal(b []byte) error

type BatchCommandsRequest_Request 

type BatchCommandsRequest_Request struct {
	// Types that are valid to be assigned to Cmd:
	//	*BatchCommandsRequest_Request_Get
	//	*BatchCommandsRequest_Request_Scan
	//	*BatchCommandsRequest_Request_Prewrite
	//	*BatchCommandsRequest_Request_Commit
	//	*BatchCommandsRequest_Request_Import
	//	*BatchCommandsRequest_Request_Cleanup
	//	*BatchCommandsRequest_Request_BatchGet
	//	*BatchCommandsRequest_Request_BatchRollback
	//	*BatchCommandsRequest_Request_ScanLock
	//	*BatchCommandsRequest_Request_ResolveLock
	//	*BatchCommandsRequest_Request_GC
	//	*BatchCommandsRequest_Request_DeleteRange
	//	*BatchCommandsRequest_Request_RawGet
	//	*BatchCommandsRequest_Request_RawBatchGet
	//	*BatchCommandsRequest_Request_RawPut
	//	*BatchCommandsRequest_Request_RawBatchPut
	//	*BatchCommandsRequest_Request_RawDelete
	//	*BatchCommandsRequest_Request_RawBatchDelete
	//	*BatchCommandsRequest_Request_RawScan
	//	*BatchCommandsRequest_Request_RawDeleteRange
	//	*BatchCommandsRequest_Request_RawBatchScan
	//	*BatchCommandsRequest_Request_Coprocessor
	//	*BatchCommandsRequest_Request_PessimisticLock
	//	*BatchCommandsRequest_Request_PessimisticRollback
	//	*BatchCommandsRequest_Request_CheckTxnStatus
	//	*BatchCommandsRequest_Request_TxnHeartBeat
	//	*BatchCommandsRequest_Request_Empty
	Cmd                  isBatchCommandsRequest_Request_Cmd `protobuf_oneof:"cmd"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*BatchCommandsRequest_Request) Descriptor 

func (*BatchCommandsRequest_Request) Descriptor() ([]byte, []int)

func (*BatchCommandsRequest_Request) GetBatchGet 

func (m *BatchCommandsRequest_Request) GetBatchGet() *kvrpcpb.BatchGetRequest

func (*BatchCommandsRequest_Request) GetBatchRollback 

func (m *BatchCommandsRequest_Request) GetBatchRollback() *kvrpcpb.BatchRollbackRequest

func (*BatchCommandsRequest_Request) GetCheckTxnStatus 

func (m *BatchCommandsRequest_Request) GetCheckTxnStatus() *kvrpcpb.CheckTxnStatusRequest

func (*BatchCommandsRequest_Request) GetCleanup 

func (m *BatchCommandsRequest_Request) GetCleanup() *kvrpcpb.CleanupRequest

func (*BatchCommandsRequest_Request) GetCmd 

func (m *BatchCommandsRequest_Request) GetCmd() isBatchCommandsRequest_Request_Cmd

func (*BatchCommandsRequest_Request) GetCommit 

func (m *BatchCommandsRequest_Request) GetCommit() *kvrpcpb.CommitRequest

func (*BatchCommandsRequest_Request) GetCoprocessor 

func (m *BatchCommandsRequest_Request) GetCoprocessor() *coprocessor.Request

func (*BatchCommandsRequest_Request) GetDeleteRange 

func (m *BatchCommandsRequest_Request) GetDeleteRange() *kvrpcpb.DeleteRangeRequest

func (*BatchCommandsRequest_Request) GetEmpty 

func (m *BatchCommandsRequest_Request) GetEmpty() *BatchCommandsEmptyRequest

func (*BatchCommandsRequest_Request) GetGC 

func (m *BatchCommandsRequest_Request) GetGC() *kvrpcpb.GCRequest

func (*BatchCommandsRequest_Request) GetGet 

func (m *BatchCommandsRequest_Request) GetGet() *kvrpcpb.GetRequest

func (*BatchCommandsRequest_Request) GetImport 

func (m *BatchCommandsRequest_Request) GetImport() *kvrpcpb.ImportRequest

func (*BatchCommandsRequest_Request) GetPessimisticLock 

func (m *BatchCommandsRequest_Request) GetPessimisticLock() *kvrpcpb.PessimisticLockRequest

func (*BatchCommandsRequest_Request) GetPessimisticRollback 

func (m *BatchCommandsRequest_Request) GetPessimisticRollback() *kvrpcpb.PessimisticRollbackRequest

func (*BatchCommandsRequest_Request) GetPrewrite 

func (m *BatchCommandsRequest_Request) GetPrewrite() *kvrpcpb.PrewriteRequest

func (*BatchCommandsRequest_Request) GetRawBatchDelete 

func (m *BatchCommandsRequest_Request) GetRawBatchDelete() *kvrpcpb.RawBatchDeleteRequest

func (*BatchCommandsRequest_Request) GetRawBatchGet 

func (m *BatchCommandsRequest_Request) GetRawBatchGet() *kvrpcpb.RawBatchGetRequest

func (*BatchCommandsRequest_Request) GetRawBatchPut 

func (m *BatchCommandsRequest_Request) GetRawBatchPut() *kvrpcpb.RawBatchPutRequest

func (*BatchCommandsRequest_Request) GetRawBatchScan 

func (m *BatchCommandsRequest_Request) GetRawBatchScan() *kvrpcpb.RawBatchScanRequest

func (*BatchCommandsRequest_Request) GetRawDelete 

func (m *BatchCommandsRequest_Request) GetRawDelete() *kvrpcpb.RawDeleteRequest

func (*BatchCommandsRequest_Request) GetRawDeleteRange 

func (m *BatchCommandsRequest_Request) GetRawDeleteRange() *kvrpcpb.RawDeleteRangeRequest

func (*BatchCommandsRequest_Request) GetRawGet 

func (m *BatchCommandsRequest_Request) GetRawGet() *kvrpcpb.RawGetRequest

func (*BatchCommandsRequest_Request) GetRawPut 

func (m *BatchCommandsRequest_Request) GetRawPut() *kvrpcpb.RawPutRequest

func (*BatchCommandsRequest_Request) GetRawScan 

func (m *BatchCommandsRequest_Request) GetRawScan() *kvrpcpb.RawScanRequest

func (*BatchCommandsRequest_Request) GetResolveLock 

func (m *BatchCommandsRequest_Request) GetResolveLock() *kvrpcpb.ResolveLockRequest

func (*BatchCommandsRequest_Request) GetScan 

func (m *BatchCommandsRequest_Request) GetScan() *kvrpcpb.ScanRequest

func (*BatchCommandsRequest_Request) GetScanLock 

func (m *BatchCommandsRequest_Request) GetScanLock() *kvrpcpb.ScanLockRequest

func (*BatchCommandsRequest_Request) GetTxnHeartBeat 

func (m *BatchCommandsRequest_Request) GetTxnHeartBeat() *kvrpcpb.TxnHeartBeatRequest

func (*BatchCommandsRequest_Request) Marshal 

func (m *BatchCommandsRequest_Request) Marshal() (dAtA []byte, err error)

func (*BatchCommandsRequest_Request) MarshalTo 

func (m *BatchCommandsRequest_Request) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request) ProtoMessage 

func (*BatchCommandsRequest_Request) ProtoMessage()

func (*BatchCommandsRequest_Request) Reset 

func (m *BatchCommandsRequest_Request) Reset()

func (*BatchCommandsRequest_Request) Size 

func (m *BatchCommandsRequest_Request) Size() (n int)

func (*BatchCommandsRequest_Request) String 

func (m *BatchCommandsRequest_Request) String() string

func (*BatchCommandsRequest_Request) Unmarshal 

func (m *BatchCommandsRequest_Request) Unmarshal(dAtA []byte) error

func (*BatchCommandsRequest_Request) XXX_DiscardUnknown 

func (m *BatchCommandsRequest_Request) XXX_DiscardUnknown()

func (*BatchCommandsRequest_Request) XXX_Marshal 

func (m *BatchCommandsRequest_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsRequest_Request) XXX_Merge 

func (dst *BatchCommandsRequest_Request) XXX_Merge(src proto.Message)

func (*BatchCommandsRequest_Request) XXX_OneofFuncs 

func (*BatchCommandsRequest_Request) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*BatchCommandsRequest_Request) XXX_Size 

func (m *BatchCommandsRequest_Request) XXX_Size() int

func (*BatchCommandsRequest_Request) XXX_Unmarshal 

func (m *BatchCommandsRequest_Request) XXX_Unmarshal(b []byte) error

type BatchCommandsRequest_Request_BatchGet 

type BatchCommandsRequest_Request_BatchGet struct {
	BatchGet *kvrpcpb.BatchGetRequest `protobuf:"bytes,7,opt,name=BatchGet,oneof"`
}

func (*BatchCommandsRequest_Request_BatchGet) MarshalTo 

func (m *BatchCommandsRequest_Request_BatchGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_BatchGet) Size 

func (m *BatchCommandsRequest_Request_BatchGet) Size() (n int)

type BatchCommandsRequest_Request_BatchRollback 

type BatchCommandsRequest_Request_BatchRollback struct {
	BatchRollback *kvrpcpb.BatchRollbackRequest `protobuf:"bytes,8,opt,name=BatchRollback,oneof"`
}

func (*BatchCommandsRequest_Request_BatchRollback) MarshalTo 

func (m *BatchCommandsRequest_Request_BatchRollback) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_BatchRollback) Size 

func (m *BatchCommandsRequest_Request_BatchRollback) Size() (n int)

type BatchCommandsRequest_Request_CheckTxnStatus 

type BatchCommandsRequest_Request_CheckTxnStatus struct {
	CheckTxnStatus *kvrpcpb.CheckTxnStatusRequest `protobuf:"bytes,25,opt,name=CheckTxnStatus,oneof"`
}

func (*BatchCommandsRequest_Request_CheckTxnStatus) MarshalTo 

func (m *BatchCommandsRequest_Request_CheckTxnStatus) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_CheckTxnStatus) Size 

func (m *BatchCommandsRequest_Request_CheckTxnStatus) Size() (n int)

type BatchCommandsRequest_Request_Cleanup 

type BatchCommandsRequest_Request_Cleanup struct {
	Cleanup *kvrpcpb.CleanupRequest `protobuf:"bytes,6,opt,name=Cleanup,oneof"`
}

func (*BatchCommandsRequest_Request_Cleanup) MarshalTo 

func (m *BatchCommandsRequest_Request_Cleanup) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Cleanup) Size 

func (m *BatchCommandsRequest_Request_Cleanup) Size() (n int)

type BatchCommandsRequest_Request_Commit 

type BatchCommandsRequest_Request_Commit struct {
	Commit *kvrpcpb.CommitRequest `protobuf:"bytes,4,opt,name=Commit,oneof"`
}

func (*BatchCommandsRequest_Request_Commit) MarshalTo 

func (m *BatchCommandsRequest_Request_Commit) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Commit) Size 

func (m *BatchCommandsRequest_Request_Commit) Size() (n int)

type BatchCommandsRequest_Request_Coprocessor 

type BatchCommandsRequest_Request_Coprocessor struct {
	Coprocessor *coprocessor.Request `protobuf:"bytes,22,opt,name=Coprocessor,oneof"`
}

func (*BatchCommandsRequest_Request_Coprocessor) MarshalTo 

func (m *BatchCommandsRequest_Request_Coprocessor) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Coprocessor) Size 

func (m *BatchCommandsRequest_Request_Coprocessor) Size() (n int)

type BatchCommandsRequest_Request_DeleteRange 

type BatchCommandsRequest_Request_DeleteRange struct {
	DeleteRange *kvrpcpb.DeleteRangeRequest `protobuf:"bytes,12,opt,name=DeleteRange,oneof"`
}

func (*BatchCommandsRequest_Request_DeleteRange) MarshalTo 

func (m *BatchCommandsRequest_Request_DeleteRange) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_DeleteRange) Size 

func (m *BatchCommandsRequest_Request_DeleteRange) Size() (n int)

type BatchCommandsRequest_Request_Empty 

type BatchCommandsRequest_Request_Empty struct {
	Empty *BatchCommandsEmptyRequest `protobuf:"bytes,255,opt,name=Empty,oneof"`
}

func (*BatchCommandsRequest_Request_Empty) MarshalTo 

func (m *BatchCommandsRequest_Request_Empty) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Empty) Size 

func (m *BatchCommandsRequest_Request_Empty) Size() (n int)

type BatchCommandsRequest_Request_GC 

type BatchCommandsRequest_Request_GC struct {
	GC *kvrpcpb.GCRequest `protobuf:"bytes,11,opt,name=GC,oneof"`
}

func (*BatchCommandsRequest_Request_GC) MarshalTo 

func (m *BatchCommandsRequest_Request_GC) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_GC) Size 

func (m *BatchCommandsRequest_Request_GC) Size() (n int)

type BatchCommandsRequest_Request_Get 

type BatchCommandsRequest_Request_Get struct {
	Get *kvrpcpb.GetRequest `protobuf:"bytes,1,opt,name=Get,oneof"`
}

func (*BatchCommandsRequest_Request_Get) MarshalTo 

func (m *BatchCommandsRequest_Request_Get) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Get) Size 

func (m *BatchCommandsRequest_Request_Get) Size() (n int)

type BatchCommandsRequest_Request_Import 

type BatchCommandsRequest_Request_Import struct {
	Import *kvrpcpb.ImportRequest `protobuf:"bytes,5,opt,name=Import,oneof"`
}

func (*BatchCommandsRequest_Request_Import) MarshalTo 

func (m *BatchCommandsRequest_Request_Import) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Import) Size 

func (m *BatchCommandsRequest_Request_Import) Size() (n int)

type BatchCommandsRequest_Request_PessimisticLock 

type BatchCommandsRequest_Request_PessimisticLock struct {
	PessimisticLock *kvrpcpb.PessimisticLockRequest `protobuf:"bytes,23,opt,name=PessimisticLock,oneof"`
}

func (*BatchCommandsRequest_Request_PessimisticLock) MarshalTo 

func (m *BatchCommandsRequest_Request_PessimisticLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_PessimisticLock) Size 

func (m *BatchCommandsRequest_Request_PessimisticLock) Size() (n int)

type BatchCommandsRequest_Request_PessimisticRollback 

type BatchCommandsRequest_Request_PessimisticRollback struct {
	PessimisticRollback *kvrpcpb.PessimisticRollbackRequest `protobuf:"bytes,24,opt,name=PessimisticRollback,oneof"`
}

func (*BatchCommandsRequest_Request_PessimisticRollback) MarshalTo 

func (m *BatchCommandsRequest_Request_PessimisticRollback) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_PessimisticRollback) Size 

func (m *BatchCommandsRequest_Request_PessimisticRollback) Size() (n int)

type BatchCommandsRequest_Request_Prewrite 

type BatchCommandsRequest_Request_Prewrite struct {
	Prewrite *kvrpcpb.PrewriteRequest `protobuf:"bytes,3,opt,name=Prewrite,oneof"`
}

func (*BatchCommandsRequest_Request_Prewrite) MarshalTo 

func (m *BatchCommandsRequest_Request_Prewrite) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Prewrite) Size 

func (m *BatchCommandsRequest_Request_Prewrite) Size() (n int)

type BatchCommandsRequest_Request_RawBatchDelete 

type BatchCommandsRequest_Request_RawBatchDelete struct {
	RawBatchDelete *kvrpcpb.RawBatchDeleteRequest `protobuf:"bytes,18,opt,name=RawBatchDelete,oneof"`
}

func (*BatchCommandsRequest_Request_RawBatchDelete) MarshalTo 

func (m *BatchCommandsRequest_Request_RawBatchDelete) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawBatchDelete) Size 

func (m *BatchCommandsRequest_Request_RawBatchDelete) Size() (n int)

type BatchCommandsRequest_Request_RawBatchGet 

type BatchCommandsRequest_Request_RawBatchGet struct {
	RawBatchGet *kvrpcpb.RawBatchGetRequest `protobuf:"bytes,14,opt,name=RawBatchGet,oneof"`
}

func (*BatchCommandsRequest_Request_RawBatchGet) MarshalTo 

func (m *BatchCommandsRequest_Request_RawBatchGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawBatchGet) Size 

func (m *BatchCommandsRequest_Request_RawBatchGet) Size() (n int)

type BatchCommandsRequest_Request_RawBatchPut 

type BatchCommandsRequest_Request_RawBatchPut struct {
	RawBatchPut *kvrpcpb.RawBatchPutRequest `protobuf:"bytes,16,opt,name=RawBatchPut,oneof"`
}

func (*BatchCommandsRequest_Request_RawBatchPut) MarshalTo 

func (m *BatchCommandsRequest_Request_RawBatchPut) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawBatchPut) Size 

func (m *BatchCommandsRequest_Request_RawBatchPut) Size() (n int)

type BatchCommandsRequest_Request_RawBatchScan 

type BatchCommandsRequest_Request_RawBatchScan struct {
	RawBatchScan *kvrpcpb.RawBatchScanRequest `protobuf:"bytes,21,opt,name=RawBatchScan,oneof"`
}

func (*BatchCommandsRequest_Request_RawBatchScan) MarshalTo 

func (m *BatchCommandsRequest_Request_RawBatchScan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawBatchScan) Size 

func (m *BatchCommandsRequest_Request_RawBatchScan) Size() (n int)

type BatchCommandsRequest_Request_RawDelete 

type BatchCommandsRequest_Request_RawDelete struct {
	RawDelete *kvrpcpb.RawDeleteRequest `protobuf:"bytes,17,opt,name=RawDelete,oneof"`
}

func (*BatchCommandsRequest_Request_RawDelete) MarshalTo 

func (m *BatchCommandsRequest_Request_RawDelete) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawDelete) Size 

func (m *BatchCommandsRequest_Request_RawDelete) Size() (n int)

type BatchCommandsRequest_Request_RawDeleteRange 

type BatchCommandsRequest_Request_RawDeleteRange struct {
	RawDeleteRange *kvrpcpb.RawDeleteRangeRequest `protobuf:"bytes,20,opt,name=RawDeleteRange,oneof"`
}

func (*BatchCommandsRequest_Request_RawDeleteRange) MarshalTo 

func (m *BatchCommandsRequest_Request_RawDeleteRange) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawDeleteRange) Size 

func (m *BatchCommandsRequest_Request_RawDeleteRange) Size() (n int)

type BatchCommandsRequest_Request_RawGet 

type BatchCommandsRequest_Request_RawGet struct {
	RawGet *kvrpcpb.RawGetRequest `protobuf:"bytes,13,opt,name=RawGet,oneof"`
}

func (*BatchCommandsRequest_Request_RawGet) MarshalTo 

func (m *BatchCommandsRequest_Request_RawGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawGet) Size 

func (m *BatchCommandsRequest_Request_RawGet) Size() (n int)

type BatchCommandsRequest_Request_RawPut 

type BatchCommandsRequest_Request_RawPut struct {
	RawPut *kvrpcpb.RawPutRequest `protobuf:"bytes,15,opt,name=RawPut,oneof"`
}

func (*BatchCommandsRequest_Request_RawPut) MarshalTo 

func (m *BatchCommandsRequest_Request_RawPut) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawPut) Size 

func (m *BatchCommandsRequest_Request_RawPut) Size() (n int)

type BatchCommandsRequest_Request_RawScan 

type BatchCommandsRequest_Request_RawScan struct {
	RawScan *kvrpcpb.RawScanRequest `protobuf:"bytes,19,opt,name=RawScan,oneof"`
}

func (*BatchCommandsRequest_Request_RawScan) MarshalTo 

func (m *BatchCommandsRequest_Request_RawScan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_RawScan) Size 

func (m *BatchCommandsRequest_Request_RawScan) Size() (n int)

type BatchCommandsRequest_Request_ResolveLock 

type BatchCommandsRequest_Request_ResolveLock struct {
	ResolveLock *kvrpcpb.ResolveLockRequest `protobuf:"bytes,10,opt,name=ResolveLock,oneof"`
}

func (*BatchCommandsRequest_Request_ResolveLock) MarshalTo 

func (m *BatchCommandsRequest_Request_ResolveLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_ResolveLock) Size 

func (m *BatchCommandsRequest_Request_ResolveLock) Size() (n int)

type BatchCommandsRequest_Request_Scan 

type BatchCommandsRequest_Request_Scan struct {
	Scan *kvrpcpb.ScanRequest `protobuf:"bytes,2,opt,name=Scan,oneof"`
}

func (*BatchCommandsRequest_Request_Scan) MarshalTo 

func (m *BatchCommandsRequest_Request_Scan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_Scan) Size 

func (m *BatchCommandsRequest_Request_Scan) Size() (n int)

type BatchCommandsRequest_Request_ScanLock 

type BatchCommandsRequest_Request_ScanLock struct {
	ScanLock *kvrpcpb.ScanLockRequest `protobuf:"bytes,9,opt,name=ScanLock,oneof"`
}

func (*BatchCommandsRequest_Request_ScanLock) MarshalTo 

func (m *BatchCommandsRequest_Request_ScanLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_ScanLock) Size 

func (m *BatchCommandsRequest_Request_ScanLock) Size() (n int)

type BatchCommandsRequest_Request_TxnHeartBeat 

type BatchCommandsRequest_Request_TxnHeartBeat struct {
	TxnHeartBeat *kvrpcpb.TxnHeartBeatRequest `protobuf:"bytes,26,opt,name=TxnHeartBeat,oneof"`
}

func (*BatchCommandsRequest_Request_TxnHeartBeat) MarshalTo 

func (m *BatchCommandsRequest_Request_TxnHeartBeat) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsRequest_Request_TxnHeartBeat) Size 

func (m *BatchCommandsRequest_Request_TxnHeartBeat) Size() (n int)

type BatchCommandsResponse 

type BatchCommandsResponse struct {
	Responses  []*BatchCommandsResponse_Response `protobuf:"bytes,1,rep,name=responses" json:"responses,omitempty"`
	RequestIds []uint64                          `protobuf:"varint,2,rep,packed,name=request_ids,json=requestIds" json:"request_ids,omitempty"`
	// 280 means TiKV gRPC cpu usage is 280%.
	TransportLayerLoad   uint64   `protobuf:"varint,3,opt,name=transport_layer_load,json=transportLayerLoad,proto3" json:"transport_layer_load,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchCommandsResponse) Descriptor 

func (*BatchCommandsResponse) Descriptor() ([]byte, []int)

func (*BatchCommandsResponse) GetRequestIds 

func (m *BatchCommandsResponse) GetRequestIds() []uint64

func (*BatchCommandsResponse) GetResponses 

func (m *BatchCommandsResponse) GetResponses() []*BatchCommandsResponse_Response

func (*BatchCommandsResponse) GetTransportLayerLoad 

func (m *BatchCommandsResponse) GetTransportLayerLoad() uint64

func (*BatchCommandsResponse) Marshal 

func (m *BatchCommandsResponse) Marshal() (dAtA []byte, err error)

func (*BatchCommandsResponse) MarshalTo 

func (m *BatchCommandsResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse) ProtoMessage 

func (*BatchCommandsResponse) ProtoMessage()

func (*BatchCommandsResponse) Reset 

func (m *BatchCommandsResponse) Reset()

func (*BatchCommandsResponse) Size 

func (m *BatchCommandsResponse) Size() (n int)

func (*BatchCommandsResponse) String 

func (m *BatchCommandsResponse) String() string

func (*BatchCommandsResponse) Unmarshal 

func (m *BatchCommandsResponse) Unmarshal(dAtA []byte) error

func (*BatchCommandsResponse) XXX_DiscardUnknown 

func (m *BatchCommandsResponse) XXX_DiscardUnknown()

func (*BatchCommandsResponse) XXX_Marshal 

func (m *BatchCommandsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsResponse) XXX_Merge 

func (dst *BatchCommandsResponse) XXX_Merge(src proto.Message)

func (*BatchCommandsResponse) XXX_Size 

func (m *BatchCommandsResponse) XXX_Size() int

func (*BatchCommandsResponse) XXX_Unmarshal 

func (m *BatchCommandsResponse) XXX_Unmarshal(b []byte) error

type BatchCommandsResponse_Response 

type BatchCommandsResponse_Response struct {
	// Types that are valid to be assigned to Cmd:
	//	*BatchCommandsResponse_Response_Get
	//	*BatchCommandsResponse_Response_Scan
	//	*BatchCommandsResponse_Response_Prewrite
	//	*BatchCommandsResponse_Response_Commit
	//	*BatchCommandsResponse_Response_Import
	//	*BatchCommandsResponse_Response_Cleanup
	//	*BatchCommandsResponse_Response_BatchGet
	//	*BatchCommandsResponse_Response_BatchRollback
	//	*BatchCommandsResponse_Response_ScanLock
	//	*BatchCommandsResponse_Response_ResolveLock
	//	*BatchCommandsResponse_Response_GC
	//	*BatchCommandsResponse_Response_DeleteRange
	//	*BatchCommandsResponse_Response_RawGet
	//	*BatchCommandsResponse_Response_RawBatchGet
	//	*BatchCommandsResponse_Response_RawPut
	//	*BatchCommandsResponse_Response_RawBatchPut
	//	*BatchCommandsResponse_Response_RawDelete
	//	*BatchCommandsResponse_Response_RawBatchDelete
	//	*BatchCommandsResponse_Response_RawScan
	//	*BatchCommandsResponse_Response_RawDeleteRange
	//	*BatchCommandsResponse_Response_RawBatchScan
	//	*BatchCommandsResponse_Response_Coprocessor
	//	*BatchCommandsResponse_Response_PessimisticLock
	//	*BatchCommandsResponse_Response_PessimisticRollback
	//	*BatchCommandsResponse_Response_CheckTxnStatus
	//	*BatchCommandsResponse_Response_TxnHeartBeat
	//	*BatchCommandsResponse_Response_Empty
	Cmd                  isBatchCommandsResponse_Response_Cmd `protobuf_oneof:"cmd"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*BatchCommandsResponse_Response) Descriptor 

func (*BatchCommandsResponse_Response) Descriptor() ([]byte, []int)

func (*BatchCommandsResponse_Response) GetBatchGet 

func (m *BatchCommandsResponse_Response) GetBatchGet() *kvrpcpb.BatchGetResponse

func (*BatchCommandsResponse_Response) GetBatchRollback 

func (m *BatchCommandsResponse_Response) GetBatchRollback() *kvrpcpb.BatchRollbackResponse

func (*BatchCommandsResponse_Response) GetCheckTxnStatus 

func (m *BatchCommandsResponse_Response) GetCheckTxnStatus() *kvrpcpb.CheckTxnStatusResponse

func (*BatchCommandsResponse_Response) GetCleanup 

func (m *BatchCommandsResponse_Response) GetCleanup() *kvrpcpb.CleanupResponse

func (*BatchCommandsResponse_Response) GetCmd 

func (m *BatchCommandsResponse_Response) GetCmd() isBatchCommandsResponse_Response_Cmd

func (*BatchCommandsResponse_Response) GetCommit 

func (m *BatchCommandsResponse_Response) GetCommit() *kvrpcpb.CommitResponse

func (*BatchCommandsResponse_Response) GetCoprocessor 

func (m *BatchCommandsResponse_Response) GetCoprocessor() *coprocessor.Response

func (*BatchCommandsResponse_Response) GetDeleteRange 

func (m *BatchCommandsResponse_Response) GetDeleteRange() *kvrpcpb.DeleteRangeResponse

func (*BatchCommandsResponse_Response) GetEmpty 

func (m *BatchCommandsResponse_Response) GetEmpty() *BatchCommandsEmptyResponse

func (*BatchCommandsResponse_Response) GetGC 

func (m *BatchCommandsResponse_Response) GetGC() *kvrpcpb.GCResponse

func (*BatchCommandsResponse_Response) GetGet 

func (m *BatchCommandsResponse_Response) GetGet() *kvrpcpb.GetResponse

func (*BatchCommandsResponse_Response) GetImport 

func (m *BatchCommandsResponse_Response) GetImport() *kvrpcpb.ImportResponse

func (*BatchCommandsResponse_Response) GetPessimisticLock 

func (m *BatchCommandsResponse_Response) GetPessimisticLock() *kvrpcpb.PessimisticLockResponse

func (*BatchCommandsResponse_Response) GetPessimisticRollback 

func (m *BatchCommandsResponse_Response) GetPessimisticRollback() *kvrpcpb.PessimisticRollbackResponse

func (*BatchCommandsResponse_Response) GetPrewrite 

func (m *BatchCommandsResponse_Response) GetPrewrite() *kvrpcpb.PrewriteResponse

func (*BatchCommandsResponse_Response) GetRawBatchDelete 

func (m *BatchCommandsResponse_Response) GetRawBatchDelete() *kvrpcpb.RawBatchDeleteResponse

func (*BatchCommandsResponse_Response) GetRawBatchGet 

func (m *BatchCommandsResponse_Response) GetRawBatchGet() *kvrpcpb.RawBatchGetResponse

func (*BatchCommandsResponse_Response) GetRawBatchPut 

func (m *BatchCommandsResponse_Response) GetRawBatchPut() *kvrpcpb.RawBatchPutResponse

func (*BatchCommandsResponse_Response) GetRawBatchScan 

func (m *BatchCommandsResponse_Response) GetRawBatchScan() *kvrpcpb.RawBatchScanResponse

func (*BatchCommandsResponse_Response) GetRawDelete 

func (m *BatchCommandsResponse_Response) GetRawDelete() *kvrpcpb.RawDeleteResponse

func (*BatchCommandsResponse_Response) GetRawDeleteRange 

func (m *BatchCommandsResponse_Response) GetRawDeleteRange() *kvrpcpb.RawDeleteRangeResponse

func (*BatchCommandsResponse_Response) GetRawGet 

func (m *BatchCommandsResponse_Response) GetRawGet() *kvrpcpb.RawGetResponse

func (*BatchCommandsResponse_Response) GetRawPut 

func (m *BatchCommandsResponse_Response) GetRawPut() *kvrpcpb.RawPutResponse

func (*BatchCommandsResponse_Response) GetRawScan 

func (m *BatchCommandsResponse_Response) GetRawScan() *kvrpcpb.RawScanResponse

func (*BatchCommandsResponse_Response) GetResolveLock 

func (m *BatchCommandsResponse_Response) GetResolveLock() *kvrpcpb.ResolveLockResponse

func (*BatchCommandsResponse_Response) GetScan 

func (m *BatchCommandsResponse_Response) GetScan() *kvrpcpb.ScanResponse

func (*BatchCommandsResponse_Response) GetScanLock 

func (m *BatchCommandsResponse_Response) GetScanLock() *kvrpcpb.ScanLockResponse

func (*BatchCommandsResponse_Response) GetTxnHeartBeat 

func (m *BatchCommandsResponse_Response) GetTxnHeartBeat() *kvrpcpb.TxnHeartBeatResponse

func (*BatchCommandsResponse_Response) Marshal 

func (m *BatchCommandsResponse_Response) Marshal() (dAtA []byte, err error)

func (*BatchCommandsResponse_Response) MarshalTo 

func (m *BatchCommandsResponse_Response) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response) ProtoMessage 

func (*BatchCommandsResponse_Response) ProtoMessage()

func (*BatchCommandsResponse_Response) Reset 

func (m *BatchCommandsResponse_Response) Reset()

func (*BatchCommandsResponse_Response) Size 

func (m *BatchCommandsResponse_Response) Size() (n int)

func (*BatchCommandsResponse_Response) String 

func (m *BatchCommandsResponse_Response) String() string

func (*BatchCommandsResponse_Response) Unmarshal 

func (m *BatchCommandsResponse_Response) Unmarshal(dAtA []byte) error

func (*BatchCommandsResponse_Response) XXX_DiscardUnknown 

func (m *BatchCommandsResponse_Response) XXX_DiscardUnknown()

func (*BatchCommandsResponse_Response) XXX_Marshal 

func (m *BatchCommandsResponse_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommandsResponse_Response) XXX_Merge 

func (dst *BatchCommandsResponse_Response) XXX_Merge(src proto.Message)

func (*BatchCommandsResponse_Response) XXX_OneofFuncs 

func (*BatchCommandsResponse_Response) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*BatchCommandsResponse_Response) XXX_Size 

func (m *BatchCommandsResponse_Response) XXX_Size() int

func (*BatchCommandsResponse_Response) XXX_Unmarshal 

func (m *BatchCommandsResponse_Response) XXX_Unmarshal(b []byte) error

type BatchCommandsResponse_Response_BatchGet 

type BatchCommandsResponse_Response_BatchGet struct {
	BatchGet *kvrpcpb.BatchGetResponse `protobuf:"bytes,7,opt,name=BatchGet,oneof"`
}

func (*BatchCommandsResponse_Response_BatchGet) MarshalTo 

func (m *BatchCommandsResponse_Response_BatchGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_BatchGet) Size 

func (m *BatchCommandsResponse_Response_BatchGet) Size() (n int)

type BatchCommandsResponse_Response_BatchRollback 

type BatchCommandsResponse_Response_BatchRollback struct {
	BatchRollback *kvrpcpb.BatchRollbackResponse `protobuf:"bytes,8,opt,name=BatchRollback,oneof"`
}

func (*BatchCommandsResponse_Response_BatchRollback) MarshalTo 

func (m *BatchCommandsResponse_Response_BatchRollback) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_BatchRollback) Size 

func (m *BatchCommandsResponse_Response_BatchRollback) Size() (n int)

type BatchCommandsResponse_Response_CheckTxnStatus 

type BatchCommandsResponse_Response_CheckTxnStatus struct {
	CheckTxnStatus *kvrpcpb.CheckTxnStatusResponse `protobuf:"bytes,25,opt,name=CheckTxnStatus,oneof"`
}

func (*BatchCommandsResponse_Response_CheckTxnStatus) MarshalTo 

func (m *BatchCommandsResponse_Response_CheckTxnStatus) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_CheckTxnStatus) Size 

func (m *BatchCommandsResponse_Response_CheckTxnStatus) Size() (n int)

type BatchCommandsResponse_Response_Cleanup 

type BatchCommandsResponse_Response_Cleanup struct {
	Cleanup *kvrpcpb.CleanupResponse `protobuf:"bytes,6,opt,name=Cleanup,oneof"`
}

func (*BatchCommandsResponse_Response_Cleanup) MarshalTo 

func (m *BatchCommandsResponse_Response_Cleanup) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Cleanup) Size 

func (m *BatchCommandsResponse_Response_Cleanup) Size() (n int)

type BatchCommandsResponse_Response_Commit 

type BatchCommandsResponse_Response_Commit struct {
	Commit *kvrpcpb.CommitResponse `protobuf:"bytes,4,opt,name=Commit,oneof"`
}

func (*BatchCommandsResponse_Response_Commit) MarshalTo 

func (m *BatchCommandsResponse_Response_Commit) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Commit) Size 

func (m *BatchCommandsResponse_Response_Commit) Size() (n int)

type BatchCommandsResponse_Response_Coprocessor 

type BatchCommandsResponse_Response_Coprocessor struct {
	Coprocessor *coprocessor.Response `protobuf:"bytes,22,opt,name=Coprocessor,oneof"`
}

func (*BatchCommandsResponse_Response_Coprocessor) MarshalTo 

func (m *BatchCommandsResponse_Response_Coprocessor) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Coprocessor) Size 

func (m *BatchCommandsResponse_Response_Coprocessor) Size() (n int)

type BatchCommandsResponse_Response_DeleteRange 

type BatchCommandsResponse_Response_DeleteRange struct {
	DeleteRange *kvrpcpb.DeleteRangeResponse `protobuf:"bytes,12,opt,name=DeleteRange,oneof"`
}

func (*BatchCommandsResponse_Response_DeleteRange) MarshalTo 

func (m *BatchCommandsResponse_Response_DeleteRange) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_DeleteRange) Size 

func (m *BatchCommandsResponse_Response_DeleteRange) Size() (n int)

type BatchCommandsResponse_Response_Empty 

type BatchCommandsResponse_Response_Empty struct {
	Empty *BatchCommandsEmptyResponse `protobuf:"bytes,255,opt,name=Empty,oneof"`
}

func (*BatchCommandsResponse_Response_Empty) MarshalTo 

func (m *BatchCommandsResponse_Response_Empty) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Empty) Size 

func (m *BatchCommandsResponse_Response_Empty) Size() (n int)

type BatchCommandsResponse_Response_GC 

type BatchCommandsResponse_Response_GC struct {
	GC *kvrpcpb.GCResponse `protobuf:"bytes,11,opt,name=GC,oneof"`
}

func (*BatchCommandsResponse_Response_GC) MarshalTo 

func (m *BatchCommandsResponse_Response_GC) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_GC) Size 

func (m *BatchCommandsResponse_Response_GC) Size() (n int)

type BatchCommandsResponse_Response_Get 

type BatchCommandsResponse_Response_Get struct {
	Get *kvrpcpb.GetResponse `protobuf:"bytes,1,opt,name=Get,oneof"`
}

func (*BatchCommandsResponse_Response_Get) MarshalTo 

func (m *BatchCommandsResponse_Response_Get) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Get) Size 

func (m *BatchCommandsResponse_Response_Get) Size() (n int)

type BatchCommandsResponse_Response_Import 

type BatchCommandsResponse_Response_Import struct {
	Import *kvrpcpb.ImportResponse `protobuf:"bytes,5,opt,name=Import,oneof"`
}

func (*BatchCommandsResponse_Response_Import) MarshalTo 

func (m *BatchCommandsResponse_Response_Import) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Import) Size 

func (m *BatchCommandsResponse_Response_Import) Size() (n int)

type BatchCommandsResponse_Response_PessimisticLock 

type BatchCommandsResponse_Response_PessimisticLock struct {
	PessimisticLock *kvrpcpb.PessimisticLockResponse `protobuf:"bytes,23,opt,name=PessimisticLock,oneof"`
}

func (*BatchCommandsResponse_Response_PessimisticLock) MarshalTo 

func (m *BatchCommandsResponse_Response_PessimisticLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_PessimisticLock) Size 

func (m *BatchCommandsResponse_Response_PessimisticLock) Size() (n int)

type BatchCommandsResponse_Response_PessimisticRollback 

type BatchCommandsResponse_Response_PessimisticRollback struct {
	PessimisticRollback *kvrpcpb.PessimisticRollbackResponse `protobuf:"bytes,24,opt,name=PessimisticRollback,oneof"`
}

func (*BatchCommandsResponse_Response_PessimisticRollback) MarshalTo 

func (m *BatchCommandsResponse_Response_PessimisticRollback) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_PessimisticRollback) Size 

func (m *BatchCommandsResponse_Response_PessimisticRollback) Size() (n int)

type BatchCommandsResponse_Response_Prewrite 

type BatchCommandsResponse_Response_Prewrite struct {
	Prewrite *kvrpcpb.PrewriteResponse `protobuf:"bytes,3,opt,name=Prewrite,oneof"`
}

func (*BatchCommandsResponse_Response_Prewrite) MarshalTo 

func (m *BatchCommandsResponse_Response_Prewrite) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Prewrite) Size 

func (m *BatchCommandsResponse_Response_Prewrite) Size() (n int)

type BatchCommandsResponse_Response_RawBatchDelete 

type BatchCommandsResponse_Response_RawBatchDelete struct {
	RawBatchDelete *kvrpcpb.RawBatchDeleteResponse `protobuf:"bytes,18,opt,name=RawBatchDelete,oneof"`
}

func (*BatchCommandsResponse_Response_RawBatchDelete) MarshalTo 

func (m *BatchCommandsResponse_Response_RawBatchDelete) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawBatchDelete) Size 

func (m *BatchCommandsResponse_Response_RawBatchDelete) Size() (n int)

type BatchCommandsResponse_Response_RawBatchGet 

type BatchCommandsResponse_Response_RawBatchGet struct {
	RawBatchGet *kvrpcpb.RawBatchGetResponse `protobuf:"bytes,14,opt,name=RawBatchGet,oneof"`
}

func (*BatchCommandsResponse_Response_RawBatchGet) MarshalTo 

func (m *BatchCommandsResponse_Response_RawBatchGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawBatchGet) Size 

func (m *BatchCommandsResponse_Response_RawBatchGet) Size() (n int)

type BatchCommandsResponse_Response_RawBatchPut 

type BatchCommandsResponse_Response_RawBatchPut struct {
	RawBatchPut *kvrpcpb.RawBatchPutResponse `protobuf:"bytes,16,opt,name=RawBatchPut,oneof"`
}

func (*BatchCommandsResponse_Response_RawBatchPut) MarshalTo 

func (m *BatchCommandsResponse_Response_RawBatchPut) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawBatchPut) Size 

func (m *BatchCommandsResponse_Response_RawBatchPut) Size() (n int)

type BatchCommandsResponse_Response_RawBatchScan 

type BatchCommandsResponse_Response_RawBatchScan struct {
	RawBatchScan *kvrpcpb.RawBatchScanResponse `protobuf:"bytes,21,opt,name=RawBatchScan,oneof"`
}

func (*BatchCommandsResponse_Response_RawBatchScan) MarshalTo 

func (m *BatchCommandsResponse_Response_RawBatchScan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawBatchScan) Size 

func (m *BatchCommandsResponse_Response_RawBatchScan) Size() (n int)

type BatchCommandsResponse_Response_RawDelete 

type BatchCommandsResponse_Response_RawDelete struct {
	RawDelete *kvrpcpb.RawDeleteResponse `protobuf:"bytes,17,opt,name=RawDelete,oneof"`
}

func (*BatchCommandsResponse_Response_RawDelete) MarshalTo 

func (m *BatchCommandsResponse_Response_RawDelete) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawDelete) Size 

func (m *BatchCommandsResponse_Response_RawDelete) Size() (n int)

type BatchCommandsResponse_Response_RawDeleteRange 

type BatchCommandsResponse_Response_RawDeleteRange struct {
	RawDeleteRange *kvrpcpb.RawDeleteRangeResponse `protobuf:"bytes,20,opt,name=RawDeleteRange,oneof"`
}

func (*BatchCommandsResponse_Response_RawDeleteRange) MarshalTo 

func (m *BatchCommandsResponse_Response_RawDeleteRange) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawDeleteRange) Size 

func (m *BatchCommandsResponse_Response_RawDeleteRange) Size() (n int)

type BatchCommandsResponse_Response_RawGet 

type BatchCommandsResponse_Response_RawGet struct {
	RawGet *kvrpcpb.RawGetResponse `protobuf:"bytes,13,opt,name=RawGet,oneof"`
}

func (*BatchCommandsResponse_Response_RawGet) MarshalTo 

func (m *BatchCommandsResponse_Response_RawGet) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawGet) Size 

func (m *BatchCommandsResponse_Response_RawGet) Size() (n int)

type BatchCommandsResponse_Response_RawPut 

type BatchCommandsResponse_Response_RawPut struct {
	RawPut *kvrpcpb.RawPutResponse `protobuf:"bytes,15,opt,name=RawPut,oneof"`
}

func (*BatchCommandsResponse_Response_RawPut) MarshalTo 

func (m *BatchCommandsResponse_Response_RawPut) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawPut) Size 

func (m *BatchCommandsResponse_Response_RawPut) Size() (n int)

type BatchCommandsResponse_Response_RawScan 

type BatchCommandsResponse_Response_RawScan struct {
	RawScan *kvrpcpb.RawScanResponse `protobuf:"bytes,19,opt,name=RawScan,oneof"`
}

func (*BatchCommandsResponse_Response_RawScan) MarshalTo 

func (m *BatchCommandsResponse_Response_RawScan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_RawScan) Size 

func (m *BatchCommandsResponse_Response_RawScan) Size() (n int)

type BatchCommandsResponse_Response_ResolveLock 

type BatchCommandsResponse_Response_ResolveLock struct {
	ResolveLock *kvrpcpb.ResolveLockResponse `protobuf:"bytes,10,opt,name=ResolveLock,oneof"`
}

func (*BatchCommandsResponse_Response_ResolveLock) MarshalTo 

func (m *BatchCommandsResponse_Response_ResolveLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_ResolveLock) Size 

func (m *BatchCommandsResponse_Response_ResolveLock) Size() (n int)

type BatchCommandsResponse_Response_Scan 

type BatchCommandsResponse_Response_Scan struct {
	Scan *kvrpcpb.ScanResponse `protobuf:"bytes,2,opt,name=Scan,oneof"`
}

func (*BatchCommandsResponse_Response_Scan) MarshalTo 

func (m *BatchCommandsResponse_Response_Scan) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_Scan) Size 

func (m *BatchCommandsResponse_Response_Scan) Size() (n int)

type BatchCommandsResponse_Response_ScanLock 

type BatchCommandsResponse_Response_ScanLock struct {
	ScanLock *kvrpcpb.ScanLockResponse `protobuf:"bytes,9,opt,name=ScanLock,oneof"`
}

func (*BatchCommandsResponse_Response_ScanLock) MarshalTo 

func (m *BatchCommandsResponse_Response_ScanLock) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_ScanLock) Size 

func (m *BatchCommandsResponse_Response_ScanLock) Size() (n int)

type BatchCommandsResponse_Response_TxnHeartBeat 

type BatchCommandsResponse_Response_TxnHeartBeat struct {
	TxnHeartBeat *kvrpcpb.TxnHeartBeatResponse `protobuf:"bytes,26,opt,name=TxnHeartBeat,oneof"`
}

func (*BatchCommandsResponse_Response_TxnHeartBeat) MarshalTo 

func (m *BatchCommandsResponse_Response_TxnHeartBeat) MarshalTo(dAtA []byte) (int, error)

func (*BatchCommandsResponse_Response_TxnHeartBeat) Size 

func (m *BatchCommandsResponse_Response_TxnHeartBeat) Size() (n int)

type BatchRaftMessage 

type BatchRaftMessage struct {
	Msgs                 []*raft_serverpb.RaftMessage `protobuf:"bytes,1,rep,name=msgs" json:"msgs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*BatchRaftMessage) Descriptor 

func (*BatchRaftMessage) Descriptor() ([]byte, []int)

func (*BatchRaftMessage) GetMsgs 

func (m *BatchRaftMessage) GetMsgs() []*raft_serverpb.RaftMessage

func (*BatchRaftMessage) Marshal 

func (m *BatchRaftMessage) Marshal() (dAtA []byte, err error)

func (*BatchRaftMessage) MarshalTo 

func (m *BatchRaftMessage) MarshalTo(dAtA []byte) (int, error)

func (*BatchRaftMessage) ProtoMessage 

func (*BatchRaftMessage) ProtoMessage()

func (*BatchRaftMessage) Reset 

func (m *BatchRaftMessage) Reset()

func (*BatchRaftMessage) Size 

func (m *BatchRaftMessage) Size() (n int)

func (*BatchRaftMessage) String 

func (m *BatchRaftMessage) String() string

func (*BatchRaftMessage) Unmarshal 

func (m *BatchRaftMessage) Unmarshal(dAtA []byte) error

func (*BatchRaftMessage) XXX_DiscardUnknown 

func (m *BatchRaftMessage) XXX_DiscardUnknown()

func (*BatchRaftMessage) XXX_Marshal 

func (m *BatchRaftMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchRaftMessage) XXX_Merge 

func (dst *BatchRaftMessage) XXX_Merge(src proto.Message)

func (*BatchRaftMessage) XXX_Size 

func (m *BatchRaftMessage) XXX_Size() int

func (*BatchRaftMessage) XXX_Unmarshal 

func (m *BatchRaftMessage) XXX_Unmarshal(b []byte) error

type TikvClient 

type TikvClient interface {
	// KV commands with mvcc/txn supported.
	KvGet(ctx context.Context, in *kvrpcpb.GetRequest, opts ...grpc.CallOption) (*kvrpcpb.GetResponse, error)
	KvScan(ctx context.Context, in *kvrpcpb.ScanRequest, opts ...grpc.CallOption) (*kvrpcpb.ScanResponse, error)
	KvPrewrite(ctx context.Context, in *kvrpcpb.PrewriteRequest, opts ...grpc.CallOption) (*kvrpcpb.PrewriteResponse, error)
	KvPessimisticLock(ctx context.Context, in *kvrpcpb.PessimisticLockRequest, opts ...grpc.CallOption) (*kvrpcpb.PessimisticLockResponse, error)
	KVPessimisticRollback(ctx context.Context, in *kvrpcpb.PessimisticRollbackRequest, opts ...grpc.CallOption) (*kvrpcpb.PessimisticRollbackResponse, error)
	KvTxnHeartBeat(ctx context.Context, in *kvrpcpb.TxnHeartBeatRequest, opts ...grpc.CallOption) (*kvrpcpb.TxnHeartBeatResponse, error)
	KvCheckTxnStatus(ctx context.Context, in *kvrpcpb.CheckTxnStatusRequest, opts ...grpc.CallOption) (*kvrpcpb.CheckTxnStatusResponse, error)
	KvCommit(ctx context.Context, in *kvrpcpb.CommitRequest, opts ...grpc.CallOption) (*kvrpcpb.CommitResponse, error)
	KvImport(ctx context.Context, in *kvrpcpb.ImportRequest, opts ...grpc.CallOption) (*kvrpcpb.ImportResponse, error)
	KvCleanup(ctx context.Context, in *kvrpcpb.CleanupRequest, opts ...grpc.CallOption) (*kvrpcpb.CleanupResponse, error)
	KvBatchGet(ctx context.Context, in *kvrpcpb.BatchGetRequest, opts ...grpc.CallOption) (*kvrpcpb.BatchGetResponse, error)
	KvBatchRollback(ctx context.Context, in *kvrpcpb.BatchRollbackRequest, opts ...grpc.CallOption) (*kvrpcpb.BatchRollbackResponse, error)
	KvScanLock(ctx context.Context, in *kvrpcpb.ScanLockRequest, opts ...grpc.CallOption) (*kvrpcpb.ScanLockResponse, error)
	KvResolveLock(ctx context.Context, in *kvrpcpb.ResolveLockRequest, opts ...grpc.CallOption) (*kvrpcpb.ResolveLockResponse, error)
	KvGC(ctx context.Context, in *kvrpcpb.GCRequest, opts ...grpc.CallOption) (*kvrpcpb.GCResponse, error)
	KvDeleteRange(ctx context.Context, in *kvrpcpb.DeleteRangeRequest, opts ...grpc.CallOption) (*kvrpcpb.DeleteRangeResponse, error)
	// RawKV commands.
	RawGet(ctx context.Context, in *kvrpcpb.RawGetRequest, opts ...grpc.CallOption) (*kvrpcpb.RawGetResponse, error)
	RawBatchGet(ctx context.Context, in *kvrpcpb.RawBatchGetRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchGetResponse, error)
	RawPut(ctx context.Context, in *kvrpcpb.RawPutRequest, opts ...grpc.CallOption) (*kvrpcpb.RawPutResponse, error)
	RawBatchPut(ctx context.Context, in *kvrpcpb.RawBatchPutRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchPutResponse, error)
	RawDelete(ctx context.Context, in *kvrpcpb.RawDeleteRequest, opts ...grpc.CallOption) (*kvrpcpb.RawDeleteResponse, error)
	RawBatchDelete(ctx context.Context, in *kvrpcpb.RawBatchDeleteRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchDeleteResponse, error)
	RawScan(ctx context.Context, in *kvrpcpb.RawScanRequest, opts ...grpc.CallOption) (*kvrpcpb.RawScanResponse, error)
	RawDeleteRange(ctx context.Context, in *kvrpcpb.RawDeleteRangeRequest, opts ...grpc.CallOption) (*kvrpcpb.RawDeleteRangeResponse, error)
	RawBatchScan(ctx context.Context, in *kvrpcpb.RawBatchScanRequest, opts ...grpc.CallOption) (*kvrpcpb.RawBatchScanResponse, error)
	// Store commands (to the whole tikv but not a certain region)
	UnsafeDestroyRange(ctx context.Context, in *kvrpcpb.UnsafeDestroyRangeRequest, opts ...grpc.CallOption) (*kvrpcpb.UnsafeDestroyRangeResponse, error)
	// SQL push down commands.
	Coprocessor(ctx context.Context, in *coprocessor.Request, opts ...grpc.CallOption) (*coprocessor.Response, error)
	CoprocessorStream(ctx context.Context, in *coprocessor.Request, opts ...grpc.CallOption) (Tikv_CoprocessorStreamClient, error)
	// Raft commands (tikv <-> tikv).
	Raft(ctx context.Context, opts ...grpc.CallOption) (Tikv_RaftClient, error)
	BatchRaft(ctx context.Context, opts ...grpc.CallOption) (Tikv_BatchRaftClient, error)
	Snapshot(ctx context.Context, opts ...grpc.CallOption) (Tikv_SnapshotClient, error)
	// Region commands.
	SplitRegion(ctx context.Context, in *kvrpcpb.SplitRegionRequest, opts ...grpc.CallOption) (*kvrpcpb.SplitRegionResponse, error)
	ReadIndex(ctx context.Context, in *kvrpcpb.ReadIndexRequest, opts ...grpc.CallOption) (*kvrpcpb.ReadIndexResponse, error)
	// transaction debugger commands.
	MvccGetByKey(ctx context.Context, in *kvrpcpb.MvccGetByKeyRequest, opts ...grpc.CallOption) (*kvrpcpb.MvccGetByKeyResponse, error)
	MvccGetByStartTs(ctx context.Context, in *kvrpcpb.MvccGetByStartTsRequest, opts ...grpc.CallOption) (*kvrpcpb.MvccGetByStartTsResponse, error)
	BatchCommands(ctx context.Context, opts ...grpc.CallOption) (Tikv_BatchCommandsClient, error)
}

func NewTikvClient 

func NewTikvClient(cc *grpc.ClientConn) TikvClient

type TikvServer 

type TikvServer interface {
	// KV commands with mvcc/txn supported.
	KvGet(context.Context, *kvrpcpb.GetRequest) (*kvrpcpb.GetResponse, error)
	KvScan(context.Context, *kvrpcpb.ScanRequest) (*kvrpcpb.ScanResponse, error)
	KvPrewrite(context.Context, *kvrpcpb.PrewriteRequest) (*kvrpcpb.PrewriteResponse, error)
	KvPessimisticLock(context.Context, *kvrpcpb.PessimisticLockRequest) (*kvrpcpb.PessimisticLockResponse, error)
	KVPessimisticRollback(context.Context, *kvrpcpb.PessimisticRollbackRequest) (*kvrpcpb.PessimisticRollbackResponse, error)
	KvTxnHeartBeat(context.Context, *kvrpcpb.TxnHeartBeatRequest) (*kvrpcpb.TxnHeartBeatResponse, error)
	KvCheckTxnStatus(context.Context, *kvrpcpb.CheckTxnStatusRequest) (*kvrpcpb.CheckTxnStatusResponse, error)
	KvCommit(context.Context, *kvrpcpb.CommitRequest) (*kvrpcpb.CommitResponse, error)
	KvImport(context.Context, *kvrpcpb.ImportRequest) (*kvrpcpb.ImportResponse, error)
	KvCleanup(context.Context, *kvrpcpb.CleanupRequest) (*kvrpcpb.CleanupResponse, error)
	KvBatchGet(context.Context, *kvrpcpb.BatchGetRequest) (*kvrpcpb.BatchGetResponse, error)
	KvBatchRollback(context.Context, *kvrpcpb.BatchRollbackRequest) (*kvrpcpb.BatchRollbackResponse, error)
	KvScanLock(context.Context, *kvrpcpb.ScanLockRequest) (*kvrpcpb.ScanLockResponse, error)
	KvResolveLock(context.Context, *kvrpcpb.ResolveLockRequest) (*kvrpcpb.ResolveLockResponse, error)
	KvGC(context.Context, *kvrpcpb.GCRequest) (*kvrpcpb.GCResponse, error)
	KvDeleteRange(context.Context, *kvrpcpb.DeleteRangeRequest) (*kvrpcpb.DeleteRangeResponse, error)
	// RawKV commands.
	RawGet(context.Context, *kvrpcpb.RawGetRequest) (*kvrpcpb.RawGetResponse, error)
	RawBatchGet(context.Context, *kvrpcpb.RawBatchGetRequest) (*kvrpcpb.RawBatchGetResponse, error)
	RawPut(context.Context, *kvrpcpb.RawPutRequest) (*kvrpcpb.RawPutResponse, error)
	RawBatchPut(context.Context, *kvrpcpb.RawBatchPutRequest) (*kvrpcpb.RawBatchPutResponse, error)
	RawDelete(context.Context, *kvrpcpb.RawDeleteRequest) (*kvrpcpb.RawDeleteResponse, error)
	RawBatchDelete(context.Context, *kvrpcpb.RawBatchDeleteRequest) (*kvrpcpb.RawBatchDeleteResponse, error)
	RawScan(context.Context, *kvrpcpb.RawScanRequest) (*kvrpcpb.RawScanResponse, error)
	RawDeleteRange(context.Context, *kvrpcpb.RawDeleteRangeRequest) (*kvrpcpb.RawDeleteRangeResponse, error)
	RawBatchScan(context.Context, *kvrpcpb.RawBatchScanRequest) (*kvrpcpb.RawBatchScanResponse, error)
	// Store commands (to the whole tikv but not a certain region)
	UnsafeDestroyRange(context.Context, *kvrpcpb.UnsafeDestroyRangeRequest) (*kvrpcpb.UnsafeDestroyRangeResponse, error)
	// SQL push down commands.
	Coprocessor(context.Context, *coprocessor.Request) (*coprocessor.Response, error)
	CoprocessorStream(*coprocessor.Request, Tikv_CoprocessorStreamServer) error
	// Raft commands (tikv <-> tikv).
	Raft(Tikv_RaftServer) error
	BatchRaft(Tikv_BatchRaftServer) error
	Snapshot(Tikv_SnapshotServer) error
	// Region commands.
	SplitRegion(context.Context, *kvrpcpb.SplitRegionRequest) (*kvrpcpb.SplitRegionResponse, error)
	ReadIndex(context.Context, *kvrpcpb.ReadIndexRequest) (*kvrpcpb.ReadIndexResponse, error)
	// transaction debugger commands.
	MvccGetByKey(context.Context, *kvrpcpb.MvccGetByKeyRequest) (*kvrpcpb.MvccGetByKeyResponse, error)
	MvccGetByStartTs(context.Context, *kvrpcpb.MvccGetByStartTsRequest) (*kvrpcpb.MvccGetByStartTsResponse, error)
	BatchCommands(Tikv_BatchCommandsServer) error
}

type Tikv_BatchCommandsClient 

type Tikv_BatchCommandsClient interface {
	Send(*BatchCommandsRequest) error
	Recv() (*BatchCommandsResponse, error)
	grpc.ClientStream
}

type Tikv_BatchCommandsServer 

type Tikv_BatchCommandsServer interface {
	Send(*BatchCommandsResponse) error
	Recv() (*BatchCommandsRequest, error)
	grpc.ServerStream
}

type Tikv_BatchRaftClient 

type Tikv_BatchRaftClient interface {
	Send(*BatchRaftMessage) error
	CloseAndRecv() (*raft_serverpb.Done, error)
	grpc.ClientStream
}

type Tikv_BatchRaftServer 

type Tikv_BatchRaftServer interface {
	SendAndClose(*raft_serverpb.Done) error
	Recv() (*BatchRaftMessage, error)
	grpc.ServerStream
}

type Tikv_CoprocessorStreamClient 

type Tikv_CoprocessorStreamClient interface {
	Recv() (*coprocessor.Response, error)
	grpc.ClientStream
}

type Tikv_CoprocessorStreamServer 

type Tikv_CoprocessorStreamServer interface {
	Send(*coprocessor.Response) error
	grpc.ServerStream
}

type Tikv_RaftClient 

type Tikv_RaftClient interface {
	Send(*raft_serverpb.RaftMessage) error
	CloseAndRecv() (*raft_serverpb.Done, error)
	grpc.ClientStream
}

type Tikv_RaftServer 

type Tikv_RaftServer interface {
	SendAndClose(*raft_serverpb.Done) error
	Recv() (*raft_serverpb.RaftMessage, error)
	grpc.ServerStream
}

type Tikv_SnapshotClient 

type Tikv_SnapshotClient interface {
	Send(*raft_serverpb.SnapshotChunk) error
	CloseAndRecv() (*raft_serverpb.Done, error)
	grpc.ClientStream
}

type Tikv_SnapshotServer 

type Tikv_SnapshotServer interface {
	SendAndClose(*raft_serverpb.Done) error
	Recv() (*raft_serverpb.SnapshotChunk, error)
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.