kvrpcpb

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

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
GetRequest
GetResponse
ScanRequest
KvPair
ScanResponse
Mutation
PrewriteRequest
PrewriteResponse
CommitRequest
CommitResponse
ImportRequest
ImportResponse
BatchRollbackRequest
BatchRollbackResponse
CleanupRequest
CleanupResponse
BatchGetRequest
BatchGetResponse
ScanLockRequest
ScanLockResponse
ResolveLockRequest
ResolveLockResponse
GCRequest
GCResponse
RawGetRequest
RawGetResponse
RawPutRequest
RawPutResponse
RawDeleteRequest
RawDeleteResponse
DeleteRangeRequest
DeleteRangeResponse
RawScanRequest
RawScanResponse
WriteInfo
ValueInfo
MvccInfo
MvccGetByKeyRequest
MvccGetByKeyResponse
MvccGetByStartTsRequest
MvccGetByStartTsResponse
SplitRegionRequest
SplitRegionResponse

Index

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 CommandPri_name = map[int32]string{
	0: "Normal",
	1: "Low",
	2: "High",
}
View Source 
var CommandPri_value = map[string]int32{
	"Normal": 0,
	"Low":    1,
	"High":   2,
}
View Source 
var IsolationLevel_name = map[int32]string{
	0: "SI",
	1: "RC",
}
View Source 
var IsolationLevel_value = map[string]int32{
	"SI": 0,
	"RC": 1,
}
View Source 
var Op_name = map[int32]string{
	0: "Put",
	1: "Del",
	2: "Lock",
	3: "Rollback",
}
View Source 
var Op_value = map[string]int32{
	"Put":      0,
	"Del":      1,
	"Lock":     2,
	"Rollback": 3,
}

Functions

This section is empty.

Types

type BatchGetRequest 

type BatchGetRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Keys    [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	Version uint64   `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
}

func (*BatchGetRequest) Descriptor 

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

func (*BatchGetRequest) GetContext 

func (m *BatchGetRequest) GetContext() *Context

func (*BatchGetRequest) GetKeys 

func (m *BatchGetRequest) GetKeys() [][]byte

func (*BatchGetRequest) GetVersion 

func (m *BatchGetRequest) GetVersion() uint64

func (*BatchGetRequest) Marshal 

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

func (*BatchGetRequest) MarshalTo 

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

func (*BatchGetRequest) ProtoMessage 

func (*BatchGetRequest) ProtoMessage()

func (*BatchGetRequest) Reset 

func (m *BatchGetRequest) Reset()

func (*BatchGetRequest) Size 

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

func (*BatchGetRequest) String 

func (m *BatchGetRequest) String() string

func (*BatchGetRequest) Unmarshal 

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

type BatchGetResponse 

type BatchGetResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Pairs       []*KvPair      `protobuf:"bytes,2,rep,name=pairs" json:"pairs,omitempty"`
}

func (*BatchGetResponse) Descriptor 

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

func (*BatchGetResponse) GetPairs 

func (m *BatchGetResponse) GetPairs() []*KvPair

func (*BatchGetResponse) GetRegionError 

func (m *BatchGetResponse) GetRegionError() *errorpb.Error

func (*BatchGetResponse) Marshal 

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

func (*BatchGetResponse) MarshalTo 

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

func (*BatchGetResponse) ProtoMessage 

func (*BatchGetResponse) ProtoMessage()

func (*BatchGetResponse) Reset 

func (m *BatchGetResponse) Reset()

func (*BatchGetResponse) Size 

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

func (*BatchGetResponse) String 

func (m *BatchGetResponse) String() string

func (*BatchGetResponse) Unmarshal 

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

type BatchRollbackRequest 

type BatchRollbackRequest struct {
	Context      *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartVersion uint64   `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	Keys         [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
}

func (*BatchRollbackRequest) Descriptor 

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

func (*BatchRollbackRequest) GetContext 

func (m *BatchRollbackRequest) GetContext() *Context

func (*BatchRollbackRequest) GetKeys 

func (m *BatchRollbackRequest) GetKeys() [][]byte

func (*BatchRollbackRequest) GetStartVersion 

func (m *BatchRollbackRequest) GetStartVersion() uint64

func (*BatchRollbackRequest) Marshal 

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

func (*BatchRollbackRequest) MarshalTo 

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

func (*BatchRollbackRequest) ProtoMessage 

func (*BatchRollbackRequest) ProtoMessage()

func (*BatchRollbackRequest) Reset 

func (m *BatchRollbackRequest) Reset()

func (*BatchRollbackRequest) Size 

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

func (*BatchRollbackRequest) String 

func (m *BatchRollbackRequest) String() string

func (*BatchRollbackRequest) Unmarshal 

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

type BatchRollbackResponse 

type BatchRollbackResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*BatchRollbackResponse) Descriptor 

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

func (*BatchRollbackResponse) GetError 

func (m *BatchRollbackResponse) GetError() *KeyError

func (*BatchRollbackResponse) GetRegionError 

func (m *BatchRollbackResponse) GetRegionError() *errorpb.Error

func (*BatchRollbackResponse) Marshal 

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

func (*BatchRollbackResponse) MarshalTo 

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

func (*BatchRollbackResponse) ProtoMessage 

func (*BatchRollbackResponse) ProtoMessage()

func (*BatchRollbackResponse) Reset 

func (m *BatchRollbackResponse) Reset()

func (*BatchRollbackResponse) Size 

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

func (*BatchRollbackResponse) String 

func (m *BatchRollbackResponse) String() string

func (*BatchRollbackResponse) Unmarshal 

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

type CleanupRequest 

type CleanupRequest struct {
	Context      *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key          []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	StartVersion uint64   `protobuf:"varint,3,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
}

func (*CleanupRequest) Descriptor 

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

func (*CleanupRequest) GetContext 

func (m *CleanupRequest) GetContext() *Context

func (*CleanupRequest) GetKey 

func (m *CleanupRequest) GetKey() []byte

func (*CleanupRequest) GetStartVersion 

func (m *CleanupRequest) GetStartVersion() uint64

func (*CleanupRequest) Marshal 

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

func (*CleanupRequest) MarshalTo 

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

func (*CleanupRequest) ProtoMessage 

func (*CleanupRequest) ProtoMessage()

func (*CleanupRequest) Reset 

func (m *CleanupRequest) Reset()

func (*CleanupRequest) Size 

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

func (*CleanupRequest) String 

func (m *CleanupRequest) String() string

func (*CleanupRequest) Unmarshal 

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

type CleanupResponse 

type CleanupResponse struct {
	RegionError   *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error         *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	CommitVersion uint64         `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
}

func (*CleanupResponse) Descriptor 

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

func (*CleanupResponse) GetCommitVersion 

func (m *CleanupResponse) GetCommitVersion() uint64

func (*CleanupResponse) GetError 

func (m *CleanupResponse) GetError() *KeyError

func (*CleanupResponse) GetRegionError 

func (m *CleanupResponse) GetRegionError() *errorpb.Error

func (*CleanupResponse) Marshal 

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

func (*CleanupResponse) MarshalTo 

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

func (*CleanupResponse) ProtoMessage 

func (*CleanupResponse) ProtoMessage()

func (*CleanupResponse) Reset 

func (m *CleanupResponse) Reset()

func (*CleanupResponse) Size 

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

func (*CleanupResponse) String 

func (m *CleanupResponse) String() string

func (*CleanupResponse) Unmarshal 

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

type CommandPri 

type CommandPri int32
const (
	CommandPri_Normal CommandPri = 0
	CommandPri_Low    CommandPri = 1
	CommandPri_High   CommandPri = 2
)

func (CommandPri) EnumDescriptor 

func (CommandPri) EnumDescriptor() ([]byte, []int)

func (CommandPri) String 

func (x CommandPri) String() string

type CommitRequest 

type CommitRequest struct {
	Context       *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartVersion  uint64   `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	Keys          [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
	CommitVersion uint64   `protobuf:"varint,4,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
}

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetCommitVersion 

func (m *CommitRequest) GetCommitVersion() uint64

func (*CommitRequest) GetContext 

func (m *CommitRequest) GetContext() *Context

func (*CommitRequest) GetKeys 

func (m *CommitRequest) GetKeys() [][]byte

func (*CommitRequest) GetStartVersion 

func (m *CommitRequest) GetStartVersion() uint64

func (*CommitRequest) Marshal 

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

func (*CommitRequest) MarshalTo 

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

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) Size 

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

func (*CommitRequest) String 

func (m *CommitRequest) String() string

func (*CommitRequest) Unmarshal 

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

type CommitResponse 

type CommitResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) GetError 

func (m *CommitResponse) GetError() *KeyError

func (*CommitResponse) GetRegionError 

func (m *CommitResponse) GetRegionError() *errorpb.Error

func (*CommitResponse) Marshal 

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

func (*CommitResponse) MarshalTo 

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

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) Size 

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

func (*CommitResponse) String 

func (m *CommitResponse) String() string

func (*CommitResponse) Unmarshal 

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

type Context 

type Context struct {
	RegionId       uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	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"`
	Term           uint64              `protobuf:"varint,5,opt,name=term,proto3" json:"term,omitempty"`
	Priority       CommandPri          `protobuf:"varint,6,opt,name=priority,proto3,enum=kvrpcpb.CommandPri" json:"priority,omitempty"`
	IsolationLevel IsolationLevel      `` /* 132-byte string literal not displayed */
	NotFillCache   bool                `protobuf:"varint,8,opt,name=not_fill_cache,json=notFillCache,proto3" json:"not_fill_cache,omitempty"`
	SyncLog        bool                `protobuf:"varint,9,opt,name=sync_log,json=syncLog,proto3" json:"sync_log,omitempty"`
}

func (*Context) Descriptor 

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

func (*Context) GetIsolationLevel 

func (m *Context) GetIsolationLevel() IsolationLevel

func (*Context) GetNotFillCache 

func (m *Context) GetNotFillCache() bool

func (*Context) GetPeer 

func (m *Context) GetPeer() *metapb.Peer

func (*Context) GetPriority 

func (m *Context) GetPriority() CommandPri

func (*Context) GetRegionEpoch 

func (m *Context) GetRegionEpoch() *metapb.RegionEpoch

func (*Context) GetRegionId 

func (m *Context) GetRegionId() uint64

func (*Context) GetSyncLog 

func (m *Context) GetSyncLog() bool

func (*Context) GetTerm 

func (m *Context) GetTerm() uint64

func (*Context) Marshal 

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

func (*Context) MarshalTo 

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

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) Reset 

func (m *Context) Reset()

func (*Context) Size 

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

func (*Context) String 

func (m *Context) String() string

func (*Context) Unmarshal 

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

type DeleteRangeRequest 

type DeleteRangeRequest struct {
	Context  *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartKey []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte   `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
}

func (*DeleteRangeRequest) Descriptor 

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

func (*DeleteRangeRequest) GetContext 

func (m *DeleteRangeRequest) GetContext() *Context

func (*DeleteRangeRequest) GetEndKey 

func (m *DeleteRangeRequest) GetEndKey() []byte

func (*DeleteRangeRequest) GetStartKey 

func (m *DeleteRangeRequest) GetStartKey() []byte

func (*DeleteRangeRequest) Marshal 

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

func (*DeleteRangeRequest) MarshalTo 

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

func (*DeleteRangeRequest) ProtoMessage 

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) Reset 

func (m *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) Size 

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

func (*DeleteRangeRequest) String 

func (m *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) Unmarshal 

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

type DeleteRangeResponse 

type DeleteRangeResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*DeleteRangeResponse) Descriptor 

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

func (*DeleteRangeResponse) GetError 

func (m *DeleteRangeResponse) GetError() string

func (*DeleteRangeResponse) GetRegionError 

func (m *DeleteRangeResponse) GetRegionError() *errorpb.Error

func (*DeleteRangeResponse) Marshal 

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

func (*DeleteRangeResponse) MarshalTo 

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

func (*DeleteRangeResponse) ProtoMessage 

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) Reset 

func (m *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) Size 

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

func (*DeleteRangeResponse) String 

func (m *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) Unmarshal 

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

type GCRequest 

type GCRequest struct {
	Context   *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	SafePoint uint64   `protobuf:"varint,2,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
}

func (*GCRequest) Descriptor 

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

func (*GCRequest) GetContext 

func (m *GCRequest) GetContext() *Context

func (*GCRequest) GetSafePoint 

func (m *GCRequest) GetSafePoint() uint64

func (*GCRequest) Marshal 

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

func (*GCRequest) MarshalTo 

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

func (*GCRequest) ProtoMessage 

func (*GCRequest) ProtoMessage()

func (*GCRequest) Reset 

func (m *GCRequest) Reset()

func (*GCRequest) Size 

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

func (*GCRequest) String 

func (m *GCRequest) String() string

func (*GCRequest) Unmarshal 

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

type GCResponse 

type GCResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*GCResponse) Descriptor 

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

func (*GCResponse) GetError 

func (m *GCResponse) GetError() *KeyError

func (*GCResponse) GetRegionError 

func (m *GCResponse) GetRegionError() *errorpb.Error

func (*GCResponse) Marshal 

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

func (*GCResponse) MarshalTo 

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

func (*GCResponse) ProtoMessage 

func (*GCResponse) ProtoMessage()

func (*GCResponse) Reset 

func (m *GCResponse) Reset()

func (*GCResponse) Size 

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

func (*GCResponse) String 

func (m *GCResponse) String() string

func (*GCResponse) Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key     []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Version uint64   `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetContext 

func (m *GetRequest) GetContext() *Context

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) GetVersion 

func (m *GetRequest) GetVersion() uint64

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

type GetResponse 

type GetResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Value       []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetError 

func (m *GetResponse) GetError() *KeyError

func (*GetResponse) GetRegionError 

func (m *GetResponse) GetRegionError() *errorpb.Error

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() []byte

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

type ImportRequest 

type ImportRequest struct {
	Mutations     []*Mutation `protobuf:"bytes,1,rep,name=mutations" json:"mutations,omitempty"`
	CommitVersion uint64      `protobuf:"varint,2,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
}

func (*ImportRequest) Descriptor 

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

func (*ImportRequest) GetCommitVersion 

func (m *ImportRequest) GetCommitVersion() uint64

func (*ImportRequest) GetMutations 

func (m *ImportRequest) GetMutations() []*Mutation

func (*ImportRequest) Marshal 

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

func (*ImportRequest) MarshalTo 

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

func (*ImportRequest) ProtoMessage 

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) Reset 

func (m *ImportRequest) Reset()

func (*ImportRequest) Size 

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

func (*ImportRequest) String 

func (m *ImportRequest) String() string

func (*ImportRequest) Unmarshal 

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

type ImportResponse 

type ImportResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*ImportResponse) Descriptor 

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

func (*ImportResponse) GetError 

func (m *ImportResponse) GetError() string

func (*ImportResponse) GetRegionError 

func (m *ImportResponse) GetRegionError() *errorpb.Error

func (*ImportResponse) Marshal 

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

func (*ImportResponse) MarshalTo 

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

func (*ImportResponse) ProtoMessage 

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) Reset 

func (m *ImportResponse) Reset()

func (*ImportResponse) Size 

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

func (*ImportResponse) String 

func (m *ImportResponse) String() string

func (*ImportResponse) Unmarshal 

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

type IsolationLevel 

type IsolationLevel int32
const (
	IsolationLevel_SI IsolationLevel = 0
	IsolationLevel_RC IsolationLevel = 1
)

func (IsolationLevel) EnumDescriptor 

func (IsolationLevel) EnumDescriptor() ([]byte, []int)

func (IsolationLevel) String 

func (x IsolationLevel) String() string

type KeyError 

type KeyError struct {
	Locked    *LockInfo `protobuf:"bytes,1,opt,name=locked" json:"locked,omitempty"`
	Retryable string    `protobuf:"bytes,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
	Abort     string    `protobuf:"bytes,3,opt,name=abort,proto3" json:"abort,omitempty"`
}

func (*KeyError) Descriptor 

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

func (*KeyError) GetAbort 

func (m *KeyError) GetAbort() string

func (*KeyError) GetLocked 

func (m *KeyError) GetLocked() *LockInfo

func (*KeyError) GetRetryable 

func (m *KeyError) GetRetryable() string

func (*KeyError) Marshal 

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

func (*KeyError) MarshalTo 

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

func (*KeyError) ProtoMessage 

func (*KeyError) ProtoMessage()

func (*KeyError) Reset 

func (m *KeyError) Reset()

func (*KeyError) Size 

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

func (*KeyError) String 

func (m *KeyError) String() string

func (*KeyError) Unmarshal 

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

type KvPair 

type KvPair struct {
	Error *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Key   []byte    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KvPair) Descriptor 

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

func (*KvPair) GetError 

func (m *KvPair) GetError() *KeyError

func (*KvPair) GetKey 

func (m *KvPair) GetKey() []byte

func (*KvPair) GetValue 

func (m *KvPair) GetValue() []byte

func (*KvPair) Marshal 

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

func (*KvPair) MarshalTo 

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

func (*KvPair) ProtoMessage 

func (*KvPair) ProtoMessage()

func (*KvPair) Reset 

func (m *KvPair) Reset()

func (*KvPair) Size 

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

func (*KvPair) String 

func (m *KvPair) String() string

func (*KvPair) Unmarshal 

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

type LockInfo 

type LockInfo struct {
	PrimaryLock []byte `protobuf:"bytes,1,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
	LockVersion uint64 `protobuf:"varint,2,opt,name=lock_version,json=lockVersion,proto3" json:"lock_version,omitempty"`
	Key         []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	LockTtl     uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
}

func (*LockInfo) Descriptor 

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

func (*LockInfo) GetKey 

func (m *LockInfo) GetKey() []byte

func (*LockInfo) GetLockTtl 

func (m *LockInfo) GetLockTtl() uint64

func (*LockInfo) GetLockVersion 

func (m *LockInfo) GetLockVersion() uint64

func (*LockInfo) GetPrimaryLock 

func (m *LockInfo) GetPrimaryLock() []byte

func (*LockInfo) Marshal 

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

func (*LockInfo) MarshalTo 

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

func (*LockInfo) ProtoMessage 

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset 

func (m *LockInfo) Reset()

func (*LockInfo) Size 

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

func (*LockInfo) String 

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal 

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

type Mutation 

type Mutation struct {
	Op    Op     `protobuf:"varint,1,opt,name=op,proto3,enum=kvrpcpb.Op" json:"op,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Mutation) Descriptor 

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

func (*Mutation) GetKey 

func (m *Mutation) GetKey() []byte

func (*Mutation) GetOp 

func (m *Mutation) GetOp() Op

func (*Mutation) GetValue 

func (m *Mutation) GetValue() []byte

func (*Mutation) Marshal 

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

func (*Mutation) MarshalTo 

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

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) Reset 

func (m *Mutation) Reset()

func (*Mutation) Size 

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

func (*Mutation) String 

func (m *Mutation) String() string

func (*Mutation) Unmarshal 

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

type MvccGetByKeyRequest 

type MvccGetByKeyRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key     []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*MvccGetByKeyRequest) Descriptor 

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

func (*MvccGetByKeyRequest) GetContext 

func (m *MvccGetByKeyRequest) GetContext() *Context

func (*MvccGetByKeyRequest) GetKey 

func (m *MvccGetByKeyRequest) GetKey() []byte

func (*MvccGetByKeyRequest) Marshal 

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

func (*MvccGetByKeyRequest) MarshalTo 

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

func (*MvccGetByKeyRequest) ProtoMessage 

func (*MvccGetByKeyRequest) ProtoMessage()

func (*MvccGetByKeyRequest) Reset 

func (m *MvccGetByKeyRequest) Reset()

func (*MvccGetByKeyRequest) Size 

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

func (*MvccGetByKeyRequest) String 

func (m *MvccGetByKeyRequest) String() string

func (*MvccGetByKeyRequest) Unmarshal 

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

type MvccGetByKeyResponse 

type MvccGetByKeyResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Info        *MvccInfo      `protobuf:"bytes,3,opt,name=info" json:"info,omitempty"`
}

func (*MvccGetByKeyResponse) Descriptor 

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

func (*MvccGetByKeyResponse) GetError 

func (m *MvccGetByKeyResponse) GetError() string

func (*MvccGetByKeyResponse) GetInfo 

func (m *MvccGetByKeyResponse) GetInfo() *MvccInfo

func (*MvccGetByKeyResponse) GetRegionError 

func (m *MvccGetByKeyResponse) GetRegionError() *errorpb.Error

func (*MvccGetByKeyResponse) Marshal 

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

func (*MvccGetByKeyResponse) MarshalTo 

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

func (*MvccGetByKeyResponse) ProtoMessage 

func (*MvccGetByKeyResponse) ProtoMessage()

func (*MvccGetByKeyResponse) Reset 

func (m *MvccGetByKeyResponse) Reset()

func (*MvccGetByKeyResponse) Size 

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

func (*MvccGetByKeyResponse) String 

func (m *MvccGetByKeyResponse) String() string

func (*MvccGetByKeyResponse) Unmarshal 

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

type MvccGetByStartTsRequest 

type MvccGetByStartTsRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartTs uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
}

func (*MvccGetByStartTsRequest) Descriptor 

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

func (*MvccGetByStartTsRequest) GetContext 

func (m *MvccGetByStartTsRequest) GetContext() *Context

func (*MvccGetByStartTsRequest) GetStartTs 

func (m *MvccGetByStartTsRequest) GetStartTs() uint64

func (*MvccGetByStartTsRequest) Marshal 

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

func (*MvccGetByStartTsRequest) MarshalTo 

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

func (*MvccGetByStartTsRequest) ProtoMessage 

func (*MvccGetByStartTsRequest) ProtoMessage()

func (*MvccGetByStartTsRequest) Reset 

func (m *MvccGetByStartTsRequest) Reset()

func (*MvccGetByStartTsRequest) Size 

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

func (*MvccGetByStartTsRequest) String 

func (m *MvccGetByStartTsRequest) String() string

func (*MvccGetByStartTsRequest) Unmarshal 

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

type MvccGetByStartTsResponse 

type MvccGetByStartTsResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Key         []byte         `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Info        *MvccInfo      `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
}

func (*MvccGetByStartTsResponse) Descriptor 

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

func (*MvccGetByStartTsResponse) GetError 

func (m *MvccGetByStartTsResponse) GetError() string

func (*MvccGetByStartTsResponse) GetInfo 

func (m *MvccGetByStartTsResponse) GetInfo() *MvccInfo

func (*MvccGetByStartTsResponse) GetKey 

func (m *MvccGetByStartTsResponse) GetKey() []byte

func (*MvccGetByStartTsResponse) GetRegionError 

func (m *MvccGetByStartTsResponse) GetRegionError() *errorpb.Error

func (*MvccGetByStartTsResponse) Marshal 

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

func (*MvccGetByStartTsResponse) MarshalTo 

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

func (*MvccGetByStartTsResponse) ProtoMessage 

func (*MvccGetByStartTsResponse) ProtoMessage()

func (*MvccGetByStartTsResponse) Reset 

func (m *MvccGetByStartTsResponse) Reset()

func (*MvccGetByStartTsResponse) Size 

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

func (*MvccGetByStartTsResponse) String 

func (m *MvccGetByStartTsResponse) String() string

func (*MvccGetByStartTsResponse) Unmarshal 

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

type MvccInfo 

type MvccInfo struct {
	Lock   *LockInfo    `protobuf:"bytes,1,opt,name=lock" json:"lock,omitempty"`
	Writes []*WriteInfo `protobuf:"bytes,2,rep,name=writes" json:"writes,omitempty"`
	Values []*ValueInfo `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
}

