Versions in this module Expand all Collapse all v1 v1.1.0-alpha Oct 31, 2017 v1.0.9 Apr 20, 2018 v1.0.8 Feb 11, 2018 v1.0.7 Jan 19, 2018 v1.0.6 Jan 8, 2018 v1.0.5 Dec 26, 2017 v1.0.4 Dec 11, 2017 v1.0.3 Nov 25, 2017 v1.0.2 Nov 13, 2017 v1.0.1 Oct 31, 2017 v1.0.0 Oct 16, 2017 Changes in this version + var CommandPri_name = map[int32]string + var CommandPri_value = map[string]int32 + var ErrIntOverflowKvrpcpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthKvrpcpb = fmt.Errorf("proto: negative length found during unmarshaling") + var IsolationLevel_name = map[int32]string + var IsolationLevel_value = map[string]int32 + var Op_name = map[int32]string + var Op_value = map[string]int32 + type BatchGetRequest struct + Context *Context + Keys [][]byte + Version uint64 + func (*BatchGetRequest) Descriptor() ([]byte, []int) + func (*BatchGetRequest) ProtoMessage() + func (m *BatchGetRequest) GetContext() *Context + func (m *BatchGetRequest) GetKeys() [][]byte + func (m *BatchGetRequest) GetVersion() uint64 + func (m *BatchGetRequest) Marshal() (dAtA []byte, err error) + func (m *BatchGetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchGetRequest) Reset() + func (m *BatchGetRequest) Size() (n int) + func (m *BatchGetRequest) String() string + func (m *BatchGetRequest) Unmarshal(dAtA []byte) error + type BatchGetResponse struct + Pairs []*KvPair + RegionError *errorpb.Error + func (*BatchGetResponse) Descriptor() ([]byte, []int) + func (*BatchGetResponse) ProtoMessage() + func (m *BatchGetResponse) GetPairs() []*KvPair + func (m *BatchGetResponse) GetRegionError() *errorpb.Error + func (m *BatchGetResponse) Marshal() (dAtA []byte, err error) + func (m *BatchGetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchGetResponse) Reset() + func (m *BatchGetResponse) Size() (n int) + func (m *BatchGetResponse) String() string + func (m *BatchGetResponse) Unmarshal(dAtA []byte) error + type BatchRollbackRequest struct + Context *Context + Keys [][]byte + StartVersion uint64 + func (*BatchRollbackRequest) Descriptor() ([]byte, []int) + func (*BatchRollbackRequest) ProtoMessage() + func (m *BatchRollbackRequest) GetContext() *Context + func (m *BatchRollbackRequest) GetKeys() [][]byte + func (m *BatchRollbackRequest) GetStartVersion() uint64 + func (m *BatchRollbackRequest) Marshal() (dAtA []byte, err error) + func (m *BatchRollbackRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchRollbackRequest) Reset() + func (m *BatchRollbackRequest) Size() (n int) + func (m *BatchRollbackRequest) String() string + func (m *BatchRollbackRequest) Unmarshal(dAtA []byte) error + type BatchRollbackResponse struct + Error *KeyError + RegionError *errorpb.Error + func (*BatchRollbackResponse) Descriptor() ([]byte, []int) + func (*BatchRollbackResponse) ProtoMessage() + func (m *BatchRollbackResponse) GetError() *KeyError + func (m *BatchRollbackResponse) GetRegionError() *errorpb.Error + func (m *BatchRollbackResponse) Marshal() (dAtA []byte, err error) + func (m *BatchRollbackResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchRollbackResponse) Reset() + func (m *BatchRollbackResponse) Size() (n int) + func (m *BatchRollbackResponse) String() string + func (m *BatchRollbackResponse) Unmarshal(dAtA []byte) error + type CleanupRequest struct + Context *Context + Key []byte + StartVersion uint64 + func (*CleanupRequest) Descriptor() ([]byte, []int) + func (*CleanupRequest) ProtoMessage() + func (m *CleanupRequest) GetContext() *Context + func (m *CleanupRequest) GetKey() []byte + func (m *CleanupRequest) GetStartVersion() uint64 + func (m *CleanupRequest) Marshal() (dAtA []byte, err error) + func (m *CleanupRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CleanupRequest) Reset() + func (m *CleanupRequest) Size() (n int) + func (m *CleanupRequest) String() string + func (m *CleanupRequest) Unmarshal(dAtA []byte) error + type CleanupResponse struct + CommitVersion uint64 + Error *KeyError + RegionError *errorpb.Error + func (*CleanupResponse) Descriptor() ([]byte, []int) + func (*CleanupResponse) ProtoMessage() + func (m *CleanupResponse) GetCommitVersion() uint64 + func (m *CleanupResponse) GetError() *KeyError + func (m *CleanupResponse) GetRegionError() *errorpb.Error + func (m *CleanupResponse) Marshal() (dAtA []byte, err error) + func (m *CleanupResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CleanupResponse) Reset() + func (m *CleanupResponse) Size() (n int) + func (m *CleanupResponse) String() string + func (m *CleanupResponse) Unmarshal(dAtA []byte) error + type CommandPri int32 + const CommandPri_High + const CommandPri_Low + const CommandPri_Normal + func (CommandPri) EnumDescriptor() ([]byte, []int) + func (x CommandPri) String() string + type CommitRequest struct + CommitVersion uint64 + Context *Context + Keys [][]byte + StartVersion uint64 + func (*CommitRequest) Descriptor() ([]byte, []int) + func (*CommitRequest) ProtoMessage() + func (m *CommitRequest) GetCommitVersion() uint64 + func (m *CommitRequest) GetContext() *Context + func (m *CommitRequest) GetKeys() [][]byte + func (m *CommitRequest) GetStartVersion() uint64 + func (m *CommitRequest) Marshal() (dAtA []byte, err error) + func (m *CommitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CommitRequest) Reset() + func (m *CommitRequest) Size() (n int) + func (m *CommitRequest) String() string + func (m *CommitRequest) Unmarshal(dAtA []byte) error + type CommitResponse struct + Error *KeyError + RegionError *errorpb.Error + func (*CommitResponse) Descriptor() ([]byte, []int) + func (*CommitResponse) ProtoMessage() + func (m *CommitResponse) GetError() *KeyError + func (m *CommitResponse) GetRegionError() *errorpb.Error + func (m *CommitResponse) Marshal() (dAtA []byte, err error) + func (m *CommitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommitResponse) Reset() + func (m *CommitResponse) Size() (n int) + func (m *CommitResponse) String() string + func (m *CommitResponse) Unmarshal(dAtA []byte) error + type Context struct + IsolationLevel IsolationLevel + NotFillCache bool + Peer *metapb.Peer + Priority CommandPri + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + SyncLog bool + Term uint64 + func (*Context) Descriptor() ([]byte, []int) + func (*Context) ProtoMessage() + func (m *Context) GetIsolationLevel() IsolationLevel + func (m *Context) GetNotFillCache() bool + func (m *Context) GetPeer() *metapb.Peer + func (m *Context) GetPriority() CommandPri + func (m *Context) GetRegionEpoch() *metapb.RegionEpoch + func (m *Context) GetRegionId() uint64 + func (m *Context) GetSyncLog() bool + func (m *Context) GetTerm() uint64 + func (m *Context) Marshal() (dAtA []byte, err error) + func (m *Context) MarshalTo(dAtA []byte) (int, error) + func (m *Context) Reset() + func (m *Context) Size() (n int) + func (m *Context) String() string + func (m *Context) Unmarshal(dAtA []byte) error + type DeleteRangeRequest struct + Context *Context + EndKey []byte + StartKey []byte + func (*DeleteRangeRequest) Descriptor() ([]byte, []int) + func (*DeleteRangeRequest) ProtoMessage() + func (m *DeleteRangeRequest) GetContext() *Context + func (m *DeleteRangeRequest) GetEndKey() []byte + func (m *DeleteRangeRequest) GetStartKey() []byte + func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeRequest) Reset() + func (m *DeleteRangeRequest) Size() (n int) + func (m *DeleteRangeRequest) String() string + func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error + type DeleteRangeResponse struct + Error string + RegionError *errorpb.Error + func (*DeleteRangeResponse) Descriptor() ([]byte, []int) + func (*DeleteRangeResponse) ProtoMessage() + func (m *DeleteRangeResponse) GetError() string + func (m *DeleteRangeResponse) GetRegionError() *errorpb.Error + func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeResponse) Reset() + func (m *DeleteRangeResponse) Size() (n int) + func (m *DeleteRangeResponse) String() string + func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error + type GCRequest struct + Context *Context + SafePoint uint64 + func (*GCRequest) Descriptor() ([]byte, []int) + func (*GCRequest) ProtoMessage() + func (m *GCRequest) GetContext() *Context + func (m *GCRequest) GetSafePoint() uint64 + func (m *GCRequest) Marshal() (dAtA []byte, err error) + func (m *GCRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GCRequest) Reset() + func (m *GCRequest) Size() (n int) + func (m *GCRequest) String() string + func (m *GCRequest) Unmarshal(dAtA []byte) error + type GCResponse struct + Error *KeyError + RegionError *errorpb.Error + func (*GCResponse) Descriptor() ([]byte, []int) + func (*GCResponse) ProtoMessage() + func (m *GCResponse) GetError() *KeyError + func (m *GCResponse) GetRegionError() *errorpb.Error + func (m *GCResponse) Marshal() (dAtA []byte, err error) + func (m *GCResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GCResponse) Reset() + func (m *GCResponse) Size() (n int) + func (m *GCResponse) String() string + func (m *GCResponse) Unmarshal(dAtA []byte) error + type GetRequest struct + Context *Context + Key []byte + Version uint64 + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetContext() *Context + func (m *GetRequest) GetKey() []byte + func (m *GetRequest) GetVersion() uint64 + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + type GetResponse struct + Error *KeyError + RegionError *errorpb.Error + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetError() *KeyError + func (m *GetResponse) GetRegionError() *errorpb.Error + func (m *GetResponse) GetValue() []byte + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + type ImportRequest struct + CommitVersion uint64 + Mutations []*Mutation + func (*ImportRequest) Descriptor() ([]byte, []int) + func (*ImportRequest) ProtoMessage() + func (m *ImportRequest) GetCommitVersion() uint64 + func (m *ImportRequest) GetMutations() []*Mutation + func (m *ImportRequest) Marshal() (dAtA []byte, err error) + func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRequest) Reset() + func (m *ImportRequest) Size() (n int) + func (m *ImportRequest) String() string + func (m *ImportRequest) Unmarshal(dAtA []byte) error + type ImportResponse struct + Error string + RegionError *errorpb.Error + func (*ImportResponse) Descriptor() ([]byte, []int) + func (*ImportResponse) ProtoMessage() + func (m *ImportResponse) GetError() string + func (m *ImportResponse) GetRegionError() *errorpb.Error + func (m *ImportResponse) Marshal() (dAtA []byte, err error) + func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ImportResponse) Reset() + func (m *ImportResponse) Size() (n int) + func (m *ImportResponse) String() string + func (m *ImportResponse) Unmarshal(dAtA []byte) error + type IsolationLevel int32 + const IsolationLevel_RC + const IsolationLevel_SI + func (IsolationLevel) EnumDescriptor() ([]byte, []int) + func (x IsolationLevel) String() string + type KeyError struct + Abort string + Locked *LockInfo + Retryable string + func (*KeyError) Descriptor() ([]byte, []int) + func (*KeyError) ProtoMessage() + 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 (m *KeyError) Reset() + func (m *KeyError) Size() (n int) + func (m *KeyError) String() string + func (m *KeyError) Unmarshal(dAtA []byte) error + type KvPair struct + Error *KeyError + Key []byte + Value []byte + func (*KvPair) Descriptor() ([]byte, []int) + func (*KvPair) ProtoMessage() + 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 (m *KvPair) Reset() + func (m *KvPair) Size() (n int) + func (m *KvPair) String() string + func (m *KvPair) Unmarshal(dAtA []byte) error + type LockInfo struct + Key []byte + LockTtl uint64 + LockVersion uint64 + PrimaryLock []byte + func (*LockInfo) Descriptor() ([]byte, []int) + func (*LockInfo) ProtoMessage() + 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 (m *LockInfo) Reset() + func (m *LockInfo) Size() (n int) + func (m *LockInfo) String() string + func (m *LockInfo) Unmarshal(dAtA []byte) error + type Mutation struct + Key []byte + Op Op + Value []byte + func (*Mutation) Descriptor() ([]byte, []int) + func (*Mutation) ProtoMessage() + 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 (m *Mutation) Reset() + func (m *Mutation) Size() (n int) + func (m *Mutation) String() string + func (m *Mutation) Unmarshal(dAtA []byte) error + type MvccGetByKeyRequest struct + Context *Context + Key []byte + func (*MvccGetByKeyRequest) Descriptor() ([]byte, []int) + func (*MvccGetByKeyRequest) ProtoMessage() + func (m *MvccGetByKeyRequest) GetContext() *Context + func (m *MvccGetByKeyRequest) GetKey() []byte + func (m *MvccGetByKeyRequest) Marshal() (dAtA []byte, err error) + func (m *MvccGetByKeyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MvccGetByKeyRequest) Reset() + func (m *MvccGetByKeyRequest) Size() (n int) + func (m *MvccGetByKeyRequest) String() string + func (m *MvccGetByKeyRequest) Unmarshal(dAtA []byte) error + type MvccGetByKeyResponse struct + Error string + Info *MvccInfo + RegionError *errorpb.Error + func (*MvccGetByKeyResponse) Descriptor() ([]byte, []int) + func (*MvccGetByKeyResponse) ProtoMessage() + func (m *MvccGetByKeyResponse) GetError() string + func (m *MvccGetByKeyResponse) GetInfo() *MvccInfo + func (m *MvccGetByKeyResponse) GetRegionError() *errorpb.Error + func (m *MvccGetByKeyResponse) Marshal() (dAtA []byte, err error) + func (m *MvccGetByKeyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MvccGetByKeyResponse) Reset() + func (m *MvccGetByKeyResponse) Size() (n int) + func (m *MvccGetByKeyResponse) String() string + func (m *MvccGetByKeyResponse) Unmarshal(dAtA []byte) error + type MvccGetByStartTsRequest struct + Context *Context + StartTs uint64 + func (*MvccGetByStartTsRequest) Descriptor() ([]byte, []int) + func (*MvccGetByStartTsRequest) ProtoMessage() + func (m *MvccGetByStartTsRequest) GetContext() *Context + func (m *MvccGetByStartTsRequest) GetStartTs() uint64 + func (m *MvccGetByStartTsRequest) Marshal() (dAtA []byte, err error) + func (m *MvccGetByStartTsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MvccGetByStartTsRequest) Reset() + func (m *MvccGetByStartTsRequest) Size() (n int) + func (m *MvccGetByStartTsRequest) String() string + func (m *MvccGetByStartTsRequest) Unmarshal(dAtA []byte) error + type MvccGetByStartTsResponse struct + Error string + Info *MvccInfo + Key []byte + RegionError *errorpb.Error + func (*MvccGetByStartTsResponse) Descriptor() ([]byte, []int) + func (*MvccGetByStartTsResponse) ProtoMessage() + func (m *MvccGetByStartTsResponse) GetError() string + func (m *MvccGetByStartTsResponse) GetInfo() *MvccInfo + func (m *MvccGetByStartTsResponse) GetKey() []byte + func (m *MvccGetByStartTsResponse) GetRegionError() *errorpb.Error + func (m *MvccGetByStartTsResponse) Marshal() (dAtA []byte, err error) + func (m *MvccGetByStartTsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MvccGetByStartTsResponse) Reset() + func (m *MvccGetByStartTsResponse) Size() (n int) + func (m *MvccGetByStartTsResponse) String() string + func (m *MvccGetByStartTsResponse) Unmarshal(dAtA []byte) error + type MvccInfo struct + Lock *LockInfo + Values []*ValueInfo + Writes []*WriteInfo + func (*MvccInfo) Descriptor() ([]byte, []int) + func (*MvccInfo) ProtoMessage() + func (m *MvccInfo) GetLock() *LockInfo + func (m *MvccInfo) GetValues() []*ValueInfo + func (m *MvccInfo) GetWrites() []*WriteInfo + func (m *MvccInfo) Marshal() (dAtA []byte, err error) + func (m *MvccInfo) MarshalTo(dAtA []byte) (int, error) + func (m *MvccInfo) Reset() + func (m *MvccInfo) Size() (n int) + func (m *MvccInfo) String() string + func (m *MvccInfo) Unmarshal(dAtA []byte) error + type Op int32 + const Op_Del + const Op_Lock + const Op_Put + const Op_Rollback + func (Op) EnumDescriptor() ([]byte, []int) + func (x Op) String() string + type PrewriteRequest struct + Context *Context + LockTtl uint64 + Mutations []*Mutation + PrimaryLock []byte + SkipConstraintCheck bool + StartVersion uint64 + func (*PrewriteRequest) Descriptor() ([]byte, []int) + func (*PrewriteRequest) ProtoMessage() + func (m *PrewriteRequest) GetContext() *Context + func (m *PrewriteRequest) GetLockTtl() uint64 + func (m *PrewriteRequest) GetMutations() []*Mutation + func (m *PrewriteRequest) GetPrimaryLock() []byte + func (m *PrewriteRequest) GetSkipConstraintCheck() bool + func (m *PrewriteRequest) GetStartVersion() uint64 + func (m *PrewriteRequest) Marshal() (dAtA []byte, err error) + func (m *PrewriteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PrewriteRequest) Reset() + func (m *PrewriteRequest) Size() (n int) + func (m *PrewriteRequest) String() string + func (m *PrewriteRequest) Unmarshal(dAtA []byte) error + type PrewriteResponse struct + Errors []*KeyError + RegionError *errorpb.Error + func (*PrewriteResponse) Descriptor() ([]byte, []int) + func (*PrewriteResponse) ProtoMessage() + func (m *PrewriteResponse) GetErrors() []*KeyError + func (m *PrewriteResponse) GetRegionError() *errorpb.Error + func (m *PrewriteResponse) Marshal() (dAtA []byte, err error) + func (m *PrewriteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PrewriteResponse) Reset() + func (m *PrewriteResponse) Size() (n int) + func (m *PrewriteResponse) String() string + func (m *PrewriteResponse) Unmarshal(dAtA []byte) error + type RawDeleteRequest struct + Context *Context + Key []byte + func (*RawDeleteRequest) Descriptor() ([]byte, []int) + func (*RawDeleteRequest) ProtoMessage() + func (m *RawDeleteRequest) GetContext() *Context + func (m *RawDeleteRequest) GetKey() []byte + func (m *RawDeleteRequest) Marshal() (dAtA []byte, err error) + func (m *RawDeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RawDeleteRequest) Reset() + func (m *RawDeleteRequest) Size() (n int) + func (m *RawDeleteRequest) String() string + func (m *RawDeleteRequest) Unmarshal(dAtA []byte) error + type RawDeleteResponse struct + Error string + RegionError *errorpb.Error + func (*RawDeleteResponse) Descriptor() ([]byte, []int) + func (*RawDeleteResponse) ProtoMessage() + func (m *RawDeleteResponse) GetError() string + func (m *RawDeleteResponse) GetRegionError() *errorpb.Error + func (m *RawDeleteResponse) Marshal() (dAtA []byte, err error) + func (m *RawDeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RawDeleteResponse) Reset() + func (m *RawDeleteResponse) Size() (n int) + func (m *RawDeleteResponse) String() string + func (m *RawDeleteResponse) Unmarshal(dAtA []byte) error + type RawGetRequest struct + Context *Context + Key []byte + func (*RawGetRequest) Descriptor() ([]byte, []int) + func (*RawGetRequest) ProtoMessage() + func (m *RawGetRequest) GetContext() *Context + func (m *RawGetRequest) GetKey() []byte + func (m *RawGetRequest) Marshal() (dAtA []byte, err error) + func (m *RawGetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RawGetRequest) Reset() + func (m *RawGetRequest) Size() (n int) + func (m *RawGetRequest) String() string + func (m *RawGetRequest) Unmarshal(dAtA []byte) error + type RawGetResponse struct + Error string + RegionError *errorpb.Error + Value []byte + func (*RawGetResponse) Descriptor() ([]byte, []int) + func (*RawGetResponse) ProtoMessage() + func (m *RawGetResponse) GetError() string + func (m *RawGetResponse) GetRegionError() *errorpb.Error + func (m *RawGetResponse) GetValue() []byte + func (m *RawGetResponse) Marshal() (dAtA []byte, err error) + func (m *RawGetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RawGetResponse) Reset() + func (m *RawGetResponse) Size() (n int) + func (m *RawGetResponse) String() string + func (m *RawGetResponse) Unmarshal(dAtA []byte) error + type RawPutRequest struct + Context *Context + Key []byte + Value []byte + func (*RawPutRequest) Descriptor() ([]byte, []int) + func (*RawPutRequest) ProtoMessage() + func (m *RawPutRequest) GetContext() *Context + func (m *RawPutRequest) GetKey() []byte + func (m *RawPutRequest) GetValue() []byte + func (m *RawPutRequest) Marshal() (dAtA []byte, err error) + func (m *RawPutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RawPutRequest) Reset() + func (m *RawPutRequest) Size() (n int) + func (m *RawPutRequest) String() string + func (m *RawPutRequest) Unmarshal(dAtA []byte) error + type RawPutResponse struct + Error string + RegionError *errorpb.Error + func (*RawPutResponse) Descriptor() ([]byte, []int) + func (*RawPutResponse) ProtoMessage() + func (m *RawPutResponse) GetError() string + func (m *RawPutResponse) GetRegionError() *errorpb.Error + func (m *RawPutResponse) Marshal() (dAtA []byte, err error) + func (m *RawPutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RawPutResponse) Reset() + func (m *RawPutResponse) Size() (n int) + func (m *RawPutResponse) String() string + func (m *RawPutResponse) Unmarshal(dAtA []byte) error + type RawScanRequest struct + Context *Context + Limit uint32 + StartKey []byte + func (*RawScanRequest) Descriptor() ([]byte, []int) + func (*RawScanRequest) ProtoMessage() + func (m *RawScanRequest) GetContext() *Context + func (m *RawScanRequest) GetLimit() uint32 + func (m *RawScanRequest) GetStartKey() []byte + func (m *RawScanRequest) Marshal() (dAtA []byte, err error) + func (m *RawScanRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RawScanRequest) Reset() + func (m *RawScanRequest) Size() (n int) + func (m *RawScanRequest) String() string + func (m *RawScanRequest) Unmarshal(dAtA []byte) error + type RawScanResponse struct + Kvs []*KvPair + RegionError *errorpb.Error + func (*RawScanResponse) Descriptor() ([]byte, []int) + func (*RawScanResponse) ProtoMessage() + func (m *RawScanResponse) GetKvs() []*KvPair + func (m *RawScanResponse) GetRegionError() *errorpb.Error + func (m *RawScanResponse) Marshal() (dAtA []byte, err error) + func (m *RawScanResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RawScanResponse) Reset() + func (m *RawScanResponse) Size() (n int) + func (m *RawScanResponse) String() string + func (m *RawScanResponse) Unmarshal(dAtA []byte) error + type ResolveLockRequest struct + CommitVersion uint64 + Context *Context + StartVersion uint64 + func (*ResolveLockRequest) Descriptor() ([]byte, []int) + func (*ResolveLockRequest) ProtoMessage() + func (m *ResolveLockRequest) GetCommitVersion() uint64 + func (m *ResolveLockRequest) GetContext() *Context + func (m *ResolveLockRequest) GetStartVersion() uint64 + func (m *ResolveLockRequest) Marshal() (dAtA []byte, err error) + func (m *ResolveLockRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveLockRequest) Reset() + func (m *ResolveLockRequest) Size() (n int) + func (m *ResolveLockRequest) String() string + func (m *ResolveLockRequest) Unmarshal(dAtA []byte) error + type ResolveLockResponse struct + Error *KeyError + RegionError *errorpb.Error + func (*ResolveLockResponse) Descriptor() ([]byte, []int) + func (*ResolveLockResponse) ProtoMessage() + func (m *ResolveLockResponse) GetError() *KeyError + func (m *ResolveLockResponse) GetRegionError() *errorpb.Error + func (m *ResolveLockResponse) Marshal() (dAtA []byte, err error) + func (m *ResolveLockResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveLockResponse) Reset() + func (m *ResolveLockResponse) Size() (n int) + func (m *ResolveLockResponse) String() string + func (m *ResolveLockResponse) Unmarshal(dAtA []byte) error + type ScanLockRequest struct + Context *Context + MaxVersion uint64 + func (*ScanLockRequest) Descriptor() ([]byte, []int) + func (*ScanLockRequest) ProtoMessage() + func (m *ScanLockRequest) GetContext() *Context + func (m *ScanLockRequest) GetMaxVersion() uint64 + func (m *ScanLockRequest) Marshal() (dAtA []byte, err error) + func (m *ScanLockRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ScanLockRequest) Reset() + func (m *ScanLockRequest) Size() (n int) + func (m *ScanLockRequest) String() string + func (m *ScanLockRequest) Unmarshal(dAtA []byte) error + type ScanLockResponse struct + Error *KeyError + Locks []*LockInfo + RegionError *errorpb.Error + func (*ScanLockResponse) Descriptor() ([]byte, []int) + func (*ScanLockResponse) ProtoMessage() + func (m *ScanLockResponse) GetError() *KeyError + func (m *ScanLockResponse) GetLocks() []*LockInfo + func (m *ScanLockResponse) GetRegionError() *errorpb.Error + func (m *ScanLockResponse) Marshal() (dAtA []byte, err error) + func (m *ScanLockResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ScanLockResponse) Reset() + func (m *ScanLockResponse) Size() (n int) + func (m *ScanLockResponse) String() string + func (m *ScanLockResponse) Unmarshal(dAtA []byte) error + type ScanRequest struct + Context *Context + KeyOnly bool + Limit uint32 + StartKey []byte + Version uint64 + func (*ScanRequest) Descriptor() ([]byte, []int) + func (*ScanRequest) ProtoMessage() + func (m *ScanRequest) GetContext() *Context + func (m *ScanRequest) GetKeyOnly() bool + func (m *ScanRequest) GetLimit() uint32 + func (m *ScanRequest) GetStartKey() []byte + func (m *ScanRequest) GetVersion() uint64 + func (m *ScanRequest) Marshal() (dAtA []byte, err error) + func (m *ScanRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ScanRequest) Reset() + func (m *ScanRequest) Size() (n int) + func (m *ScanRequest) String() string + func (m *ScanRequest) Unmarshal(dAtA []byte) error + type ScanResponse struct + Pairs []*KvPair + RegionError *errorpb.Error + func (*ScanResponse) Descriptor() ([]byte, []int) + func (*ScanResponse) ProtoMessage() + func (m *ScanResponse) GetPairs() []*KvPair + func (m *ScanResponse) GetRegionError() *errorpb.Error + func (m *ScanResponse) Marshal() (dAtA []byte, err error) + func (m *ScanResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ScanResponse) Reset() + func (m *ScanResponse) Size() (n int) + func (m *ScanResponse) String() string + func (m *ScanResponse) Unmarshal(dAtA []byte) error + type SplitRegionRequest struct + Context *Context + SplitKey []byte + func (*SplitRegionRequest) Descriptor() ([]byte, []int) + func (*SplitRegionRequest) ProtoMessage() + func (m *SplitRegionRequest) GetContext() *Context + func (m *SplitRegionRequest) GetSplitKey() []byte + func (m *SplitRegionRequest) Marshal() (dAtA []byte, err error) + func (m *SplitRegionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SplitRegionRequest) Reset() + func (m *SplitRegionRequest) Size() (n int) + func (m *SplitRegionRequest) String() string + func (m *SplitRegionRequest) Unmarshal(dAtA []byte) error + type SplitRegionResponse struct + Left *metapb.Region + RegionError *errorpb.Error + Right *metapb.Region + func (*SplitRegionResponse) Descriptor() ([]byte, []int) + func (*SplitRegionResponse) ProtoMessage() + func (m *SplitRegionResponse) GetLeft() *metapb.Region + func (m *SplitRegionResponse) GetRegionError() *errorpb.Error + func (m *SplitRegionResponse) GetRight() *metapb.Region + func (m *SplitRegionResponse) Marshal() (dAtA []byte, err error) + func (m *SplitRegionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SplitRegionResponse) Reset() + func (m *SplitRegionResponse) Size() (n int) + func (m *SplitRegionResponse) String() string + func (m *SplitRegionResponse) Unmarshal(dAtA []byte) error + type ValueInfo struct + IsShortValue bool + Ts uint64 + Value []byte + func (*ValueInfo) Descriptor() ([]byte, []int) + func (*ValueInfo) ProtoMessage() + func (m *ValueInfo) GetIsShortValue() bool + func (m *ValueInfo) GetTs() uint64 + func (m *ValueInfo) GetValue() []byte + func (m *ValueInfo) Marshal() (dAtA []byte, err error) + func (m *ValueInfo) MarshalTo(dAtA []byte) (int, error) + func (m *ValueInfo) Reset() + func (m *ValueInfo) Size() (n int) + func (m *ValueInfo) String() string + func (m *ValueInfo) Unmarshal(dAtA []byte) error + type WriteInfo struct + CommitTs uint64 + StartTs uint64 + Type Op + func (*WriteInfo) Descriptor() ([]byte, []int) + func (*WriteInfo) ProtoMessage() + func (m *WriteInfo) GetCommitTs() uint64 + func (m *WriteInfo) GetStartTs() uint64 + func (m *WriteInfo) GetType() Op + func (m *WriteInfo) Marshal() (dAtA []byte, err error) + func (m *WriteInfo) MarshalTo(dAtA []byte) (int, error) + func (m *WriteInfo) Reset() + func (m *WriteInfo) Size() (n int) + func (m *WriteInfo) String() string + func (m *WriteInfo) Unmarshal(dAtA []byte) error
Go to main page