Documentation ¶
Overview ¶
Package kvrpcpb is a generated protocol buffer package.
It is generated from these files:
kvrpcpb.proto
It has these top-level messages:
LockInfo KeyError Context CmdGetRequest CmdGetResponse CmdScanRequest KvPair CmdScanResponse Mutation CmdPrewriteRequest CmdPrewriteResponse CmdCommitRequest CmdCommitResponse CmdBatchRollbackRequest CmdBatchRollbackResponse CmdCleanupRequest CmdCleanupResponse CmdBatchGetRequest CmdBatchGetResponse CmdScanLockRequest CmdScanLockResponse CmdResolveLockRequest CmdResolveLockResponse CmdGCRequest CmdGCResponse CmdRawGetRequest CmdRawGetResponse CmdRawPutRequest CmdRawPutResponse CmdRawDeleteRequest CmdRawDeleteResponse Request Response
Index ¶
- Variables
- type CmdBatchGetRequest
- func (*CmdBatchGetRequest) Descriptor() ([]byte, []int)
- func (m *CmdBatchGetRequest) GetKeys() [][]byte
- func (m *CmdBatchGetRequest) GetVersion() uint64
- func (m *CmdBatchGetRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdBatchGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdBatchGetRequest) ProtoMessage()
- func (m *CmdBatchGetRequest) Reset()
- func (m *CmdBatchGetRequest) Size() (n int)
- func (m *CmdBatchGetRequest) String() string
- func (m *CmdBatchGetRequest) Unmarshal(dAtA []byte) error
- type CmdBatchGetResponse
- func (*CmdBatchGetResponse) Descriptor() ([]byte, []int)
- func (m *CmdBatchGetResponse) GetPairs() []*KvPair
- func (m *CmdBatchGetResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdBatchGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdBatchGetResponse) ProtoMessage()
- func (m *CmdBatchGetResponse) Reset()
- func (m *CmdBatchGetResponse) Size() (n int)
- func (m *CmdBatchGetResponse) String() string
- func (m *CmdBatchGetResponse) Unmarshal(dAtA []byte) error
- type CmdBatchRollbackRequest
- func (*CmdBatchRollbackRequest) Descriptor() ([]byte, []int)
- func (m *CmdBatchRollbackRequest) GetKeys() [][]byte
- func (m *CmdBatchRollbackRequest) GetStartVersion() uint64
- func (m *CmdBatchRollbackRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdBatchRollbackRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdBatchRollbackRequest) ProtoMessage()
- func (m *CmdBatchRollbackRequest) Reset()
- func (m *CmdBatchRollbackRequest) Size() (n int)
- func (m *CmdBatchRollbackRequest) String() string
- func (m *CmdBatchRollbackRequest) Unmarshal(dAtA []byte) error
- type CmdBatchRollbackResponse
- func (*CmdBatchRollbackResponse) Descriptor() ([]byte, []int)
- func (m *CmdBatchRollbackResponse) GetError() *KeyError
- func (m *CmdBatchRollbackResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdBatchRollbackResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdBatchRollbackResponse) ProtoMessage()
- func (m *CmdBatchRollbackResponse) Reset()
- func (m *CmdBatchRollbackResponse) Size() (n int)
- func (m *CmdBatchRollbackResponse) String() string
- func (m *CmdBatchRollbackResponse) Unmarshal(dAtA []byte) error
- type CmdCleanupRequest
- func (*CmdCleanupRequest) Descriptor() ([]byte, []int)
- func (m *CmdCleanupRequest) GetKey() []byte
- func (m *CmdCleanupRequest) GetStartVersion() uint64
- func (m *CmdCleanupRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdCleanupRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdCleanupRequest) ProtoMessage()
- func (m *CmdCleanupRequest) Reset()
- func (m *CmdCleanupRequest) Size() (n int)
- func (m *CmdCleanupRequest) String() string
- func (m *CmdCleanupRequest) Unmarshal(dAtA []byte) error
- type CmdCleanupResponse
- func (*CmdCleanupResponse) Descriptor() ([]byte, []int)
- func (m *CmdCleanupResponse) GetCommitVersion() uint64
- func (m *CmdCleanupResponse) GetError() *KeyError
- func (m *CmdCleanupResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdCleanupResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdCleanupResponse) ProtoMessage()
- func (m *CmdCleanupResponse) Reset()
- func (m *CmdCleanupResponse) Size() (n int)
- func (m *CmdCleanupResponse) String() string
- func (m *CmdCleanupResponse) Unmarshal(dAtA []byte) error
- type CmdCommitRequest
- func (*CmdCommitRequest) Descriptor() ([]byte, []int)
- func (m *CmdCommitRequest) GetBinlog() []byte
- func (m *CmdCommitRequest) GetCommitVersion() uint64
- func (m *CmdCommitRequest) GetKeys() [][]byte
- func (m *CmdCommitRequest) GetStartVersion() uint64
- func (m *CmdCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdCommitRequest) ProtoMessage()
- func (m *CmdCommitRequest) Reset()
- func (m *CmdCommitRequest) Size() (n int)
- func (m *CmdCommitRequest) String() string
- func (m *CmdCommitRequest) Unmarshal(dAtA []byte) error
- type CmdCommitResponse
- func (*CmdCommitResponse) Descriptor() ([]byte, []int)
- func (m *CmdCommitResponse) GetError() *KeyError
- func (m *CmdCommitResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdCommitResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdCommitResponse) ProtoMessage()
- func (m *CmdCommitResponse) Reset()
- func (m *CmdCommitResponse) Size() (n int)
- func (m *CmdCommitResponse) String() string
- func (m *CmdCommitResponse) Unmarshal(dAtA []byte) error
- type CmdGCRequest
- func (*CmdGCRequest) Descriptor() ([]byte, []int)
- func (m *CmdGCRequest) GetSafePoint() uint64
- func (m *CmdGCRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdGCRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdGCRequest) ProtoMessage()
- func (m *CmdGCRequest) Reset()
- func (m *CmdGCRequest) Size() (n int)
- func (m *CmdGCRequest) String() string
- func (m *CmdGCRequest) Unmarshal(dAtA []byte) error
- type CmdGCResponse
- func (*CmdGCResponse) Descriptor() ([]byte, []int)
- func (m *CmdGCResponse) GetError() *KeyError
- func (m *CmdGCResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdGCResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdGCResponse) ProtoMessage()
- func (m *CmdGCResponse) Reset()
- func (m *CmdGCResponse) Size() (n int)
- func (m *CmdGCResponse) String() string
- func (m *CmdGCResponse) Unmarshal(dAtA []byte) error
- type CmdGetRequest
- func (*CmdGetRequest) Descriptor() ([]byte, []int)
- func (m *CmdGetRequest) GetKey() []byte
- func (m *CmdGetRequest) GetVersion() uint64
- func (m *CmdGetRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdGetRequest) ProtoMessage()
- func (m *CmdGetRequest) Reset()
- func (m *CmdGetRequest) Size() (n int)
- func (m *CmdGetRequest) String() string
- func (m *CmdGetRequest) Unmarshal(dAtA []byte) error
- type CmdGetResponse
- func (*CmdGetResponse) Descriptor() ([]byte, []int)
- func (m *CmdGetResponse) GetError() *KeyError
- func (m *CmdGetResponse) GetValue() []byte
- func (m *CmdGetResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdGetResponse) ProtoMessage()
- func (m *CmdGetResponse) Reset()
- func (m *CmdGetResponse) Size() (n int)
- func (m *CmdGetResponse) String() string
- func (m *CmdGetResponse) Unmarshal(dAtA []byte) error
- type CmdPrewriteRequest
- func (*CmdPrewriteRequest) Descriptor() ([]byte, []int)
- func (m *CmdPrewriteRequest) GetLockTtl() uint64
- func (m *CmdPrewriteRequest) GetMutations() []*Mutation
- func (m *CmdPrewriteRequest) GetPrimaryLock() []byte
- func (m *CmdPrewriteRequest) GetSkipConstraintCheck() bool
- func (m *CmdPrewriteRequest) GetStartVersion() uint64
- func (m *CmdPrewriteRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdPrewriteRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdPrewriteRequest) ProtoMessage()
- func (m *CmdPrewriteRequest) Reset()
- func (m *CmdPrewriteRequest) Size() (n int)
- func (m *CmdPrewriteRequest) String() string
- func (m *CmdPrewriteRequest) Unmarshal(dAtA []byte) error
- type CmdPrewriteResponse
- func (*CmdPrewriteResponse) Descriptor() ([]byte, []int)
- func (m *CmdPrewriteResponse) GetErrors() []*KeyError
- func (m *CmdPrewriteResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdPrewriteResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdPrewriteResponse) ProtoMessage()
- func (m *CmdPrewriteResponse) Reset()
- func (m *CmdPrewriteResponse) Size() (n int)
- func (m *CmdPrewriteResponse) String() string
- func (m *CmdPrewriteResponse) Unmarshal(dAtA []byte) error
- type CmdRawDeleteRequest
- func (*CmdRawDeleteRequest) Descriptor() ([]byte, []int)
- func (m *CmdRawDeleteRequest) GetKey() []byte
- func (m *CmdRawDeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdRawDeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawDeleteRequest) ProtoMessage()
- func (m *CmdRawDeleteRequest) Reset()
- func (m *CmdRawDeleteRequest) Size() (n int)
- func (m *CmdRawDeleteRequest) String() string
- func (m *CmdRawDeleteRequest) Unmarshal(dAtA []byte) error
- type CmdRawDeleteResponse
- func (*CmdRawDeleteResponse) Descriptor() ([]byte, []int)
- func (m *CmdRawDeleteResponse) GetError() string
- func (m *CmdRawDeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdRawDeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawDeleteResponse) ProtoMessage()
- func (m *CmdRawDeleteResponse) Reset()
- func (m *CmdRawDeleteResponse) Size() (n int)
- func (m *CmdRawDeleteResponse) String() string
- func (m *CmdRawDeleteResponse) Unmarshal(dAtA []byte) error
- type CmdRawGetRequest
- func (*CmdRawGetRequest) Descriptor() ([]byte, []int)
- func (m *CmdRawGetRequest) GetKey() []byte
- func (m *CmdRawGetRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdRawGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawGetRequest) ProtoMessage()
- func (m *CmdRawGetRequest) Reset()
- func (m *CmdRawGetRequest) Size() (n int)
- func (m *CmdRawGetRequest) String() string
- func (m *CmdRawGetRequest) Unmarshal(dAtA []byte) error
- type CmdRawGetResponse
- func (*CmdRawGetResponse) Descriptor() ([]byte, []int)
- func (m *CmdRawGetResponse) GetError() string
- func (m *CmdRawGetResponse) GetValue() []byte
- func (m *CmdRawGetResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdRawGetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawGetResponse) ProtoMessage()
- func (m *CmdRawGetResponse) Reset()
- func (m *CmdRawGetResponse) Size() (n int)
- func (m *CmdRawGetResponse) String() string
- func (m *CmdRawGetResponse) Unmarshal(dAtA []byte) error
- type CmdRawPutRequest
- func (*CmdRawPutRequest) Descriptor() ([]byte, []int)
- func (m *CmdRawPutRequest) GetKey() []byte
- func (m *CmdRawPutRequest) GetValue() []byte
- func (m *CmdRawPutRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdRawPutRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawPutRequest) ProtoMessage()
- func (m *CmdRawPutRequest) Reset()
- func (m *CmdRawPutRequest) Size() (n int)
- func (m *CmdRawPutRequest) String() string
- func (m *CmdRawPutRequest) Unmarshal(dAtA []byte) error
- type CmdRawPutResponse
- func (*CmdRawPutResponse) Descriptor() ([]byte, []int)
- func (m *CmdRawPutResponse) GetError() string
- func (m *CmdRawPutResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdRawPutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdRawPutResponse) ProtoMessage()
- func (m *CmdRawPutResponse) Reset()
- func (m *CmdRawPutResponse) Size() (n int)
- func (m *CmdRawPutResponse) String() string
- func (m *CmdRawPutResponse) Unmarshal(dAtA []byte) error
- type CmdResolveLockRequest
- func (*CmdResolveLockRequest) Descriptor() ([]byte, []int)
- func (m *CmdResolveLockRequest) GetCommitVersion() uint64
- func (m *CmdResolveLockRequest) GetStartVersion() uint64
- func (m *CmdResolveLockRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdResolveLockRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdResolveLockRequest) ProtoMessage()
- func (m *CmdResolveLockRequest) Reset()
- func (m *CmdResolveLockRequest) Size() (n int)
- func (m *CmdResolveLockRequest) String() string
- func (m *CmdResolveLockRequest) Unmarshal(dAtA []byte) error
- type CmdResolveLockResponse
- func (*CmdResolveLockResponse) Descriptor() ([]byte, []int)
- func (m *CmdResolveLockResponse) GetError() *KeyError
- func (m *CmdResolveLockResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdResolveLockResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdResolveLockResponse) ProtoMessage()
- func (m *CmdResolveLockResponse) Reset()
- func (m *CmdResolveLockResponse) Size() (n int)
- func (m *CmdResolveLockResponse) String() string
- func (m *CmdResolveLockResponse) Unmarshal(dAtA []byte) error
- type CmdScanLockRequest
- func (*CmdScanLockRequest) Descriptor() ([]byte, []int)
- func (m *CmdScanLockRequest) GetMaxVersion() uint64
- func (m *CmdScanLockRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdScanLockRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdScanLockRequest) ProtoMessage()
- func (m *CmdScanLockRequest) Reset()
- func (m *CmdScanLockRequest) Size() (n int)
- func (m *CmdScanLockRequest) String() string
- func (m *CmdScanLockRequest) Unmarshal(dAtA []byte) error
- type CmdScanLockResponse
- func (*CmdScanLockResponse) Descriptor() ([]byte, []int)
- func (m *CmdScanLockResponse) GetError() *KeyError
- func (m *CmdScanLockResponse) GetLocks() []*LockInfo
- func (m *CmdScanLockResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdScanLockResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdScanLockResponse) ProtoMessage()
- func (m *CmdScanLockResponse) Reset()
- func (m *CmdScanLockResponse) Size() (n int)
- func (m *CmdScanLockResponse) String() string
- func (m *CmdScanLockResponse) Unmarshal(dAtA []byte) error
- type CmdScanRequest
- func (*CmdScanRequest) Descriptor() ([]byte, []int)
- func (m *CmdScanRequest) GetKeyOnly() bool
- func (m *CmdScanRequest) GetLimit() uint32
- func (m *CmdScanRequest) GetStartKey() []byte
- func (m *CmdScanRequest) GetVersion() uint64
- func (m *CmdScanRequest) Marshal() (dAtA []byte, err error)
- func (m *CmdScanRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CmdScanRequest) ProtoMessage()
- func (m *CmdScanRequest) Reset()
- func (m *CmdScanRequest) Size() (n int)
- func (m *CmdScanRequest) String() string
- func (m *CmdScanRequest) Unmarshal(dAtA []byte) error
- type CmdScanResponse
- func (*CmdScanResponse) Descriptor() ([]byte, []int)
- func (m *CmdScanResponse) GetPairs() []*KvPair
- func (m *CmdScanResponse) Marshal() (dAtA []byte, err error)
- func (m *CmdScanResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CmdScanResponse) ProtoMessage()
- func (m *CmdScanResponse) Reset()
- func (m *CmdScanResponse) Size() (n int)
- func (m *CmdScanResponse) String() string
- func (m *CmdScanResponse) Unmarshal(dAtA []byte) error
- type Context
- func (*Context) Descriptor() ([]byte, []int)
- func (m *Context) GetPeer() *metapb.Peer
- func (m *Context) GetReadQuorum() bool
- func (m *Context) GetRegionEpoch() *metapb.RegionEpoch
- func (m *Context) GetRegionId() uint64
- func (m *Context) GetTerm() uint64
- func (m *Context) Marshal() (dAtA []byte, err error)
- func (m *Context) MarshalTo(dAtA []byte) (int, error)
- func (*Context) ProtoMessage()
- func (m *Context) Reset()
- func (m *Context) Size() (n int)
- func (m *Context) String() string
- func (m *Context) Unmarshal(dAtA []byte) error
- type KeyError
- func (*KeyError) Descriptor() ([]byte, []int)
- func (m *KeyError) GetAbort() string
- func (m *KeyError) GetLocked() *LockInfo
- func (m *KeyError) GetRetryable() string
- func (m *KeyError) Marshal() (dAtA []byte, err error)
- func (m *KeyError) MarshalTo(dAtA []byte) (int, error)
- func (*KeyError) ProtoMessage()
- func (m *KeyError) Reset()
- func (m *KeyError) Size() (n int)
- func (m *KeyError) String() string
- func (m *KeyError) Unmarshal(dAtA []byte) error
- type KvPair
- func (*KvPair) Descriptor() ([]byte, []int)
- func (m *KvPair) GetError() *KeyError
- func (m *KvPair) GetKey() []byte
- func (m *KvPair) GetValue() []byte
- func (m *KvPair) Marshal() (dAtA []byte, err error)
- func (m *KvPair) MarshalTo(dAtA []byte) (int, error)
- func (*KvPair) ProtoMessage()
- func (m *KvPair) Reset()
- func (m *KvPair) Size() (n int)
- func (m *KvPair) String() string
- func (m *KvPair) Unmarshal(dAtA []byte) error
- type LockInfo
- func (*LockInfo) Descriptor() ([]byte, []int)
- func (m *LockInfo) GetKey() []byte
- func (m *LockInfo) GetLockTtl() uint64
- func (m *LockInfo) GetLockVersion() uint64
- func (m *LockInfo) GetPrimaryLock() []byte
- func (m *LockInfo) Marshal() (dAtA []byte, err error)
- func (m *LockInfo) MarshalTo(dAtA []byte) (int, error)
- func (*LockInfo) ProtoMessage()
- func (m *LockInfo) Reset()
- func (m *LockInfo) Size() (n int)
- func (m *LockInfo) String() string
- func (m *LockInfo) Unmarshal(dAtA []byte) error
- type MessageType
- type Mutation
- func (*Mutation) Descriptor() ([]byte, []int)
- func (m *Mutation) GetKey() []byte
- func (m *Mutation) GetOp() Op
- func (m *Mutation) GetValue() []byte
- func (m *Mutation) Marshal() (dAtA []byte, err error)
- func (m *Mutation) MarshalTo(dAtA []byte) (int, error)
- func (*Mutation) ProtoMessage()
- func (m *Mutation) Reset()
- func (m *Mutation) Size() (n int)
- func (m *Mutation) String() string
- func (m *Mutation) Unmarshal(dAtA []byte) error
- type Op
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetCmdBatchGetReq() *CmdBatchGetRequest
- func (m *Request) GetCmdBatchRollbackReq() *CmdBatchRollbackRequest
- func (m *Request) GetCmdCleanupReq() *CmdCleanupRequest
- func (m *Request) GetCmdCommitReq() *CmdCommitRequest
- func (m *Request) GetCmdGcReq() *CmdGCRequest
- func (m *Request) GetCmdGetReq() *CmdGetRequest
- func (m *Request) GetCmdPrewriteReq() *CmdPrewriteRequest
- func (m *Request) GetCmdRawDeleteReq() *CmdRawDeleteRequest
- func (m *Request) GetCmdRawGetReq() *CmdRawGetRequest
- func (m *Request) GetCmdRawPutReq() *CmdRawPutRequest
- func (m *Request) GetCmdResolveLockReq() *CmdResolveLockRequest
- func (m *Request) GetCmdScanLockReq() *CmdScanLockRequest
- func (m *Request) GetCmdScanReq() *CmdScanRequest
- func (m *Request) GetContext() *Context
- func (m *Request) GetType() MessageType
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetCmdBatchGetResp() *CmdBatchGetResponse
- func (m *Response) GetCmdBatchRollbackResp() *CmdBatchRollbackResponse
- func (m *Response) GetCmdCleanupResp() *CmdCleanupResponse
- func (m *Response) GetCmdCommitResp() *CmdCommitResponse
- func (m *Response) GetCmdGcResp() *CmdGCResponse
- func (m *Response) GetCmdGetResp() *CmdGetResponse
- func (m *Response) GetCmdPrewriteResp() *CmdPrewriteResponse
- func (m *Response) GetCmdRawDeleteResp() *CmdRawDeleteResponse
- func (m *Response) GetCmdRawGetResp() *CmdRawGetResponse
- func (m *Response) GetCmdRawPutResp() *CmdRawPutResponse
- func (m *Response) GetCmdResolveLockResp() *CmdResolveLockResponse
- func (m *Response) GetCmdScanLockResp() *CmdScanLockResponse
- func (m *Response) GetCmdScanResp() *CmdScanResponse
- func (m *Response) GetRegionError() *errorpb.Error
- func (m *Response) GetType() MessageType
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthKvrpcpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowKvrpcpb = fmt.Errorf("proto: integer overflow") )
View Source
var MessageType_name = map[int32]string{
0: "CmdGet",
1: "CmdScan",
2: "CmdPrewrite",
3: "CmdCommit",
4: "CmdCleanup",
7: "CmdBatchGet",
8: "CmdBatchRollback",
9: "CmdScanLock",
10: "CmdResolveLock",
11: "CmdGC",
256: "CmdRawGet",
257: "CmdRawPut",
258: "CmdRawDelete",
}
View Source
var MessageType_value = map[string]int32{
"CmdGet": 0,
"CmdScan": 1,
"CmdPrewrite": 2,
"CmdCommit": 3,
"CmdCleanup": 4,
"CmdBatchGet": 7,
"CmdBatchRollback": 8,
"CmdScanLock": 9,
"CmdResolveLock": 10,
"CmdGC": 11,
"CmdRawGet": 256,
"CmdRawPut": 257,
"CmdRawDelete": 258,
}
View Source
var Op_name = map[int32]string{
0: "Put",
1: "Del",
2: "Lock",
}
View Source
var Op_value = map[string]int32{
"Put": 0,
"Del": 1,
"Lock": 2,
}
Functions ¶
This section is empty.
Types ¶
type CmdBatchGetRequest ¶
type CmdBatchGetRequest struct { Keys [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version" json:"version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdBatchGetRequest) Descriptor ¶
func (*CmdBatchGetRequest) Descriptor() ([]byte, []int)
func (*CmdBatchGetRequest) GetKeys ¶
func (m *CmdBatchGetRequest) GetKeys() [][]byte
func (*CmdBatchGetRequest) GetVersion ¶
func (m *CmdBatchGetRequest) GetVersion() uint64
func (*CmdBatchGetRequest) Marshal ¶
func (m *CmdBatchGetRequest) Marshal() (dAtA []byte, err error)
func (*CmdBatchGetRequest) MarshalTo ¶
func (m *CmdBatchGetRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdBatchGetRequest) ProtoMessage ¶
func (*CmdBatchGetRequest) ProtoMessage()
func (*CmdBatchGetRequest) Reset ¶
func (m *CmdBatchGetRequest) Reset()
func (*CmdBatchGetRequest) Size ¶
func (m *CmdBatchGetRequest) Size() (n int)
func (*CmdBatchGetRequest) String ¶
func (m *CmdBatchGetRequest) String() string
func (*CmdBatchGetRequest) Unmarshal ¶
func (m *CmdBatchGetRequest) Unmarshal(dAtA []byte) error
type CmdBatchGetResponse ¶
type CmdBatchGetResponse struct { Pairs []*KvPair `protobuf:"bytes,1,rep,name=pairs" json:"pairs,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdBatchGetResponse) Descriptor ¶
func (*CmdBatchGetResponse) Descriptor() ([]byte, []int)
func (*CmdBatchGetResponse) GetPairs ¶
func (m *CmdBatchGetResponse) GetPairs() []*KvPair
func (*CmdBatchGetResponse) Marshal ¶
func (m *CmdBatchGetResponse) Marshal() (dAtA []byte, err error)
func (*CmdBatchGetResponse) MarshalTo ¶
func (m *CmdBatchGetResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdBatchGetResponse) ProtoMessage ¶
func (*CmdBatchGetResponse) ProtoMessage()
func (*CmdBatchGetResponse) Reset ¶
func (m *CmdBatchGetResponse) Reset()
func (*CmdBatchGetResponse) Size ¶
func (m *CmdBatchGetResponse) Size() (n int)
func (*CmdBatchGetResponse) String ¶
func (m *CmdBatchGetResponse) String() string
func (*CmdBatchGetResponse) Unmarshal ¶
func (m *CmdBatchGetResponse) Unmarshal(dAtA []byte) error
type CmdBatchRollbackRequest ¶
type CmdBatchRollbackRequest struct { StartVersion uint64 `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"` Keys [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdBatchRollbackRequest) Descriptor ¶
func (*CmdBatchRollbackRequest) Descriptor() ([]byte, []int)
func (*CmdBatchRollbackRequest) GetKeys ¶
func (m *CmdBatchRollbackRequest) GetKeys() [][]byte
func (*CmdBatchRollbackRequest) GetStartVersion ¶
func (m *CmdBatchRollbackRequest) GetStartVersion() uint64
func (*CmdBatchRollbackRequest) Marshal ¶
func (m *CmdBatchRollbackRequest) Marshal() (dAtA []byte, err error)
func (*CmdBatchRollbackRequest) MarshalTo ¶
func (m *CmdBatchRollbackRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdBatchRollbackRequest) ProtoMessage ¶
func (*CmdBatchRollbackRequest) ProtoMessage()
func (*CmdBatchRollbackRequest) Reset ¶
func (m *CmdBatchRollbackRequest) Reset()
func (*CmdBatchRollbackRequest) Size ¶
func (m *CmdBatchRollbackRequest) Size() (n int)
func (*CmdBatchRollbackRequest) String ¶
func (m *CmdBatchRollbackRequest) String() string
func (*CmdBatchRollbackRequest) Unmarshal ¶
func (m *CmdBatchRollbackRequest) Unmarshal(dAtA []byte) error
type CmdBatchRollbackResponse ¶
type CmdBatchRollbackResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdBatchRollbackResponse) Descriptor ¶
func (*CmdBatchRollbackResponse) Descriptor() ([]byte, []int)
func (*CmdBatchRollbackResponse) GetError ¶
func (m *CmdBatchRollbackResponse) GetError() *KeyError
func (*CmdBatchRollbackResponse) Marshal ¶
func (m *CmdBatchRollbackResponse) Marshal() (dAtA []byte, err error)
func (*CmdBatchRollbackResponse) MarshalTo ¶
func (m *CmdBatchRollbackResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdBatchRollbackResponse) ProtoMessage ¶
func (*CmdBatchRollbackResponse) ProtoMessage()
func (*CmdBatchRollbackResponse) Reset ¶
func (m *CmdBatchRollbackResponse) Reset()
func (*CmdBatchRollbackResponse) Size ¶
func (m *CmdBatchRollbackResponse) Size() (n int)
func (*CmdBatchRollbackResponse) String ¶
func (m *CmdBatchRollbackResponse) String() string
func (*CmdBatchRollbackResponse) Unmarshal ¶
func (m *CmdBatchRollbackResponse) Unmarshal(dAtA []byte) error
type CmdCleanupRequest ¶
type CmdCleanupRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` StartVersion uint64 `protobuf:"varint,2,opt,name=start_version,json=startVersion" json:"start_version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdCleanupRequest) Descriptor ¶
func (*CmdCleanupRequest) Descriptor() ([]byte, []int)
func (*CmdCleanupRequest) GetKey ¶
func (m *CmdCleanupRequest) GetKey() []byte
func (*CmdCleanupRequest) GetStartVersion ¶
func (m *CmdCleanupRequest) GetStartVersion() uint64
func (*CmdCleanupRequest) Marshal ¶
func (m *CmdCleanupRequest) Marshal() (dAtA []byte, err error)
func (*CmdCleanupRequest) MarshalTo ¶
func (m *CmdCleanupRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdCleanupRequest) ProtoMessage ¶
func (*CmdCleanupRequest) ProtoMessage()
func (*CmdCleanupRequest) Reset ¶
func (m *CmdCleanupRequest) Reset()
func (*CmdCleanupRequest) Size ¶
func (m *CmdCleanupRequest) Size() (n int)
func (*CmdCleanupRequest) String ¶
func (m *CmdCleanupRequest) String() string
func (*CmdCleanupRequest) Unmarshal ¶
func (m *CmdCleanupRequest) Unmarshal(dAtA []byte) error
type CmdCleanupResponse ¶
type CmdCleanupResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` CommitVersion uint64 `protobuf:"varint,2,opt,name=commit_version,json=commitVersion" json:"commit_version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdCleanupResponse) Descriptor ¶
func (*CmdCleanupResponse) Descriptor() ([]byte, []int)
func (*CmdCleanupResponse) GetCommitVersion ¶
func (m *CmdCleanupResponse) GetCommitVersion() uint64
func (*CmdCleanupResponse) GetError ¶
func (m *CmdCleanupResponse) GetError() *KeyError
func (*CmdCleanupResponse) Marshal ¶
func (m *CmdCleanupResponse) Marshal() (dAtA []byte, err error)
func (*CmdCleanupResponse) MarshalTo ¶
func (m *CmdCleanupResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdCleanupResponse) ProtoMessage ¶
func (*CmdCleanupResponse) ProtoMessage()
func (*CmdCleanupResponse) Reset ¶
func (m *CmdCleanupResponse) Reset()
func (*CmdCleanupResponse) Size ¶
func (m *CmdCleanupResponse) Size() (n int)
func (*CmdCleanupResponse) String ¶
func (m *CmdCleanupResponse) String() string
func (*CmdCleanupResponse) Unmarshal ¶
func (m *CmdCleanupResponse) Unmarshal(dAtA []byte) error
type CmdCommitRequest ¶
type CmdCommitRequest struct { StartVersion uint64 `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"` Keys [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"` CommitVersion uint64 `protobuf:"varint,3,opt,name=commit_version,json=commitVersion" json:"commit_version"` Binlog []byte `protobuf:"bytes,4,opt,name=binlog" json:"binlog,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdCommitRequest) Descriptor ¶
func (*CmdCommitRequest) Descriptor() ([]byte, []int)
func (*CmdCommitRequest) GetBinlog ¶
func (m *CmdCommitRequest) GetBinlog() []byte
func (*CmdCommitRequest) GetCommitVersion ¶
func (m *CmdCommitRequest) GetCommitVersion() uint64
func (*CmdCommitRequest) GetKeys ¶
func (m *CmdCommitRequest) GetKeys() [][]byte
func (*CmdCommitRequest) GetStartVersion ¶
func (m *CmdCommitRequest) GetStartVersion() uint64
func (*CmdCommitRequest) Marshal ¶
func (m *CmdCommitRequest) Marshal() (dAtA []byte, err error)
func (*CmdCommitRequest) ProtoMessage ¶
func (*CmdCommitRequest) ProtoMessage()
func (*CmdCommitRequest) Reset ¶
func (m *CmdCommitRequest) Reset()
func (*CmdCommitRequest) Size ¶
func (m *CmdCommitRequest) Size() (n int)
func (*CmdCommitRequest) String ¶
func (m *CmdCommitRequest) String() string
func (*CmdCommitRequest) Unmarshal ¶
func (m *CmdCommitRequest) Unmarshal(dAtA []byte) error
type CmdCommitResponse ¶
type CmdCommitResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdCommitResponse) Descriptor ¶
func (*CmdCommitResponse) Descriptor() ([]byte, []int)
func (*CmdCommitResponse) GetError ¶
func (m *CmdCommitResponse) GetError() *KeyError
func (*CmdCommitResponse) Marshal ¶
func (m *CmdCommitResponse) Marshal() (dAtA []byte, err error)
func (*CmdCommitResponse) MarshalTo ¶
func (m *CmdCommitResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdCommitResponse) ProtoMessage ¶
func (*CmdCommitResponse) ProtoMessage()
func (*CmdCommitResponse) Reset ¶
func (m *CmdCommitResponse) Reset()
func (*CmdCommitResponse) Size ¶
func (m *CmdCommitResponse) Size() (n int)
func (*CmdCommitResponse) String ¶
func (m *CmdCommitResponse) String() string
func (*CmdCommitResponse) Unmarshal ¶
func (m *CmdCommitResponse) Unmarshal(dAtA []byte) error
type CmdGCRequest ¶
type CmdGCRequest struct { SafePoint uint64 `protobuf:"varint,1,opt,name=safe_point,json=safePoint" json:"safe_point"` XXX_unrecognized []byte `json:"-"` }
func (*CmdGCRequest) Descriptor ¶
func (*CmdGCRequest) Descriptor() ([]byte, []int)
func (*CmdGCRequest) GetSafePoint ¶
func (m *CmdGCRequest) GetSafePoint() uint64
func (*CmdGCRequest) Marshal ¶
func (m *CmdGCRequest) Marshal() (dAtA []byte, err error)
func (*CmdGCRequest) ProtoMessage ¶
func (*CmdGCRequest) ProtoMessage()
func (*CmdGCRequest) Reset ¶
func (m *CmdGCRequest) Reset()
func (*CmdGCRequest) Size ¶
func (m *CmdGCRequest) Size() (n int)
func (*CmdGCRequest) String ¶
func (m *CmdGCRequest) String() string
func (*CmdGCRequest) Unmarshal ¶
func (m *CmdGCRequest) Unmarshal(dAtA []byte) error
type CmdGCResponse ¶
type CmdGCResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdGCResponse) Descriptor ¶
func (*CmdGCResponse) Descriptor() ([]byte, []int)
func (*CmdGCResponse) GetError ¶
func (m *CmdGCResponse) GetError() *KeyError
func (*CmdGCResponse) Marshal ¶
func (m *CmdGCResponse) Marshal() (dAtA []byte, err error)
func (*CmdGCResponse) ProtoMessage ¶
func (*CmdGCResponse) ProtoMessage()
func (*CmdGCResponse) Reset ¶
func (m *CmdGCResponse) Reset()
func (*CmdGCResponse) Size ¶
func (m *CmdGCResponse) Size() (n int)
func (*CmdGCResponse) String ¶
func (m *CmdGCResponse) String() string
func (*CmdGCResponse) Unmarshal ¶
func (m *CmdGCResponse) Unmarshal(dAtA []byte) error
type CmdGetRequest ¶
type CmdGetRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version" json:"version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdGetRequest) Descriptor ¶
func (*CmdGetRequest) Descriptor() ([]byte, []int)
func (*CmdGetRequest) GetKey ¶
func (m *CmdGetRequest) GetKey() []byte
func (*CmdGetRequest) GetVersion ¶
func (m *CmdGetRequest) GetVersion() uint64
func (*CmdGetRequest) Marshal ¶
func (m *CmdGetRequest) Marshal() (dAtA []byte, err error)
func (*CmdGetRequest) ProtoMessage ¶
func (*CmdGetRequest) ProtoMessage()
func (*CmdGetRequest) Reset ¶
func (m *CmdGetRequest) Reset()
func (*CmdGetRequest) Size ¶
func (m *CmdGetRequest) Size() (n int)
func (*CmdGetRequest) String ¶
func (m *CmdGetRequest) String() string
func (*CmdGetRequest) Unmarshal ¶
func (m *CmdGetRequest) Unmarshal(dAtA []byte) error
type CmdGetResponse ¶
type CmdGetResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdGetResponse) Descriptor ¶
func (*CmdGetResponse) Descriptor() ([]byte, []int)
func (*CmdGetResponse) GetError ¶
func (m *CmdGetResponse) GetError() *KeyError
func (*CmdGetResponse) GetValue ¶
func (m *CmdGetResponse) GetValue() []byte
func (*CmdGetResponse) Marshal ¶
func (m *CmdGetResponse) Marshal() (dAtA []byte, err error)
func (*CmdGetResponse) ProtoMessage ¶
func (*CmdGetResponse) ProtoMessage()
func (*CmdGetResponse) Reset ¶
func (m *CmdGetResponse) Reset()
func (*CmdGetResponse) Size ¶
func (m *CmdGetResponse) Size() (n int)
func (*CmdGetResponse) String ¶
func (m *CmdGetResponse) String() string
func (*CmdGetResponse) Unmarshal ¶
func (m *CmdGetResponse) Unmarshal(dAtA []byte) error
type CmdPrewriteRequest ¶
type CmdPrewriteRequest struct { Mutations []*Mutation `protobuf:"bytes,1,rep,name=mutations" json:"mutations,omitempty"` // primary_lock_key PrimaryLock []byte `protobuf:"bytes,2,opt,name=primary_lock,json=primaryLock" json:"primary_lock,omitempty"` StartVersion uint64 `protobuf:"varint,3,opt,name=start_version,json=startVersion" json:"start_version"` LockTtl uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl" json:"lock_ttl"` SkipConstraintCheck bool `protobuf:"varint,5,opt,name=skip_constraint_check,json=skipConstraintCheck" json:"skip_constraint_check"` XXX_unrecognized []byte `json:"-"` }
func (*CmdPrewriteRequest) Descriptor ¶
func (*CmdPrewriteRequest) Descriptor() ([]byte, []int)
func (*CmdPrewriteRequest) GetLockTtl ¶
func (m *CmdPrewriteRequest) GetLockTtl() uint64
func (*CmdPrewriteRequest) GetMutations ¶
func (m *CmdPrewriteRequest) GetMutations() []*Mutation
func (*CmdPrewriteRequest) GetPrimaryLock ¶
func (m *CmdPrewriteRequest) GetPrimaryLock() []byte
func (*CmdPrewriteRequest) GetSkipConstraintCheck ¶
func (m *CmdPrewriteRequest) GetSkipConstraintCheck() bool
func (*CmdPrewriteRequest) GetStartVersion ¶
func (m *CmdPrewriteRequest) GetStartVersion() uint64
func (*CmdPrewriteRequest) Marshal ¶
func (m *CmdPrewriteRequest) Marshal() (dAtA []byte, err error)
func (*CmdPrewriteRequest) MarshalTo ¶
func (m *CmdPrewriteRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdPrewriteRequest) ProtoMessage ¶
func (*CmdPrewriteRequest) ProtoMessage()
func (*CmdPrewriteRequest) Reset ¶
func (m *CmdPrewriteRequest) Reset()
func (*CmdPrewriteRequest) Size ¶
func (m *CmdPrewriteRequest) Size() (n int)
func (*CmdPrewriteRequest) String ¶
func (m *CmdPrewriteRequest) String() string
func (*CmdPrewriteRequest) Unmarshal ¶
func (m *CmdPrewriteRequest) Unmarshal(dAtA []byte) error
type CmdPrewriteResponse ¶
type CmdPrewriteResponse struct { Errors []*KeyError `protobuf:"bytes,1,rep,name=errors" json:"errors,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdPrewriteResponse) Descriptor ¶
func (*CmdPrewriteResponse) Descriptor() ([]byte, []int)
func (*CmdPrewriteResponse) GetErrors ¶
func (m *CmdPrewriteResponse) GetErrors() []*KeyError
func (*CmdPrewriteResponse) Marshal ¶
func (m *CmdPrewriteResponse) Marshal() (dAtA []byte, err error)
func (*CmdPrewriteResponse) MarshalTo ¶
func (m *CmdPrewriteResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdPrewriteResponse) ProtoMessage ¶
func (*CmdPrewriteResponse) ProtoMessage()
func (*CmdPrewriteResponse) Reset ¶
func (m *CmdPrewriteResponse) Reset()
func (*CmdPrewriteResponse) Size ¶
func (m *CmdPrewriteResponse) Size() (n int)
func (*CmdPrewriteResponse) String ¶
func (m *CmdPrewriteResponse) String() string
func (*CmdPrewriteResponse) Unmarshal ¶
func (m *CmdPrewriteResponse) Unmarshal(dAtA []byte) error
type CmdRawDeleteRequest ¶
type CmdRawDeleteRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawDeleteRequest) Descriptor ¶
func (*CmdRawDeleteRequest) Descriptor() ([]byte, []int)
func (*CmdRawDeleteRequest) GetKey ¶
func (m *CmdRawDeleteRequest) GetKey() []byte
func (*CmdRawDeleteRequest) Marshal ¶
func (m *CmdRawDeleteRequest) Marshal() (dAtA []byte, err error)
func (*CmdRawDeleteRequest) MarshalTo ¶
func (m *CmdRawDeleteRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdRawDeleteRequest) ProtoMessage ¶
func (*CmdRawDeleteRequest) ProtoMessage()
func (*CmdRawDeleteRequest) Reset ¶
func (m *CmdRawDeleteRequest) Reset()
func (*CmdRawDeleteRequest) Size ¶
func (m *CmdRawDeleteRequest) Size() (n int)
func (*CmdRawDeleteRequest) String ¶
func (m *CmdRawDeleteRequest) String() string
func (*CmdRawDeleteRequest) Unmarshal ¶
func (m *CmdRawDeleteRequest) Unmarshal(dAtA []byte) error
type CmdRawDeleteResponse ¶
type CmdRawDeleteResponse struct { Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawDeleteResponse) Descriptor ¶
func (*CmdRawDeleteResponse) Descriptor() ([]byte, []int)
func (*CmdRawDeleteResponse) GetError ¶
func (m *CmdRawDeleteResponse) GetError() string
func (*CmdRawDeleteResponse) Marshal ¶
func (m *CmdRawDeleteResponse) Marshal() (dAtA []byte, err error)
func (*CmdRawDeleteResponse) MarshalTo ¶
func (m *CmdRawDeleteResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdRawDeleteResponse) ProtoMessage ¶
func (*CmdRawDeleteResponse) ProtoMessage()
func (*CmdRawDeleteResponse) Reset ¶
func (m *CmdRawDeleteResponse) Reset()
func (*CmdRawDeleteResponse) Size ¶
func (m *CmdRawDeleteResponse) Size() (n int)
func (*CmdRawDeleteResponse) String ¶
func (m *CmdRawDeleteResponse) String() string
func (*CmdRawDeleteResponse) Unmarshal ¶
func (m *CmdRawDeleteResponse) Unmarshal(dAtA []byte) error
type CmdRawGetRequest ¶
type CmdRawGetRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawGetRequest) Descriptor ¶
func (*CmdRawGetRequest) Descriptor() ([]byte, []int)
func (*CmdRawGetRequest) GetKey ¶
func (m *CmdRawGetRequest) GetKey() []byte
func (*CmdRawGetRequest) Marshal ¶
func (m *CmdRawGetRequest) Marshal() (dAtA []byte, err error)
func (*CmdRawGetRequest) ProtoMessage ¶
func (*CmdRawGetRequest) ProtoMessage()
func (*CmdRawGetRequest) Reset ¶
func (m *CmdRawGetRequest) Reset()
func (*CmdRawGetRequest) Size ¶
func (m *CmdRawGetRequest) Size() (n int)
func (*CmdRawGetRequest) String ¶
func (m *CmdRawGetRequest) String() string
func (*CmdRawGetRequest) Unmarshal ¶
func (m *CmdRawGetRequest) Unmarshal(dAtA []byte) error
type CmdRawGetResponse ¶
type CmdRawGetResponse struct { Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawGetResponse) Descriptor ¶
func (*CmdRawGetResponse) Descriptor() ([]byte, []int)
func (*CmdRawGetResponse) GetError ¶
func (m *CmdRawGetResponse) GetError() string
func (*CmdRawGetResponse) GetValue ¶
func (m *CmdRawGetResponse) GetValue() []byte
func (*CmdRawGetResponse) Marshal ¶
func (m *CmdRawGetResponse) Marshal() (dAtA []byte, err error)
func (*CmdRawGetResponse) MarshalTo ¶
func (m *CmdRawGetResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdRawGetResponse) ProtoMessage ¶
func (*CmdRawGetResponse) ProtoMessage()
func (*CmdRawGetResponse) Reset ¶
func (m *CmdRawGetResponse) Reset()
func (*CmdRawGetResponse) Size ¶
func (m *CmdRawGetResponse) Size() (n int)
func (*CmdRawGetResponse) String ¶
func (m *CmdRawGetResponse) String() string
func (*CmdRawGetResponse) Unmarshal ¶
func (m *CmdRawGetResponse) Unmarshal(dAtA []byte) error
type CmdRawPutRequest ¶
type CmdRawPutRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawPutRequest) Descriptor ¶
func (*CmdRawPutRequest) Descriptor() ([]byte, []int)
func (*CmdRawPutRequest) GetKey ¶
func (m *CmdRawPutRequest) GetKey() []byte
func (*CmdRawPutRequest) GetValue ¶
func (m *CmdRawPutRequest) GetValue() []byte
func (*CmdRawPutRequest) Marshal ¶
func (m *CmdRawPutRequest) Marshal() (dAtA []byte, err error)
func (*CmdRawPutRequest) ProtoMessage ¶
func (*CmdRawPutRequest) ProtoMessage()
func (*CmdRawPutRequest) Reset ¶
func (m *CmdRawPutRequest) Reset()
func (*CmdRawPutRequest) Size ¶
func (m *CmdRawPutRequest) Size() (n int)
func (*CmdRawPutRequest) String ¶
func (m *CmdRawPutRequest) String() string
func (*CmdRawPutRequest) Unmarshal ¶
func (m *CmdRawPutRequest) Unmarshal(dAtA []byte) error
type CmdRawPutResponse ¶
type CmdRawPutResponse struct { Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdRawPutResponse) Descriptor ¶
func (*CmdRawPutResponse) Descriptor() ([]byte, []int)
func (*CmdRawPutResponse) GetError ¶
func (m *CmdRawPutResponse) GetError() string
func (*CmdRawPutResponse) Marshal ¶
func (m *CmdRawPutResponse) Marshal() (dAtA []byte, err error)
func (*CmdRawPutResponse) MarshalTo ¶
func (m *CmdRawPutResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdRawPutResponse) ProtoMessage ¶
func (*CmdRawPutResponse) ProtoMessage()
func (*CmdRawPutResponse) Reset ¶
func (m *CmdRawPutResponse) Reset()
func (*CmdRawPutResponse) Size ¶
func (m *CmdRawPutResponse) Size() (n int)
func (*CmdRawPutResponse) String ¶
func (m *CmdRawPutResponse) String() string
func (*CmdRawPutResponse) Unmarshal ¶
func (m *CmdRawPutResponse) Unmarshal(dAtA []byte) error
type CmdResolveLockRequest ¶
type CmdResolveLockRequest struct { StartVersion uint64 `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"` // If the txn is rolled back, do not set it. CommitVersion uint64 `protobuf:"varint,2,opt,name=commit_version,json=commitVersion" json:"commit_version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdResolveLockRequest) Descriptor ¶
func (*CmdResolveLockRequest) Descriptor() ([]byte, []int)
func (*CmdResolveLockRequest) GetCommitVersion ¶
func (m *CmdResolveLockRequest) GetCommitVersion() uint64
func (*CmdResolveLockRequest) GetStartVersion ¶
func (m *CmdResolveLockRequest) GetStartVersion() uint64
func (*CmdResolveLockRequest) Marshal ¶
func (m *CmdResolveLockRequest) Marshal() (dAtA []byte, err error)
func (*CmdResolveLockRequest) MarshalTo ¶
func (m *CmdResolveLockRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdResolveLockRequest) ProtoMessage ¶
func (*CmdResolveLockRequest) ProtoMessage()
func (*CmdResolveLockRequest) Reset ¶
func (m *CmdResolveLockRequest) Reset()
func (*CmdResolveLockRequest) Size ¶
func (m *CmdResolveLockRequest) Size() (n int)
func (*CmdResolveLockRequest) String ¶
func (m *CmdResolveLockRequest) String() string
func (*CmdResolveLockRequest) Unmarshal ¶
func (m *CmdResolveLockRequest) Unmarshal(dAtA []byte) error
type CmdResolveLockResponse ¶
type CmdResolveLockResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdResolveLockResponse) Descriptor ¶
func (*CmdResolveLockResponse) Descriptor() ([]byte, []int)
func (*CmdResolveLockResponse) GetError ¶
func (m *CmdResolveLockResponse) GetError() *KeyError
func (*CmdResolveLockResponse) Marshal ¶
func (m *CmdResolveLockResponse) Marshal() (dAtA []byte, err error)
func (*CmdResolveLockResponse) MarshalTo ¶
func (m *CmdResolveLockResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdResolveLockResponse) ProtoMessage ¶
func (*CmdResolveLockResponse) ProtoMessage()
func (*CmdResolveLockResponse) Reset ¶
func (m *CmdResolveLockResponse) Reset()
func (*CmdResolveLockResponse) Size ¶
func (m *CmdResolveLockResponse) Size() (n int)
func (*CmdResolveLockResponse) String ¶
func (m *CmdResolveLockResponse) String() string
func (*CmdResolveLockResponse) Unmarshal ¶
func (m *CmdResolveLockResponse) Unmarshal(dAtA []byte) error
type CmdScanLockRequest ¶
type CmdScanLockRequest struct { MaxVersion uint64 `protobuf:"varint,1,opt,name=max_version,json=maxVersion" json:"max_version"` XXX_unrecognized []byte `json:"-"` }
func (*CmdScanLockRequest) Descriptor ¶
func (*CmdScanLockRequest) Descriptor() ([]byte, []int)
func (*CmdScanLockRequest) GetMaxVersion ¶
func (m *CmdScanLockRequest) GetMaxVersion() uint64
func (*CmdScanLockRequest) Marshal ¶
func (m *CmdScanLockRequest) Marshal() (dAtA []byte, err error)
func (*CmdScanLockRequest) MarshalTo ¶
func (m *CmdScanLockRequest) MarshalTo(dAtA []byte) (int, error)
func (*CmdScanLockRequest) ProtoMessage ¶
func (*CmdScanLockRequest) ProtoMessage()
func (*CmdScanLockRequest) Reset ¶
func (m *CmdScanLockRequest) Reset()
func (*CmdScanLockRequest) Size ¶
func (m *CmdScanLockRequest) Size() (n int)
func (*CmdScanLockRequest) String ¶
func (m *CmdScanLockRequest) String() string
func (*CmdScanLockRequest) Unmarshal ¶
func (m *CmdScanLockRequest) Unmarshal(dAtA []byte) error
type CmdScanLockResponse ¶
type CmdScanLockResponse struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Locks []*LockInfo `protobuf:"bytes,2,rep,name=locks" json:"locks,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdScanLockResponse) Descriptor ¶
func (*CmdScanLockResponse) Descriptor() ([]byte, []int)
func (*CmdScanLockResponse) GetError ¶
func (m *CmdScanLockResponse) GetError() *KeyError
func (*CmdScanLockResponse) GetLocks ¶
func (m *CmdScanLockResponse) GetLocks() []*LockInfo
func (*CmdScanLockResponse) Marshal ¶
func (m *CmdScanLockResponse) Marshal() (dAtA []byte, err error)
func (*CmdScanLockResponse) MarshalTo ¶
func (m *CmdScanLockResponse) MarshalTo(dAtA []byte) (int, error)
func (*CmdScanLockResponse) ProtoMessage ¶
func (*CmdScanLockResponse) ProtoMessage()
func (*CmdScanLockResponse) Reset ¶
func (m *CmdScanLockResponse) Reset()
func (*CmdScanLockResponse) Size ¶
func (m *CmdScanLockResponse) Size() (n int)
func (*CmdScanLockResponse) String ¶
func (m *CmdScanLockResponse) String() string
func (*CmdScanLockResponse) Unmarshal ¶
func (m *CmdScanLockResponse) Unmarshal(dAtA []byte) error
type CmdScanRequest ¶
type CmdScanRequest struct { StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey" json:"start_key,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit" json:"limit"` Version uint64 `protobuf:"varint,3,opt,name=version" json:"version"` KeyOnly bool `protobuf:"varint,4,opt,name=key_only,json=keyOnly" json:"key_only"` XXX_unrecognized []byte `json:"-"` }
func (*CmdScanRequest) Descriptor ¶
func (*CmdScanRequest) Descriptor() ([]byte, []int)
func (*CmdScanRequest) GetKeyOnly ¶
func (m *CmdScanRequest) GetKeyOnly() bool
func (*CmdScanRequest) GetLimit ¶
func (m *CmdScanRequest) GetLimit() uint32
func (*CmdScanRequest) GetStartKey ¶
func (m *CmdScanRequest) GetStartKey() []byte
func (*CmdScanRequest) GetVersion ¶
func (m *CmdScanRequest) GetVersion() uint64
func (*CmdScanRequest) Marshal ¶
func (m *CmdScanRequest) Marshal() (dAtA []byte, err error)
func (*CmdScanRequest) ProtoMessage ¶
func (*CmdScanRequest) ProtoMessage()
func (*CmdScanRequest) Reset ¶
func (m *CmdScanRequest) Reset()
func (*CmdScanRequest) Size ¶
func (m *CmdScanRequest) Size() (n int)
func (*CmdScanRequest) String ¶
func (m *CmdScanRequest) String() string
func (*CmdScanRequest) Unmarshal ¶
func (m *CmdScanRequest) Unmarshal(dAtA []byte) error
type CmdScanResponse ¶
type CmdScanResponse struct { Pairs []*KvPair `protobuf:"bytes,1,rep,name=pairs" json:"pairs,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CmdScanResponse) Descriptor ¶
func (*CmdScanResponse) Descriptor() ([]byte, []int)
func (*CmdScanResponse) GetPairs ¶
func (m *CmdScanResponse) GetPairs() []*KvPair
func (*CmdScanResponse) Marshal ¶
func (m *CmdScanResponse) Marshal() (dAtA []byte, err error)
func (*CmdScanResponse) ProtoMessage ¶
func (*CmdScanResponse) ProtoMessage()
func (*CmdScanResponse) Reset ¶
func (m *CmdScanResponse) Reset()
func (*CmdScanResponse) Size ¶
func (m *CmdScanResponse) Size() (n int)
func (*CmdScanResponse) String ¶
func (m *CmdScanResponse) String() string
func (*CmdScanResponse) Unmarshal ¶
func (m *CmdScanResponse) Unmarshal(dAtA []byte) error
type Context ¶
type Context struct { RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId" json:"region_id"` RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"` Peer *metapb.Peer `protobuf:"bytes,3,opt,name=peer" json:"peer,omitempty"` ReadQuorum bool `protobuf:"varint,4,opt,name=read_quorum,json=readQuorum" json:"read_quorum"` Term uint64 `protobuf:"varint,5,opt,name=term" json:"term"` XXX_unrecognized []byte `json:"-"` }
func (*Context) Descriptor ¶
func (*Context) GetReadQuorum ¶
func (*Context) GetRegionEpoch ¶
func (m *Context) GetRegionEpoch() *metapb.RegionEpoch
func (*Context) GetRegionId ¶
func (*Context) ProtoMessage ¶
func (*Context) ProtoMessage()
type KeyError ¶
type KeyError struct { Locked *LockInfo `protobuf:"bytes,1,opt,name=locked" json:"locked,omitempty"` Retryable string `protobuf:"bytes,2,opt,name=retryable" json:"retryable"` Abort string `protobuf:"bytes,3,opt,name=abort" json:"abort"` XXX_unrecognized []byte `json:"-"` }
func (*KeyError) Descriptor ¶
func (*KeyError) GetRetryable ¶
func (*KeyError) ProtoMessage ¶
func (*KeyError) ProtoMessage()
type KvPair ¶
type KvPair struct { Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*KvPair) Descriptor ¶
func (*KvPair) ProtoMessage ¶
func (*KvPair) ProtoMessage()
type LockInfo ¶
type LockInfo struct { PrimaryLock []byte `protobuf:"bytes,1,opt,name=primary_lock,json=primaryLock" json:"primary_lock,omitempty"` LockVersion uint64 `protobuf:"varint,2,opt,name=lock_version,json=lockVersion" json:"lock_version"` Key []byte `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"` LockTtl uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl" json:"lock_ttl"` XXX_unrecognized []byte `json:"-"` }
func (*LockInfo) Descriptor ¶
func (*LockInfo) GetLockTtl ¶
func (*LockInfo) GetLockVersion ¶
func (*LockInfo) GetPrimaryLock ¶
func (*LockInfo) ProtoMessage ¶
func (*LockInfo) ProtoMessage()
type MessageType ¶
type MessageType int32
const ( MessageType_CmdGet MessageType = 0 MessageType_CmdScan MessageType = 1 MessageType_CmdPrewrite MessageType = 2 MessageType_CmdCommit MessageType = 3 MessageType_CmdCleanup MessageType = 4 MessageType_CmdBatchGet MessageType = 7 MessageType_CmdBatchRollback MessageType = 8 MessageType_CmdScanLock MessageType = 9 MessageType_CmdResolveLock MessageType = 10 MessageType_CmdGC MessageType = 11 // These 3 raw APIs are for raw kv operations which do not contain // transactions or MVCC. They should not be mixed with other commands in the // same cluster. MessageType_CmdRawGet MessageType = 256 MessageType_CmdRawPut MessageType = 257 MessageType_CmdRawDelete MessageType = 258 )
func (MessageType) Enum ¶
func (x MessageType) Enum() *MessageType
func (MessageType) EnumDescriptor ¶
func (MessageType) EnumDescriptor() ([]byte, []int)
func (MessageType) String ¶
func (x MessageType) String() string
func (*MessageType) UnmarshalJSON ¶
func (x *MessageType) UnmarshalJSON(data []byte) error
type Mutation ¶
type Mutation struct { Op Op `protobuf:"varint,1,opt,name=op,enum=kvrpcpb.Op" json:"op"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Mutation) Descriptor ¶
func (*Mutation) ProtoMessage ¶
func (*Mutation) ProtoMessage()
type Request ¶
type Request struct { Type MessageType `protobuf:"varint,1,opt,name=type,enum=kvrpcpb.MessageType" json:"type"` Context *Context `protobuf:"bytes,2,opt,name=context" json:"context,omitempty"` CmdGetReq *CmdGetRequest `protobuf:"bytes,3,opt,name=cmd_get_req,json=cmdGetReq" json:"cmd_get_req,omitempty"` CmdScanReq *CmdScanRequest `protobuf:"bytes,4,opt,name=cmd_scan_req,json=cmdScanReq" json:"cmd_scan_req,omitempty"` CmdPrewriteReq *CmdPrewriteRequest `protobuf:"bytes,5,opt,name=cmd_prewrite_req,json=cmdPrewriteReq" json:"cmd_prewrite_req,omitempty"` CmdCommitReq *CmdCommitRequest `protobuf:"bytes,6,opt,name=cmd_commit_req,json=cmdCommitReq" json:"cmd_commit_req,omitempty"` CmdCleanupReq *CmdCleanupRequest `protobuf:"bytes,7,opt,name=cmd_cleanup_req,json=cmdCleanupReq" json:"cmd_cleanup_req,omitempty"` CmdBatchGetReq *CmdBatchGetRequest `protobuf:"bytes,10,opt,name=cmd_batch_get_req,json=cmdBatchGetReq" json:"cmd_batch_get_req,omitempty"` CmdBatchRollbackReq *CmdBatchRollbackRequest `protobuf:"bytes,11,opt,name=cmd_batch_rollback_req,json=cmdBatchRollbackReq" json:"cmd_batch_rollback_req,omitempty"` CmdScanLockReq *CmdScanLockRequest `protobuf:"bytes,12,opt,name=cmd_scan_lock_req,json=cmdScanLockReq" json:"cmd_scan_lock_req,omitempty"` CmdResolveLockReq *CmdResolveLockRequest `protobuf:"bytes,13,opt,name=cmd_resolve_lock_req,json=cmdResolveLockReq" json:"cmd_resolve_lock_req,omitempty"` CmdGcReq *CmdGCRequest `protobuf:"bytes,14,opt,name=cmd_gc_req,json=cmdGcReq" json:"cmd_gc_req,omitempty"` CmdRawGetReq *CmdRawGetRequest `protobuf:"bytes,256,opt,name=cmd_raw_get_req,json=cmdRawGetReq" json:"cmd_raw_get_req,omitempty"` CmdRawPutReq *CmdRawPutRequest `protobuf:"bytes,257,opt,name=cmd_raw_put_req,json=cmdRawPutReq" json:"cmd_raw_put_req,omitempty"` CmdRawDeleteReq *CmdRawDeleteRequest `protobuf:"bytes,258,opt,name=cmd_raw_delete_req,json=cmdRawDeleteReq" json:"cmd_raw_delete_req,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetCmdBatchGetReq ¶
func (m *Request) GetCmdBatchGetReq() *CmdBatchGetRequest
func (*Request) GetCmdBatchRollbackReq ¶
func (m *Request) GetCmdBatchRollbackReq() *CmdBatchRollbackRequest
func (*Request) GetCmdCleanupReq ¶
func (m *Request) GetCmdCleanupReq() *CmdCleanupRequest
func (*Request) GetCmdCommitReq ¶
func (m *Request) GetCmdCommitReq() *CmdCommitRequest
func (*Request) GetCmdGcReq ¶
func (m *Request) GetCmdGcReq() *CmdGCRequest
func (*Request) GetCmdGetReq ¶
func (m *Request) GetCmdGetReq() *CmdGetRequest
func (*Request) GetCmdPrewriteReq ¶
func (m *Request) GetCmdPrewriteReq() *CmdPrewriteRequest
func (*Request) GetCmdRawDeleteReq ¶
func (m *Request) GetCmdRawDeleteReq() *CmdRawDeleteRequest
func (*Request) GetCmdRawGetReq ¶
func (m *Request) GetCmdRawGetReq() *CmdRawGetRequest
func (*Request) GetCmdRawPutReq ¶
func (m *Request) GetCmdRawPutReq() *CmdRawPutRequest
func (*Request) GetCmdResolveLockReq ¶
func (m *Request) GetCmdResolveLockReq() *CmdResolveLockRequest
func (*Request) GetCmdScanLockReq ¶
func (m *Request) GetCmdScanLockReq() *CmdScanLockRequest
func (*Request) GetCmdScanReq ¶
func (m *Request) GetCmdScanReq() *CmdScanRequest
func (*Request) GetContext ¶
func (*Request) GetType ¶
func (m *Request) GetType() MessageType
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type Response ¶
type Response struct { Type MessageType `protobuf:"varint,1,opt,name=type,enum=kvrpcpb.MessageType" json:"type"` RegionError *errorpb.Error `protobuf:"bytes,2,opt,name=region_error,json=regionError" json:"region_error,omitempty"` CmdGetResp *CmdGetResponse `protobuf:"bytes,3,opt,name=cmd_get_resp,json=cmdGetResp" json:"cmd_get_resp,omitempty"` CmdScanResp *CmdScanResponse `protobuf:"bytes,4,opt,name=cmd_scan_resp,json=cmdScanResp" json:"cmd_scan_resp,omitempty"` CmdPrewriteResp *CmdPrewriteResponse `protobuf:"bytes,5,opt,name=cmd_prewrite_resp,json=cmdPrewriteResp" json:"cmd_prewrite_resp,omitempty"` CmdCommitResp *CmdCommitResponse `protobuf:"bytes,6,opt,name=cmd_commit_resp,json=cmdCommitResp" json:"cmd_commit_resp,omitempty"` CmdCleanupResp *CmdCleanupResponse `protobuf:"bytes,7,opt,name=cmd_cleanup_resp,json=cmdCleanupResp" json:"cmd_cleanup_resp,omitempty"` CmdBatchGetResp *CmdBatchGetResponse `protobuf:"bytes,10,opt,name=cmd_batch_get_resp,json=cmdBatchGetResp" json:"cmd_batch_get_resp,omitempty"` CmdBatchRollbackResp *CmdBatchRollbackResponse `protobuf:"bytes,11,opt,name=cmd_batch_rollback_resp,json=cmdBatchRollbackResp" json:"cmd_batch_rollback_resp,omitempty"` CmdScanLockResp *CmdScanLockResponse `protobuf:"bytes,12,opt,name=cmd_scan_lock_resp,json=cmdScanLockResp" json:"cmd_scan_lock_resp,omitempty"` CmdResolveLockResp *CmdResolveLockResponse `protobuf:"bytes,13,opt,name=cmd_resolve_lock_resp,json=cmdResolveLockResp" json:"cmd_resolve_lock_resp,omitempty"` CmdGcResp *CmdGCResponse `protobuf:"bytes,14,opt,name=cmd_gc_resp,json=cmdGcResp" json:"cmd_gc_resp,omitempty"` CmdRawGetResp *CmdRawGetResponse `protobuf:"bytes,256,opt,name=cmd_raw_get_resp,json=cmdRawGetResp" json:"cmd_raw_get_resp,omitempty"` CmdRawPutResp *CmdRawPutResponse `protobuf:"bytes,257,opt,name=cmd_raw_put_resp,json=cmdRawPutResp" json:"cmd_raw_put_resp,omitempty"` CmdRawDeleteResp *CmdRawDeleteResponse `protobuf:"bytes,258,opt,name=cmd_raw_delete_resp,json=cmdRawDeleteResp" json:"cmd_raw_delete_resp,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Response) Descriptor ¶
func (*Response) GetCmdBatchGetResp ¶
func (m *Response) GetCmdBatchGetResp() *CmdBatchGetResponse
func (*Response) GetCmdBatchRollbackResp ¶
func (m *Response) GetCmdBatchRollbackResp() *CmdBatchRollbackResponse
func (*Response) GetCmdCleanupResp ¶
func (m *Response) GetCmdCleanupResp() *CmdCleanupResponse
func (*Response) GetCmdCommitResp ¶
func (m *Response) GetCmdCommitResp() *CmdCommitResponse
func (*Response) GetCmdGcResp ¶
func (m *Response) GetCmdGcResp() *CmdGCResponse
func (*Response) GetCmdGetResp ¶
func (m *Response) GetCmdGetResp() *CmdGetResponse
func (*Response) GetCmdPrewriteResp ¶
func (m *Response) GetCmdPrewriteResp() *CmdPrewriteResponse
func (*Response) GetCmdRawDeleteResp ¶
func (m *Response) GetCmdRawDeleteResp() *CmdRawDeleteResponse
func (*Response) GetCmdRawGetResp ¶
func (m *Response) GetCmdRawGetResp() *CmdRawGetResponse
func (*Response) GetCmdRawPutResp ¶
func (m *Response) GetCmdRawPutResp() *CmdRawPutResponse
func (*Response) GetCmdResolveLockResp ¶
func (m *Response) GetCmdResolveLockResp() *CmdResolveLockResponse
func (*Response) GetCmdScanLockResp ¶
func (m *Response) GetCmdScanLockResp() *CmdScanLockResponse
func (*Response) GetCmdScanResp ¶
func (m *Response) GetCmdScanResp() *CmdScanResponse
func (*Response) GetRegionError ¶
func (*Response) GetType ¶
func (m *Response) GetType() MessageType
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.