func (*MvccInfo) Descriptor 

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

func (*MvccInfo) GetLock 

func (m *MvccInfo) GetLock() *LockInfo

func (*MvccInfo) GetValues 

func (m *MvccInfo) GetValues() []*ValueInfo

func (*MvccInfo) GetWrites 

func (m *MvccInfo) GetWrites() []*WriteInfo

func (*MvccInfo) Marshal 

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

func (*MvccInfo) MarshalTo 

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

func (*MvccInfo) ProtoMessage 

func (*MvccInfo) ProtoMessage()

func (*MvccInfo) Reset 

func (m *MvccInfo) Reset()

func (*MvccInfo) Size 

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

func (*MvccInfo) String 

func (m *MvccInfo) String() string

func (*MvccInfo) Unmarshal 

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

type Op 

type Op int32
const (
	Op_Put      Op = 0
	Op_Del      Op = 1
	Op_Lock     Op = 2
	Op_Rollback Op = 3
)

func (Op) EnumDescriptor 

func (Op) EnumDescriptor() ([]byte, []int)

func (Op) String 

func (x Op) String() string

type PrewriteRequest 

type PrewriteRequest struct {
	Context   *Context    `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Mutations []*Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
	// primary_lock_key
	PrimaryLock         []byte `protobuf:"bytes,3,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
	StartVersion        uint64 `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	LockTtl             uint64 `protobuf:"varint,5,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	SkipConstraintCheck bool   `protobuf:"varint,6,opt,name=skip_constraint_check,json=skipConstraintCheck,proto3" json:"skip_constraint_check,omitempty"`
}

func (*PrewriteRequest) Descriptor 

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

func (*PrewriteRequest) GetContext 

func (m *PrewriteRequest) GetContext() *Context

func (*PrewriteRequest) GetLockTtl 

func (m *PrewriteRequest) GetLockTtl() uint64

func (*PrewriteRequest) GetMutations 

func (m *PrewriteRequest) GetMutations() []*Mutation

func (*PrewriteRequest) GetPrimaryLock 

func (m *PrewriteRequest) GetPrimaryLock() []byte

func (*PrewriteRequest) GetSkipConstraintCheck 

func (m *PrewriteRequest) GetSkipConstraintCheck() bool

func (*PrewriteRequest) GetStartVersion 

func (m *PrewriteRequest) GetStartVersion() uint64

func (*PrewriteRequest) Marshal 

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

func (*PrewriteRequest) MarshalTo 

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

func (*PrewriteRequest) ProtoMessage 

func (*PrewriteRequest) ProtoMessage()

func (*PrewriteRequest) Reset 

func (m *PrewriteRequest) Reset()

func (*PrewriteRequest) Size 

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

func (*PrewriteRequest) String 

func (m *PrewriteRequest) String() string

func (*PrewriteRequest) Unmarshal 

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

type PrewriteResponse 

type PrewriteResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Errors      []*KeyError    `protobuf:"bytes,2,rep,name=errors" json:"errors,omitempty"`
}

func (*PrewriteResponse) Descriptor 

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

func (*PrewriteResponse) GetErrors 

func (m *PrewriteResponse) GetErrors() []*KeyError

func (*PrewriteResponse) GetRegionError 

func (m *PrewriteResponse) GetRegionError() *errorpb.Error

func (*PrewriteResponse) Marshal 

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

func (*PrewriteResponse) MarshalTo 

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

func (*PrewriteResponse) ProtoMessage 

func (*PrewriteResponse) ProtoMessage()

func (*PrewriteResponse) Reset 

func (m *PrewriteResponse) Reset()

func (*PrewriteResponse) Size 

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

func (*PrewriteResponse) String 

func (m *PrewriteResponse) String() string

func (*PrewriteResponse) Unmarshal 

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

type RawDeleteRequest 

type RawDeleteRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key     []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*RawDeleteRequest) Descriptor 

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

func (*RawDeleteRequest) GetContext 

func (m *RawDeleteRequest) GetContext() *Context

func (*RawDeleteRequest) GetKey 

func (m *RawDeleteRequest) GetKey() []byte

func (*RawDeleteRequest) Marshal 

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

func (*RawDeleteRequest) MarshalTo 

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

func (*RawDeleteRequest) ProtoMessage 

func (*RawDeleteRequest) ProtoMessage()

func (*RawDeleteRequest) Reset 

func (m *RawDeleteRequest) Reset()

func (*RawDeleteRequest) Size 

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

func (*RawDeleteRequest) String 

func (m *RawDeleteRequest) String() string

func (*RawDeleteRequest) Unmarshal 

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

type RawDeleteResponse 

type RawDeleteResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*RawDeleteResponse) Descriptor 

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

func (*RawDeleteResponse) GetError 

func (m *RawDeleteResponse) GetError() string

func (*RawDeleteResponse) GetRegionError 

func (m *RawDeleteResponse) GetRegionError() *errorpb.Error

func (*RawDeleteResponse) Marshal 

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

func (*RawDeleteResponse) MarshalTo 

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

func (*RawDeleteResponse) ProtoMessage 

func (*RawDeleteResponse) ProtoMessage()

func (*RawDeleteResponse) Reset 

func (m *RawDeleteResponse) Reset()

func (*RawDeleteResponse) Size 

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

func (*RawDeleteResponse) String 

func (m *RawDeleteResponse) String() string

func (*RawDeleteResponse) Unmarshal 

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

type RawGetRequest 

type RawGetRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key     []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*RawGetRequest) Descriptor 

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

func (*RawGetRequest) GetContext 

func (m *RawGetRequest) GetContext() *Context

func (*RawGetRequest) GetKey 

func (m *RawGetRequest) GetKey() []byte

func (*RawGetRequest) Marshal 

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

func (*RawGetRequest) MarshalTo 

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

func (*RawGetRequest) ProtoMessage 

func (*RawGetRequest) ProtoMessage()

func (*RawGetRequest) Reset 

func (m *RawGetRequest) Reset()

func (*RawGetRequest) Size 

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

func (*RawGetRequest) String 

func (m *RawGetRequest) String() string

func (*RawGetRequest) Unmarshal 

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

type RawGetResponse 

type RawGetResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Value       []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RawGetResponse) Descriptor 

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

func (*RawGetResponse) GetError 

func (m *RawGetResponse) GetError() string

func (*RawGetResponse) GetRegionError 

func (m *RawGetResponse) GetRegionError() *errorpb.Error

func (*RawGetResponse) GetValue 

func (m *RawGetResponse) GetValue() []byte

func (*RawGetResponse) Marshal 

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

func (*RawGetResponse) MarshalTo 

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

func (*RawGetResponse) ProtoMessage 

func (*RawGetResponse) ProtoMessage()

func (*RawGetResponse) Reset 

func (m *RawGetResponse) Reset()

func (*RawGetResponse) Size 

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

func (*RawGetResponse) String 

func (m *RawGetResponse) String() string

func (*RawGetResponse) Unmarshal 

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

type RawPutRequest 

type RawPutRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key     []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RawPutRequest) Descriptor 

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

func (*RawPutRequest) GetContext 

func (m *RawPutRequest) GetContext() *Context

func (*RawPutRequest) GetKey 

func (m *RawPutRequest) GetKey() []byte

func (*RawPutRequest) GetValue 

func (m *RawPutRequest) GetValue() []byte

func (*RawPutRequest) Marshal 

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

func (*RawPutRequest) MarshalTo 

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

func (*RawPutRequest) ProtoMessage 

func (*RawPutRequest) ProtoMessage()

func (*RawPutRequest) Reset 

func (m *RawPutRequest) Reset()

func (*RawPutRequest) Size 

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

func (*RawPutRequest) String 

func (m *RawPutRequest) String() string

func (*RawPutRequest) Unmarshal 

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

type RawPutResponse 

type RawPutResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*RawPutResponse) Descriptor 

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

func (*RawPutResponse) GetError 

func (m *RawPutResponse) GetError() string

func (*RawPutResponse) GetRegionError 

func (m *RawPutResponse) GetRegionError() *errorpb.Error

func (*RawPutResponse) Marshal 

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

func (*RawPutResponse) MarshalTo 

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

func (*RawPutResponse) ProtoMessage 

func (*RawPutResponse) ProtoMessage()

func (*RawPutResponse) Reset 

func (m *RawPutResponse) Reset()

func (*RawPutResponse) Size 

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

func (*RawPutResponse) String 

func (m *RawPutResponse) String() string

func (*RawPutResponse) Unmarshal 

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

type RawScanRequest 

type RawScanRequest struct {
	Context  *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartKey []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	Limit    uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*RawScanRequest) Descriptor 

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

func (*RawScanRequest) GetContext 

func (m *RawScanRequest) GetContext() *Context

func (*RawScanRequest) GetLimit 

func (m *RawScanRequest) GetLimit() uint32

func (*RawScanRequest) GetStartKey 

func (m *RawScanRequest) GetStartKey() []byte

func (*RawScanRequest) Marshal 

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

func (*RawScanRequest) MarshalTo 

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

