kvrpcpb

package
Version: v1.0.9 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2018 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL