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 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) 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 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) 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) 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) 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",
}
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,
}
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"` 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) 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 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"` 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 )
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"` 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) 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"` 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) 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.