func (*RawScanRequest) ProtoMessage 

func (*RawScanRequest) ProtoMessage()

func (*RawScanRequest) Reset 

func (m *RawScanRequest) Reset()

func (*RawScanRequest) Size 

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

func (*RawScanRequest) String 

func (m *RawScanRequest) String() string

func (*RawScanRequest) Unmarshal 

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

type RawScanResponse 

type RawScanResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Kvs         []*KvPair      `protobuf:"bytes,2,rep,name=kvs" json:"kvs,omitempty"`
}

func (*RawScanResponse) Descriptor 

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

func (*RawScanResponse) GetKvs 

func (m *RawScanResponse) GetKvs() []*KvPair

func (*RawScanResponse) GetRegionError 

func (m *RawScanResponse) GetRegionError() *errorpb.Error

func (*RawScanResponse) Marshal 

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

func (*RawScanResponse) MarshalTo 

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

func (*RawScanResponse) ProtoMessage 

func (*RawScanResponse) ProtoMessage()

func (*RawScanResponse) Reset 

func (m *RawScanResponse) Reset()

func (*RawScanResponse) Size 

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

func (*RawScanResponse) String 

func (m *RawScanResponse) String() string

func (*RawScanResponse) Unmarshal 

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

type ResolveLockRequest 

type ResolveLockRequest struct {
	Context      *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartVersion uint64   `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	// If the txn is rolled back, do not set it.
	CommitVersion uint64 `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
}

func (*ResolveLockRequest) Descriptor 

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

func (*ResolveLockRequest) GetCommitVersion 

func (m *ResolveLockRequest) GetCommitVersion() uint64

func (*ResolveLockRequest) GetContext 

func (m *ResolveLockRequest) GetContext() *Context

func (*ResolveLockRequest) GetStartVersion 

func (m *ResolveLockRequest) GetStartVersion() uint64

func (*ResolveLockRequest) Marshal 

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

func (*ResolveLockRequest) MarshalTo 

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

func (*ResolveLockRequest) ProtoMessage 

func (*ResolveLockRequest) ProtoMessage()

func (*ResolveLockRequest) Reset 

func (m *ResolveLockRequest) Reset()

func (*ResolveLockRequest) Size 

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

func (*ResolveLockRequest) String 

func (m *ResolveLockRequest) String() string

func (*ResolveLockRequest) Unmarshal 

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

type ResolveLockResponse 

type ResolveLockResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*ResolveLockResponse) Descriptor 

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

func (*ResolveLockResponse) GetError 

func (m *ResolveLockResponse) GetError() *KeyError

func (*ResolveLockResponse) GetRegionError 

func (m *ResolveLockResponse) GetRegionError() *errorpb.Error

func (*ResolveLockResponse) Marshal 

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

func (*ResolveLockResponse) MarshalTo 

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

func (*ResolveLockResponse) ProtoMessage 

func (*ResolveLockResponse) ProtoMessage()

func (*ResolveLockResponse) Reset 

func (m *ResolveLockResponse) Reset()

func (*ResolveLockResponse) Size 

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

func (*ResolveLockResponse) String 

func (m *ResolveLockResponse) String() string

func (*ResolveLockResponse) Unmarshal 

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

type ScanLockRequest 

type ScanLockRequest struct {
	Context    *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	MaxVersion uint64   `protobuf:"varint,2,opt,name=max_version,json=maxVersion,proto3" json:"max_version,omitempty"`
}

func (*ScanLockRequest) Descriptor 

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

func (*ScanLockRequest) GetContext 

func (m *ScanLockRequest) GetContext() *Context

func (*ScanLockRequest) GetMaxVersion 

func (m *ScanLockRequest) GetMaxVersion() uint64

func (*ScanLockRequest) Marshal 

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

func (*ScanLockRequest) MarshalTo 

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

func (*ScanLockRequest) ProtoMessage 

func (*ScanLockRequest) ProtoMessage()

func (*ScanLockRequest) Reset 

func (m *ScanLockRequest) Reset()

func (*ScanLockRequest) Size 

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

func (*ScanLockRequest) String 

func (m *ScanLockRequest) String() string

func (*ScanLockRequest) Unmarshal 

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

type ScanLockResponse 

type ScanLockResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Locks       []*LockInfo    `protobuf:"bytes,3,rep,name=locks" json:"locks,omitempty"`
}

func (*ScanLockResponse) Descriptor 

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

func (*ScanLockResponse) GetError 

func (m *ScanLockResponse) GetError() *KeyError

func (*ScanLockResponse) GetLocks 

func (m *ScanLockResponse) GetLocks() []*LockInfo

func (*ScanLockResponse) GetRegionError 

func (m *ScanLockResponse) GetRegionError() *errorpb.Error

func (*ScanLockResponse) Marshal 

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

func (*ScanLockResponse) MarshalTo 

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

func (*ScanLockResponse) ProtoMessage 

func (*ScanLockResponse) ProtoMessage()

func (*ScanLockResponse) Reset 

func (m *ScanLockResponse) Reset()

func (*ScanLockResponse) Size 

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

func (*ScanLockResponse) String 

func (m *ScanLockResponse) String() string

func (*ScanLockResponse) Unmarshal 

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

type ScanRequest 

type ScanRequest struct {
	Context  *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	StartKey []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	Limit    uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Version  uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	KeyOnly  bool     `protobuf:"varint,5,opt,name=key_only,json=keyOnly,proto3" json:"key_only,omitempty"`
}

func (*ScanRequest) Descriptor 

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

func (*ScanRequest) GetContext 

func (m *ScanRequest) GetContext() *Context

func (*ScanRequest) GetKeyOnly 

func (m *ScanRequest) GetKeyOnly() bool

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() uint32

func (*ScanRequest) GetStartKey 

func (m *ScanRequest) GetStartKey() []byte

func (*ScanRequest) GetVersion 

func (m *ScanRequest) GetVersion() uint64

func (*ScanRequest) Marshal 

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

func (*ScanRequest) MarshalTo 

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

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset 

func (m *ScanRequest) Reset()

func (*ScanRequest) Size 

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

func (*ScanRequest) String 

func (m *ScanRequest) String() string

func (*ScanRequest) Unmarshal 

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

type ScanResponse 

type ScanResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Pairs       []*KvPair      `protobuf:"bytes,2,rep,name=pairs" json:"pairs,omitempty"`
}

func (*ScanResponse) Descriptor 

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

func (*ScanResponse) GetPairs 

func (m *ScanResponse) GetPairs() []*KvPair

func (*ScanResponse) GetRegionError 

func (m *ScanResponse) GetRegionError() *errorpb.Error

func (*ScanResponse) Marshal 

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

func (*ScanResponse) MarshalTo 

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

func (*ScanResponse) ProtoMessage 

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) Reset 

func (m *ScanResponse) Reset()

func (*ScanResponse) Size 

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

func (*ScanResponse) String 

func (m *ScanResponse) String() string

func (*ScanResponse) Unmarshal 

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

type SplitRegionRequest 

type SplitRegionRequest struct {
	Context  *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	SplitKey []byte   `protobuf:"bytes,2,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
}

func (*SplitRegionRequest) Descriptor 

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

func (*SplitRegionRequest) GetContext 

func (m *SplitRegionRequest) GetContext() *Context

func (*SplitRegionRequest) GetSplitKey 

func (m *SplitRegionRequest) GetSplitKey() []byte

func (*SplitRegionRequest) Marshal 

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

func (*SplitRegionRequest) MarshalTo 

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

func (*SplitRegionRequest) ProtoMessage 

func (*SplitRegionRequest) ProtoMessage()

func (*SplitRegionRequest) Reset 

func (m *SplitRegionRequest) Reset()

func (*SplitRegionRequest) Size 

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

func (*SplitRegionRequest) String 

func (m *SplitRegionRequest) String() string

func (*SplitRegionRequest) Unmarshal 

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

type SplitRegionResponse 

type SplitRegionResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	Left        *metapb.Region `protobuf:"bytes,2,opt,name=left" json:"left,omitempty"`
	Right       *metapb.Region `protobuf:"bytes,3,opt,name=right" json:"right,omitempty"`
}

func (*SplitRegionResponse) Descriptor 

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

func (*SplitRegionResponse) GetLeft 

func (m *SplitRegionResponse) GetLeft() *metapb.Region

func (*SplitRegionResponse) GetRegionError 

func (m *SplitRegionResponse) GetRegionError() *errorpb.Error

func (*SplitRegionResponse) GetRight 

func (m *SplitRegionResponse) GetRight() *metapb.Region

func (*SplitRegionResponse) Marshal 

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

func (*SplitRegionResponse) MarshalTo 

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

func (*SplitRegionResponse) ProtoMessage 

func (*SplitRegionResponse) ProtoMessage()

func (*SplitRegionResponse) Reset 

func (m *SplitRegionResponse) Reset()

func (*SplitRegionResponse) Size 

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

func (*SplitRegionResponse) String 

func (m *SplitRegionResponse) String() string

func (*SplitRegionResponse) Unmarshal 

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

type ValueInfo 

type ValueInfo struct {
	Value        []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Ts           uint64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	IsShortValue bool   `protobuf:"varint,3,opt,name=is_short_value,json=isShortValue,proto3" json:"is_short_value,omitempty"`
}

func (*ValueInfo) Descriptor 

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

func (*ValueInfo) GetIsShortValue 

func (m *ValueInfo) GetIsShortValue() bool

func (*ValueInfo) GetTs 

func (m *ValueInfo) GetTs() uint64

func (*ValueInfo) GetValue 

func (m *ValueInfo) GetValue() []byte

func (*ValueInfo) Marshal 

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

func (*ValueInfo) MarshalTo 

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

func (*ValueInfo) ProtoMessage 

func (*ValueInfo) ProtoMessage()

func (*ValueInfo) Reset 

func (m *ValueInfo) Reset()

func (*ValueInfo) Size 

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

func (*ValueInfo) String 

func (m *ValueInfo) String() string

func (*ValueInfo) Unmarshal 

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

type WriteInfo 

type WriteInfo struct {
	StartTs  uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Type     Op     `protobuf:"varint,2,opt,name=type,proto3,enum=kvrpcpb.Op" json:"type,omitempty"`
	CommitTs uint64 `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
}

func (*WriteInfo) Descriptor 

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

func (*WriteInfo) GetCommitTs 

func (m *WriteInfo) GetCommitTs() uint64

func (*WriteInfo) GetStartTs 

func (m *WriteInfo) GetStartTs() uint64

func (*WriteInfo) GetType 

func (m *WriteInfo) GetType() Op

func (*WriteInfo) Marshal 

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

func (*WriteInfo) MarshalTo 

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

func (*WriteInfo) ProtoMessage 

func (*WriteInfo) ProtoMessage()

func (*WriteInfo) Reset 

func (m *WriteInfo) Reset()

func (*WriteInfo) Size 

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

func (*WriteInfo) String 

func (m *WriteInfo) String() string

func (*WriteInfo) Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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