kvrpcpb

package
v0.0.0-...-bbbbfd2 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

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 Assertion_name = map[int32]string{
	0: "None",
	1: "Exist",
	2: "NotExist",
}
View Source 
var Assertion_value = map[string]int32{
	"None":     0,
	"Exist":    1,
	"NotExist": 2,
}
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",
	4: "Insert",
	5: "PessimisticLock",
}
View Source 
var Op_value = map[string]int32{
	"Put":             0,
	"Del":             1,
	"Lock":            2,
	"Rollback":        3,
	"Insert":          4,
	"PessimisticLock": 5,
}

Functions

This section is empty.

Types

type AlreadyExist 

type AlreadyExist struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlreadyExist) Descriptor 

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

func (*AlreadyExist) GetKey 

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

func (*AlreadyExist) Marshal 

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

func (*AlreadyExist) MarshalTo 

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

func (*AlreadyExist) ProtoMessage 

func (*AlreadyExist) ProtoMessage()

func (*AlreadyExist) Reset 

func (m *AlreadyExist) Reset()

func (*AlreadyExist) Size 

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

func (*AlreadyExist) String 

func (m *AlreadyExist) String() string

func (*AlreadyExist) Unmarshal 

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

func (*AlreadyExist) XXX_DiscardUnknown 

func (m *AlreadyExist) XXX_DiscardUnknown()

func (*AlreadyExist) XXX_Marshal 

func (m *AlreadyExist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlreadyExist) XXX_Merge 

func (dst *AlreadyExist) XXX_Merge(src proto.Message)

func (*AlreadyExist) XXX_Size 

func (m *AlreadyExist) XXX_Size() int

func (*AlreadyExist) XXX_Unmarshal 

func (m *AlreadyExist) XXX_Unmarshal(b []byte) error

type Assertion 

type Assertion int32
const (
	Assertion_None     Assertion = 0
	Assertion_Exist    Assertion = 1
	Assertion_NotExist Assertion = 2
)

func (Assertion) EnumDescriptor 

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

func (Assertion) String 

func (x Assertion) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BatchGetRequest) XXX_DiscardUnknown 

func (m *BatchGetRequest) XXX_DiscardUnknown()

func (*BatchGetRequest) XXX_Marshal 

func (m *BatchGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchGetRequest) XXX_Merge 

func (dst *BatchGetRequest) XXX_Merge(src proto.Message)

func (*BatchGetRequest) XXX_Size 

func (m *BatchGetRequest) XXX_Size() int

func (*BatchGetRequest) XXX_Unmarshal 

func (m *BatchGetRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*BatchGetResponse) XXX_DiscardUnknown 

func (m *BatchGetResponse) XXX_DiscardUnknown()

func (*BatchGetResponse) XXX_Marshal 

func (m *BatchGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchGetResponse) XXX_Merge 

func (dst *BatchGetResponse) XXX_Merge(src proto.Message)

func (*BatchGetResponse) XXX_Size 

func (m *BatchGetResponse) XXX_Size() int

func (*BatchGetResponse) XXX_Unmarshal 

func (m *BatchGetResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BatchRollbackRequest) XXX_DiscardUnknown 

func (m *BatchRollbackRequest) XXX_DiscardUnknown()

func (*BatchRollbackRequest) XXX_Marshal 

func (m *BatchRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchRollbackRequest) XXX_Merge 

func (dst *BatchRollbackRequest) XXX_Merge(src proto.Message)

func (*BatchRollbackRequest) XXX_Size 

func (m *BatchRollbackRequest) XXX_Size() int

func (*BatchRollbackRequest) XXX_Unmarshal 

func (m *BatchRollbackRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*BatchRollbackResponse) XXX_DiscardUnknown 

func (m *BatchRollbackResponse) XXX_DiscardUnknown()

func (*BatchRollbackResponse) XXX_Marshal 

func (m *BatchRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchRollbackResponse) XXX_Merge 

func (dst *BatchRollbackResponse) XXX_Merge(src proto.Message)

func (*BatchRollbackResponse) XXX_Size 

func (m *BatchRollbackResponse) XXX_Size() int

func (*BatchRollbackResponse) XXX_Unmarshal 

func (m *BatchRollbackResponse) XXX_Unmarshal(b []byte) error

type CheckTxnStatusRequest 

type CheckTxnStatusRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	PrimaryKey           []byte   `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	LockTs               uint64   `protobuf:"varint,3,opt,name=lock_ts,json=lockTs,proto3" json:"lock_ts,omitempty"`
	CallerStartTs        uint64   `protobuf:"varint,4,opt,name=caller_start_ts,json=callerStartTs,proto3" json:"caller_start_ts,omitempty"`
	CurrentTs            uint64   `protobuf:"varint,5,opt,name=current_ts,json=currentTs,proto3" json:"current_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckTxnStatusRequest checks the status of a transaction. If the transaction is rollbacked/committed, return the result; If the TTL of the transaction is exhausted, abort that transaction and return rollbacked; Otherwise, returns the TTL information. CheckTxnStatusRequest may also pushe forward the minCommitTS of a large transaction.

func (*CheckTxnStatusRequest) Descriptor 

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

func (*CheckTxnStatusRequest) GetCallerStartTs 

func (m *CheckTxnStatusRequest) GetCallerStartTs() uint64

func (*CheckTxnStatusRequest) GetContext 

func (m *CheckTxnStatusRequest) GetContext() *Context

func (*CheckTxnStatusRequest) GetCurrentTs 

func (m *CheckTxnStatusRequest) GetCurrentTs() uint64

func (*CheckTxnStatusRequest) GetLockTs 

func (m *CheckTxnStatusRequest) GetLockTs() uint64

func (*CheckTxnStatusRequest) GetPrimaryKey 

func (m *CheckTxnStatusRequest) GetPrimaryKey() []byte

func (*CheckTxnStatusRequest) Marshal 

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

func (*CheckTxnStatusRequest) MarshalTo 

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

func (*CheckTxnStatusRequest) ProtoMessage 

func (*CheckTxnStatusRequest) ProtoMessage()

func (*CheckTxnStatusRequest) Reset 

func (m *CheckTxnStatusRequest) Reset()

func (*CheckTxnStatusRequest) Size 

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

func (*CheckTxnStatusRequest) String 

func (m *CheckTxnStatusRequest) String() string

func (*CheckTxnStatusRequest) Unmarshal 

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

func (*CheckTxnStatusRequest) XXX_DiscardUnknown 

func (m *CheckTxnStatusRequest) XXX_DiscardUnknown()

func (*CheckTxnStatusRequest) XXX_Marshal 

func (m *CheckTxnStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckTxnStatusRequest) XXX_Merge 

func (dst *CheckTxnStatusRequest) XXX_Merge(src proto.Message)

func (*CheckTxnStatusRequest) XXX_Size 

func (m *CheckTxnStatusRequest) XXX_Size() int

func (*CheckTxnStatusRequest) XXX_Unmarshal 

func (m *CheckTxnStatusRequest) XXX_Unmarshal(b []byte) error

type CheckTxnStatusResponse 

type CheckTxnStatusResponse 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"`
	// Three kinds of txn status:
	// locked: lock_ttl > 0
	// committed: commit_version > 0
	// rollbacked: lock_ttl = 0 && commit_version = 0
	LockTtl              uint64   `protobuf:"varint,3,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	CommitVersion        uint64   `protobuf:"varint,4,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckTxnStatusResponse) Descriptor 

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

func (*CheckTxnStatusResponse) GetCommitVersion 

func (m *CheckTxnStatusResponse) GetCommitVersion() uint64

func (*CheckTxnStatusResponse) GetError 

func (m *CheckTxnStatusResponse) GetError() *KeyError

func (*CheckTxnStatusResponse) GetLockTtl 

func (m *CheckTxnStatusResponse) GetLockTtl() uint64

func (*CheckTxnStatusResponse) GetRegionError 

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

func (*CheckTxnStatusResponse) Marshal 

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

func (*CheckTxnStatusResponse) MarshalTo 

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

func (*CheckTxnStatusResponse) ProtoMessage 

func (*CheckTxnStatusResponse) ProtoMessage()

func (*CheckTxnStatusResponse) Reset 

func (m *CheckTxnStatusResponse) Reset()

func (*CheckTxnStatusResponse) Size 

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

func (*CheckTxnStatusResponse) String 

func (m *CheckTxnStatusResponse) String() string

func (*CheckTxnStatusResponse) Unmarshal 

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

func (*CheckTxnStatusResponse) XXX_DiscardUnknown 

func (m *CheckTxnStatusResponse) XXX_DiscardUnknown()

func (*CheckTxnStatusResponse) XXX_Marshal 

func (m *CheckTxnStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckTxnStatusResponse) XXX_Merge 

func (dst *CheckTxnStatusResponse) XXX_Merge(src proto.Message)

func (*CheckTxnStatusResponse) XXX_Size 

func (m *CheckTxnStatusResponse) XXX_Size() int

func (*CheckTxnStatusResponse) XXX_Unmarshal 

func (m *CheckTxnStatusResponse) XXX_Unmarshal(b []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"`
	CurrentTs            uint64   `protobuf:"varint,4,opt,name=current_ts,json=currentTs,proto3" json:"current_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CleanupRequest) Descriptor 

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

func (*CleanupRequest) GetContext 

func (m *CleanupRequest) GetContext() *Context

func (*CleanupRequest) GetCurrentTs 

func (m *CleanupRequest) GetCurrentTs() uint64

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

func (*CleanupRequest) XXX_DiscardUnknown 

func (m *CleanupRequest) XXX_DiscardUnknown()

func (*CleanupRequest) XXX_Marshal 

func (m *CleanupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CleanupRequest) XXX_Merge 

func (dst *CleanupRequest) XXX_Merge(src proto.Message)

func (*CleanupRequest) XXX_Size 

func (m *CleanupRequest) XXX_Size() int

func (*CleanupRequest) XXX_Unmarshal 

func (m *CleanupRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*CleanupResponse) XXX_DiscardUnknown 

func (m *CleanupResponse) XXX_DiscardUnknown()

func (*CleanupResponse) XXX_Marshal 

func (m *CleanupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CleanupResponse) XXX_Merge 

func (dst *CleanupResponse) XXX_Merge(src proto.Message)

func (*CleanupResponse) XXX_Size 

func (m *CleanupResponse) XXX_Size() int

func (*CleanupResponse) XXX_Unmarshal 

func (m *CleanupResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitRequest) XXX_Merge 

func (dst *CommitRequest) XXX_Merge(src proto.Message)

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

func (m *CommitRequest) XXX_Unmarshal(b []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"`
	CommitVersion        uint64         `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) GetCommitVersion 

func (m *CommitResponse) GetCommitVersion() uint64

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

func (*CommitResponse) XXX_DiscardUnknown 

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal 

func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitResponse) XXX_Merge 

func (dst *CommitResponse) XXX_Merge(src proto.Message)

func (*CommitResponse) XXX_Size 

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal 

func (m *CommitResponse) XXX_Unmarshal(b []byte) error

type CommitTsExpired 

type CommitTsExpired struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	AttemptedCommitTs    uint64   `protobuf:"varint,2,opt,name=attempted_commit_ts,json=attemptedCommitTs,proto3" json:"attempted_commit_ts,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	MinCommitTs          uint64   `protobuf:"varint,4,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitTsExpired) Descriptor 

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

func (*CommitTsExpired) GetAttemptedCommitTs 

func (m *CommitTsExpired) GetAttemptedCommitTs() uint64

func (*CommitTsExpired) GetKey 

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

func (*CommitTsExpired) GetMinCommitTs 

func (m *CommitTsExpired) GetMinCommitTs() uint64

func (*CommitTsExpired) GetStartTs 

func (m *CommitTsExpired) GetStartTs() uint64

func (*CommitTsExpired) Marshal 

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

func (*CommitTsExpired) MarshalTo 

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

func (*CommitTsExpired) ProtoMessage 

func (*CommitTsExpired) ProtoMessage()

func (*CommitTsExpired) Reset 

func (m *CommitTsExpired) Reset()

func (*CommitTsExpired) Size 

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

func (*CommitTsExpired) String 

func (m *CommitTsExpired) String() string

func (*CommitTsExpired) Unmarshal 

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

func (*CommitTsExpired) XXX_DiscardUnknown 

func (m *CommitTsExpired) XXX_DiscardUnknown()

func (*CommitTsExpired) XXX_Marshal 

func (m *CommitTsExpired) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitTsExpired) XXX_Merge 

func (dst *CommitTsExpired) XXX_Merge(src proto.Message)

func (*CommitTsExpired) XXX_Size 

func (m *CommitTsExpired) XXX_Size() int

func (*CommitTsExpired) XXX_Unmarshal 

func (m *CommitTsExpired) XXX_Unmarshal(b []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"`
	HandleTime           bool                `protobuf:"varint,10,opt,name=handle_time,json=handleTime,proto3" json:"handle_time,omitempty"`
	ScanDetail           bool                `protobuf:"varint,11,opt,name=scan_detail,json=scanDetail,proto3" json:"scan_detail,omitempty"`
	ReplicaRead          bool                `protobuf:"varint,12,opt,name=replica_read,json=replicaRead,proto3" json:"replica_read,omitempty"`
	ResolvedLocks        []uint64            `protobuf:"varint,13,rep,packed,name=resolved_locks,json=resolvedLocks" json:"resolved_locks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Context) Descriptor 

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

func (*Context) GetHandleTime 

func (m *Context) GetHandleTime() bool

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) GetReplicaRead 

func (m *Context) GetReplicaRead() bool

func (*Context) GetResolvedLocks 

func (m *Context) GetResolvedLocks() []uint64

func (*Context) GetScanDetail 

func (m *Context) GetScanDetail() bool

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

func (*Context) XXX_DiscardUnknown 

func (m *Context) XXX_DiscardUnknown()

func (*Context) XXX_Marshal 

func (m *Context) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Context) XXX_Merge 

func (dst *Context) XXX_Merge(src proto.Message)

func (*Context) XXX_Size 

func (m *Context) XXX_Size() int

func (*Context) XXX_Unmarshal 

func (m *Context) XXX_Unmarshal(b []byte) error

type Deadlock 

type Deadlock struct {
	LockTs               uint64   `protobuf:"varint,1,opt,name=lock_ts,json=lockTs,proto3" json:"lock_ts,omitempty"`
	LockKey              []byte   `protobuf:"bytes,2,opt,name=lock_key,json=lockKey,proto3" json:"lock_key,omitempty"`
	DeadlockKeyHash      uint64   `protobuf:"varint,3,opt,name=deadlock_key_hash,json=deadlockKeyHash,proto3" json:"deadlock_key_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Deadlock) Descriptor 

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

func (*Deadlock) GetDeadlockKeyHash 

func (m *Deadlock) GetDeadlockKeyHash() uint64

func (*Deadlock) GetLockKey 

func (m *Deadlock) GetLockKey() []byte

func (*Deadlock) GetLockTs 

func (m *Deadlock) GetLockTs() uint64

func (*Deadlock) Marshal 

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

func (*Deadlock) MarshalTo 

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

func (*Deadlock) ProtoMessage 

func (*Deadlock) ProtoMessage()

func (*Deadlock) Reset 

func (m *Deadlock) Reset()

func (*Deadlock) Size 

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

func (*Deadlock) String 

func (m *Deadlock) String() string

func (*Deadlock) Unmarshal 

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

func (*Deadlock) XXX_DiscardUnknown 

func (m *Deadlock) XXX_DiscardUnknown()

func (*Deadlock) XXX_Marshal 

func (m *Deadlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Deadlock) XXX_Merge 

func (dst *Deadlock) XXX_Merge(src proto.Message)

func (*Deadlock) XXX_Size 

func (m *Deadlock) XXX_Size() int

func (*Deadlock) XXX_Unmarshal 

func (m *Deadlock) XXX_Unmarshal(b []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"`
	NotifyOnly           bool     `protobuf:"varint,4,opt,name=notify_only,json=notifyOnly,proto3" json:"notify_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetNotifyOnly 

func (m *DeleteRangeRequest) GetNotifyOnly() bool

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

func (*DeleteRangeRequest) XXX_DiscardUnknown 

func (m *DeleteRangeRequest) XXX_DiscardUnknown()

func (*DeleteRangeRequest) XXX_Marshal 

func (m *DeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRangeRequest) XXX_Merge 

func (dst *DeleteRangeRequest) XXX_Merge(src proto.Message)

func (*DeleteRangeRequest) XXX_Size 

func (m *DeleteRangeRequest) XXX_Size() int

func (*DeleteRangeRequest) XXX_Unmarshal 

func (m *DeleteRangeRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*DeleteRangeResponse) XXX_DiscardUnknown 

func (m *DeleteRangeResponse) XXX_DiscardUnknown()

func (*DeleteRangeResponse) XXX_Marshal 

func (m *DeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRangeResponse) XXX_Merge 

func (dst *DeleteRangeResponse) XXX_Merge(src proto.Message)

func (*DeleteRangeResponse) XXX_Size 

func (m *DeleteRangeResponse) XXX_Size() int

func (*DeleteRangeResponse) XXX_Unmarshal 

func (m *DeleteRangeResponse) XXX_Unmarshal(b []byte) error

type ExecDetails 

type ExecDetails struct {
	HandleTime           *HandleTime `protobuf:"bytes,1,opt,name=handle_time,json=handleTime" json:"handle_time,omitempty"`
	ScanDetail           *ScanDetail `protobuf:"bytes,2,opt,name=scan_detail,json=scanDetail" json:"scan_detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ExecDetails) Descriptor 

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

func (*ExecDetails) GetHandleTime 

func (m *ExecDetails) GetHandleTime() *HandleTime

func (*ExecDetails) GetScanDetail 

func (m *ExecDetails) GetScanDetail() *ScanDetail

func (*ExecDetails) Marshal 

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

func (*ExecDetails) MarshalTo 

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

func (*ExecDetails) ProtoMessage 

func (*ExecDetails) ProtoMessage()

func (*ExecDetails) Reset 

func (m *ExecDetails) Reset()

func (*ExecDetails) Size 

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

func (*ExecDetails) String 

func (m *ExecDetails) String() string

func (*ExecDetails) Unmarshal 

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

func (*ExecDetails) XXX_DiscardUnknown 

func (m *ExecDetails) XXX_DiscardUnknown()

func (*ExecDetails) XXX_Marshal 

func (m *ExecDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecDetails) XXX_Merge 

func (dst *ExecDetails) XXX_Merge(src proto.Message)

func (*ExecDetails) XXX_Size 

func (m *ExecDetails) XXX_Size() int

func (*ExecDetails) XXX_Unmarshal 

func (m *ExecDetails) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*GCRequest) XXX_DiscardUnknown 

func (m *GCRequest) XXX_DiscardUnknown()

func (*GCRequest) XXX_Marshal 

func (m *GCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCRequest) XXX_Merge 

func (dst *GCRequest) XXX_Merge(src proto.Message)

func (*GCRequest) XXX_Size 

func (m *GCRequest) XXX_Size() int

func (*GCRequest) XXX_Unmarshal 

func (m *GCRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GCResponse) XXX_DiscardUnknown 

func (m *GCResponse) XXX_DiscardUnknown()

func (*GCResponse) XXX_Marshal 

func (m *GCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCResponse) XXX_Merge 

func (dst *GCResponse) XXX_Merge(src proto.Message)

func (*GCResponse) XXX_Size 

func (m *GCResponse) XXX_Size() int

func (*GCResponse) XXX_Unmarshal 

func (m *GCResponse) XXX_Unmarshal(b []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"`
	ReadOnly             bool     `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetReadOnly 

func (m *GetRequest) GetReadOnly() bool

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (dst *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []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"`
	NotFound             bool           `protobuf:"varint,4,opt,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetError 

func (m *GetResponse) GetError() *KeyError

func (*GetResponse) GetNotFound 

func (m *GetResponse) GetNotFound() bool

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (dst *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type HandleTime 

type HandleTime struct {
	WaitMs               int64    `protobuf:"varint,1,opt,name=wait_ms,json=waitMs,proto3" json:"wait_ms,omitempty"`
	ProcessMs            int64    `protobuf:"varint,2,opt,name=process_ms,json=processMs,proto3" json:"process_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleTime) Descriptor 

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

func (*HandleTime) GetProcessMs 

func (m *HandleTime) GetProcessMs() int64

func (*HandleTime) GetWaitMs 

func (m *HandleTime) GetWaitMs() int64

func (*HandleTime) Marshal 

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

func (*HandleTime) MarshalTo 

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

func (*HandleTime) ProtoMessage 

func (*HandleTime) ProtoMessage()

func (*HandleTime) Reset 

func (m *HandleTime) Reset()

func (*HandleTime) Size 

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

func (*HandleTime) String 

func (m *HandleTime) String() string

func (*HandleTime) Unmarshal 

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

func (*HandleTime) XXX_DiscardUnknown 

func (m *HandleTime) XXX_DiscardUnknown()

func (*HandleTime) XXX_Marshal 

func (m *HandleTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleTime) XXX_Merge 

func (dst *HandleTime) XXX_Merge(src proto.Message)

func (*HandleTime) XXX_Size 

func (m *HandleTime) XXX_Size() int

func (*HandleTime) XXX_Unmarshal 

func (m *HandleTime) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

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

func (*ImportRequest) XXX_DiscardUnknown 

func (m *ImportRequest) XXX_DiscardUnknown()

func (*ImportRequest) XXX_Marshal 

func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportRequest) XXX_Merge 

func (dst *ImportRequest) XXX_Merge(src proto.Message)

func (*ImportRequest) XXX_Size 

func (m *ImportRequest) XXX_Size() int

func (*ImportRequest) XXX_Unmarshal 

func (m *ImportRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*ImportResponse) XXX_DiscardUnknown 

func (m *ImportResponse) XXX_DiscardUnknown()

func (*ImportResponse) XXX_Marshal 

func (m *ImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportResponse) XXX_Merge 

func (dst *ImportResponse) XXX_Merge(src proto.Message)

func (*ImportResponse) XXX_Size 

func (m *ImportResponse) XXX_Size() int

func (*ImportResponse) XXX_Unmarshal 

func (m *ImportResponse) XXX_Unmarshal(b []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"`
	Conflict             *WriteConflict   `protobuf:"bytes,4,opt,name=conflict" json:"conflict,omitempty"`
	AlreadyExist         *AlreadyExist    `protobuf:"bytes,5,opt,name=already_exist,json=alreadyExist" json:"already_exist,omitempty"`
	Deadlock             *Deadlock        `protobuf:"bytes,6,opt,name=deadlock" json:"deadlock,omitempty"`
	CommitTsExpired      *CommitTsExpired `protobuf:"bytes,7,opt,name=commit_ts_expired,json=commitTsExpired" json:"commit_ts_expired,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*KeyError) Descriptor 

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

func (*KeyError) GetAbort 

func (m *KeyError) GetAbort() string

func (*KeyError) GetAlreadyExist 

func (m *KeyError) GetAlreadyExist() *AlreadyExist

func (*KeyError) GetCommitTsExpired 

func (m *KeyError) GetCommitTsExpired() *CommitTsExpired

func (*KeyError) GetConflict 

func (m *KeyError) GetConflict() *WriteConflict

func (*KeyError) GetDeadlock 

func (m *KeyError) GetDeadlock() *Deadlock

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

func (*KeyError) XXX_DiscardUnknown 

func (m *KeyError) XXX_DiscardUnknown()

func (*KeyError) XXX_Marshal 

func (m *KeyError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyError) XXX_Merge 

func (dst *KeyError) XXX_Merge(src proto.Message)

func (*KeyError) XXX_Size 

func (m *KeyError) XXX_Size() int

func (*KeyError) XXX_Unmarshal 

func (m *KeyError) XXX_Unmarshal(b []byte) error

type KeyRange 

type KeyRange struct {
	StartKey             []byte   `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyRange) Descriptor 

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

func (*KeyRange) GetEndKey 

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

func (*KeyRange) GetStartKey 

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

func (*KeyRange) Marshal 

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

func (*KeyRange) MarshalTo 

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

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset 

func (m *KeyRange) Reset()

func (*KeyRange) Size 

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

func (*KeyRange) String 

func (m *KeyRange) String() string

func (*KeyRange) Unmarshal 

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

func (*KeyRange) XXX_DiscardUnknown 

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal 

func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRange) XXX_Merge 

func (dst *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_Size 

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal 

func (m *KeyRange) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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

func (*KvPair) XXX_DiscardUnknown 

func (m *KvPair) XXX_DiscardUnknown()

func (*KvPair) XXX_Marshal 

func (m *KvPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KvPair) XXX_Merge 

func (dst *KvPair) XXX_Merge(src proto.Message)

func (*KvPair) XXX_Size 

func (m *KvPair) XXX_Size() int

func (*KvPair) XXX_Unmarshal 

func (m *KvPair) XXX_Unmarshal(b []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"`
	// How many keys this transaction involved.
	TxnSize              uint64   `protobuf:"varint,5,opt,name=txn_size,json=txnSize,proto3" json:"txn_size,omitempty"`
	LockType             Op       `protobuf:"varint,6,opt,name=lock_type,json=lockType,proto3,enum=kvrpcpb.Op" json:"lock_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetLockType 

func (m *LockInfo) GetLockType() Op

func (*LockInfo) GetLockVersion 

func (m *LockInfo) GetLockVersion() uint64

func (*LockInfo) GetPrimaryLock 

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

func (*LockInfo) GetTxnSize 

func (m *LockInfo) GetTxnSize() uint64

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

func (*LockInfo) XXX_DiscardUnknown 

func (m *LockInfo) XXX_DiscardUnknown()

func (*LockInfo) XXX_Marshal 

func (m *LockInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LockInfo) XXX_Merge 

func (dst *LockInfo) XXX_Merge(src proto.Message)

func (*LockInfo) XXX_Size 

func (m *LockInfo) XXX_Size() int

func (*LockInfo) XXX_Unmarshal 

func (m *LockInfo) XXX_Unmarshal(b []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"`
	Assertion            Assertion `protobuf:"varint,4,opt,name=assertion,proto3,enum=kvrpcpb.Assertion" json:"assertion,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Mutation) Descriptor 

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

func (*Mutation) GetAssertion 

func (m *Mutation) GetAssertion() Assertion

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

func (*Mutation) XXX_DiscardUnknown 

func (m *Mutation) XXX_DiscardUnknown()

func (*Mutation) XXX_Marshal 

func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mutation) XXX_Merge 

func (dst *Mutation) XXX_Merge(src proto.Message)

func (*Mutation) XXX_Size 

func (m *Mutation) XXX_Size() int

func (*Mutation) XXX_Unmarshal 

func (m *Mutation) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*MvccGetByKeyRequest) XXX_DiscardUnknown 

func (m *MvccGetByKeyRequest) XXX_DiscardUnknown()

func (*MvccGetByKeyRequest) XXX_Marshal 

func (m *MvccGetByKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccGetByKeyRequest) XXX_Merge 

func (dst *MvccGetByKeyRequest) XXX_Merge(src proto.Message)

func (*MvccGetByKeyRequest) XXX_Size 

func (m *MvccGetByKeyRequest) XXX_Size() int

func (*MvccGetByKeyRequest) XXX_Unmarshal 

func (m *MvccGetByKeyRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*MvccGetByKeyResponse) XXX_DiscardUnknown 

func (m *MvccGetByKeyResponse) XXX_DiscardUnknown()

func (*MvccGetByKeyResponse) XXX_Marshal 

func (m *MvccGetByKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccGetByKeyResponse) XXX_Merge 

func (dst *MvccGetByKeyResponse) XXX_Merge(src proto.Message)

func (*MvccGetByKeyResponse) XXX_Size 

func (m *MvccGetByKeyResponse) XXX_Size() int

func (*MvccGetByKeyResponse) XXX_Unmarshal 

func (m *MvccGetByKeyResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*MvccGetByStartTsRequest) XXX_DiscardUnknown 

func (m *MvccGetByStartTsRequest) XXX_DiscardUnknown()

func (*MvccGetByStartTsRequest) XXX_Marshal 

func (m *MvccGetByStartTsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccGetByStartTsRequest) XXX_Merge 

func (dst *MvccGetByStartTsRequest) XXX_Merge(src proto.Message)

func (*MvccGetByStartTsRequest) XXX_Size 

func (m *MvccGetByStartTsRequest) XXX_Size() int

func (*MvccGetByStartTsRequest) XXX_Unmarshal 

func (m *MvccGetByStartTsRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*MvccGetByStartTsResponse) XXX_DiscardUnknown 

func (m *MvccGetByStartTsResponse) XXX_DiscardUnknown()

func (*MvccGetByStartTsResponse) XXX_Marshal 

func (m *MvccGetByStartTsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccGetByStartTsResponse) XXX_Merge 

func (dst *MvccGetByStartTsResponse) XXX_Merge(src proto.Message)

func (*MvccGetByStartTsResponse) XXX_Size 

func (m *MvccGetByStartTsResponse) XXX_Size() int

func (*MvccGetByStartTsResponse) XXX_Unmarshal 

func (m *MvccGetByStartTsResponse) XXX_Unmarshal(b []byte) error

type MvccInfo 

type MvccInfo struct {
	Lock                 *MvccLock    `protobuf:"bytes,1,opt,name=lock" json:"lock,omitempty"`
	Writes               []*MvccWrite `protobuf:"bytes,2,rep,name=writes" json:"writes,omitempty"`
	Values               []*MvccValue `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MvccInfo) Descriptor 

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

func (*MvccInfo) GetLock 

func (m *MvccInfo) GetLock() *MvccLock

func (*MvccInfo) GetValues 

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

func (*MvccInfo) GetWrites 

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

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

func (*MvccInfo) XXX_DiscardUnknown 

func (m *MvccInfo) XXX_DiscardUnknown()

func (*MvccInfo) XXX_Marshal 

func (m *MvccInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccInfo) XXX_Merge 

func (dst *MvccInfo) XXX_Merge(src proto.Message)

func (*MvccInfo) XXX_Size 

func (m *MvccInfo) XXX_Size() int

func (*MvccInfo) XXX_Unmarshal 

func (m *MvccInfo) XXX_Unmarshal(b []byte) error

type MvccLock 

type MvccLock struct {
	Type                 Op       `protobuf:"varint,1,opt,name=type,proto3,enum=kvrpcpb.Op" json:"type,omitempty"`
	StartTs              uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Primary              []byte   `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	ShortValue           []byte   `protobuf:"bytes,4,opt,name=short_value,json=shortValue,proto3" json:"short_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MvccLock) Descriptor 

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

func (*MvccLock) GetPrimary 

func (m *MvccLock) GetPrimary() []byte

func (*MvccLock) GetShortValue 

func (m *MvccLock) GetShortValue() []byte

func (*MvccLock) GetStartTs 

func (m *MvccLock) GetStartTs() uint64

func (*MvccLock) GetType 

func (m *MvccLock) GetType() Op

func (*MvccLock) Marshal 

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

func (*MvccLock) MarshalTo 

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

func (*MvccLock) ProtoMessage 

func (*MvccLock) ProtoMessage()

func (*MvccLock) Reset 

func (m *MvccLock) Reset()

func (*MvccLock) Size 

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

func (*MvccLock) String 

func (m *MvccLock) String() string

func (*MvccLock) Unmarshal 

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

func (*MvccLock) XXX_DiscardUnknown 

func (m *MvccLock) XXX_DiscardUnknown()

func (*MvccLock) XXX_Marshal 

func (m *MvccLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccLock) XXX_Merge 

func (dst *MvccLock) XXX_Merge(src proto.Message)

func (*MvccLock) XXX_Size 

func (m *MvccLock) XXX_Size() int

func (*MvccLock) XXX_Unmarshal 

func (m *MvccLock) XXX_Unmarshal(b []byte) error

type MvccValue 

type MvccValue struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MvccValue) Descriptor 

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

func (*MvccValue) GetStartTs 

func (m *MvccValue) GetStartTs() uint64

func (*MvccValue) GetValue 

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

func (*MvccValue) Marshal 

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

func (*MvccValue) MarshalTo 

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

func (*MvccValue) ProtoMessage 

func (*MvccValue) ProtoMessage()

func (*MvccValue) Reset 

func (m *MvccValue) Reset()

func (*MvccValue) Size 

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

func (*MvccValue) String 

func (m *MvccValue) String() string

func (*MvccValue) Unmarshal 

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

func (*MvccValue) XXX_DiscardUnknown 

func (m *MvccValue) XXX_DiscardUnknown()

func (*MvccValue) XXX_Marshal 

func (m *MvccValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccValue) XXX_Merge 

func (dst *MvccValue) XXX_Merge(src proto.Message)

func (*MvccValue) XXX_Size 

func (m *MvccValue) XXX_Size() int

func (*MvccValue) XXX_Unmarshal 

func (m *MvccValue) XXX_Unmarshal(b []byte) error

type MvccWrite 

type MvccWrite struct {
	Type                 Op       `protobuf:"varint,1,opt,name=type,proto3,enum=kvrpcpb.Op" json:"type,omitempty"`
	StartTs              uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs             uint64   `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	ShortValue           []byte   `protobuf:"bytes,4,opt,name=short_value,json=shortValue,proto3" json:"short_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MvccWrite) Descriptor 

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

func (*MvccWrite) GetCommitTs 

func (m *MvccWrite) GetCommitTs() uint64

func (*MvccWrite) GetShortValue 

func (m *MvccWrite) GetShortValue() []byte

func (*MvccWrite) GetStartTs 

func (m *MvccWrite) GetStartTs() uint64

func (*MvccWrite) GetType 

func (m *MvccWrite) GetType() Op

func (*MvccWrite) Marshal 

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

func (*MvccWrite) MarshalTo 

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

func (*MvccWrite) ProtoMessage 

func (*MvccWrite) ProtoMessage()

func (*MvccWrite) Reset 

func (m *MvccWrite) Reset()

func (*MvccWrite) Size 

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

func (*MvccWrite) String 

func (m *MvccWrite) String() string

func (*MvccWrite) Unmarshal 

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

func (*MvccWrite) XXX_DiscardUnknown 

func (m *MvccWrite) XXX_DiscardUnknown()

func (*MvccWrite) XXX_Marshal 

func (m *MvccWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MvccWrite) XXX_Merge 

func (dst *MvccWrite) XXX_Merge(src proto.Message)

func (*MvccWrite) XXX_Size 

func (m *MvccWrite) XXX_Size() int

func (*MvccWrite) XXX_Unmarshal 

func (m *MvccWrite) XXX_Unmarshal(b []byte) error

type Op 

type Op int32
const (
	Op_Put      Op = 0
	Op_Del      Op = 1
	Op_Lock     Op = 2
	Op_Rollback Op = 3
	// insert operation has a constraint that key should not exist before.
	Op_Insert          Op = 4
	Op_PessimisticLock Op = 5
)

func (Op) EnumDescriptor 

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

func (Op) String 

func (x Op) String() string

type PessimisticLockRequest 

type PessimisticLockRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	// In this case the Op of the mutation must be Lock.
	Mutations    []*Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
	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"`
	ForUpdateTs  uint64      `protobuf:"varint,6,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
	// If the request is the first lock request, we don't need to detect deadlock.
	IsFirstLock bool `protobuf:"varint,7,opt,name=is_first_lock,json=isFirstLock,proto3" json:"is_first_lock,omitempty"`
	// Time to wait for lock released in milliseconds when encountering locks
	WaitTimeout          uint64   `protobuf:"varint,8,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PessimisticLockRequest) Descriptor 

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

func (*PessimisticLockRequest) GetContext 

func (m *PessimisticLockRequest) GetContext() *Context

func (*PessimisticLockRequest) GetForUpdateTs 

func (m *PessimisticLockRequest) GetForUpdateTs() uint64

func (*PessimisticLockRequest) GetIsFirstLock 

func (m *PessimisticLockRequest) GetIsFirstLock() bool

func (*PessimisticLockRequest) GetLockTtl 

func (m *PessimisticLockRequest) GetLockTtl() uint64

func (*PessimisticLockRequest) GetMutations 

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

func (*PessimisticLockRequest) GetPrimaryLock 

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

func (*PessimisticLockRequest) GetStartVersion 

func (m *PessimisticLockRequest) GetStartVersion() uint64

func (*PessimisticLockRequest) GetWaitTimeout 

func (m *PessimisticLockRequest) GetWaitTimeout() uint64

func (*PessimisticLockRequest) Marshal 

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

func (*PessimisticLockRequest) MarshalTo 

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

func (*PessimisticLockRequest) ProtoMessage 

func (*PessimisticLockRequest) ProtoMessage()

func (*PessimisticLockRequest) Reset 

func (m *PessimisticLockRequest) Reset()

func (*PessimisticLockRequest) Size 

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

func (*PessimisticLockRequest) String 

func (m *PessimisticLockRequest) String() string

func (*PessimisticLockRequest) Unmarshal 

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

func (*PessimisticLockRequest) XXX_DiscardUnknown 

func (m *PessimisticLockRequest) XXX_DiscardUnknown()

func (*PessimisticLockRequest) XXX_Marshal 

func (m *PessimisticLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PessimisticLockRequest) XXX_Merge 

func (dst *PessimisticLockRequest) XXX_Merge(src proto.Message)

func (*PessimisticLockRequest) XXX_Size 

func (m *PessimisticLockRequest) XXX_Size() int

func (*PessimisticLockRequest) XXX_Unmarshal 

func (m *PessimisticLockRequest) XXX_Unmarshal(b []byte) error

type PessimisticLockResponse 

type PessimisticLockResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PessimisticLockResponse) Descriptor 

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

func (*PessimisticLockResponse) GetErrors 

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

func (*PessimisticLockResponse) GetRegionError 

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

func (*PessimisticLockResponse) Marshal 

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

func (*PessimisticLockResponse) MarshalTo 

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

func (*PessimisticLockResponse) ProtoMessage 

func (*PessimisticLockResponse) ProtoMessage()

func (*PessimisticLockResponse) Reset 

func (m *PessimisticLockResponse) Reset()

func (*PessimisticLockResponse) Size 

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

func (*PessimisticLockResponse) String 

func (m *PessimisticLockResponse) String() string

func (*PessimisticLockResponse) Unmarshal 

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

func (*PessimisticLockResponse) XXX_DiscardUnknown 

func (m *PessimisticLockResponse) XXX_DiscardUnknown()

func (*PessimisticLockResponse) XXX_Marshal 

func (m *PessimisticLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PessimisticLockResponse) XXX_Merge 

func (dst *PessimisticLockResponse) XXX_Merge(src proto.Message)

func (*PessimisticLockResponse) XXX_Size 

func (m *PessimisticLockResponse) XXX_Size() int

func (*PessimisticLockResponse) XXX_Unmarshal 

func (m *PessimisticLockResponse) XXX_Unmarshal(b []byte) error

type PessimisticRollbackRequest 

type PessimisticRollbackRequest 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"`
	ForUpdateTs          uint64   `protobuf:"varint,3,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,4,rep,name=keys" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PessimisticRollbackRequest) Descriptor 

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

func (*PessimisticRollbackRequest) GetContext 

func (m *PessimisticRollbackRequest) GetContext() *Context

func (*PessimisticRollbackRequest) GetForUpdateTs 

func (m *PessimisticRollbackRequest) GetForUpdateTs() uint64

func (*PessimisticRollbackRequest) GetKeys 

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

func (*PessimisticRollbackRequest) GetStartVersion 

func (m *PessimisticRollbackRequest) GetStartVersion() uint64

func (*PessimisticRollbackRequest) Marshal 

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

func (*PessimisticRollbackRequest) MarshalTo 

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

func (*PessimisticRollbackRequest) ProtoMessage 

func (*PessimisticRollbackRequest) ProtoMessage()

func (*PessimisticRollbackRequest) Reset 

func (m *PessimisticRollbackRequest) Reset()

func (*PessimisticRollbackRequest) Size 

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

func (*PessimisticRollbackRequest) String 

func (m *PessimisticRollbackRequest) String() string

func (*PessimisticRollbackRequest) Unmarshal 

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

func (*PessimisticRollbackRequest) XXX_DiscardUnknown 

func (m *PessimisticRollbackRequest) XXX_DiscardUnknown()

func (*PessimisticRollbackRequest) XXX_Marshal 

func (m *PessimisticRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PessimisticRollbackRequest) XXX_Merge 

func (dst *PessimisticRollbackRequest) XXX_Merge(src proto.Message)

func (*PessimisticRollbackRequest) XXX_Size 

func (m *PessimisticRollbackRequest) XXX_Size() int

func (*PessimisticRollbackRequest) XXX_Unmarshal 

func (m *PessimisticRollbackRequest) XXX_Unmarshal(b []byte) error

type PessimisticRollbackResponse 

type PessimisticRollbackResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PessimisticRollbackResponse) Descriptor 

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

func (*PessimisticRollbackResponse) GetErrors 

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

func (*PessimisticRollbackResponse) GetRegionError 

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

func (*PessimisticRollbackResponse) Marshal 

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

func (*PessimisticRollbackResponse) MarshalTo 

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

func (*PessimisticRollbackResponse) ProtoMessage 

func (*PessimisticRollbackResponse) ProtoMessage()

func (*PessimisticRollbackResponse) Reset 

func (m *PessimisticRollbackResponse) Reset()

func (*PessimisticRollbackResponse) Size 

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

func (*PessimisticRollbackResponse) String 

func (m *PessimisticRollbackResponse) String() string

func (*PessimisticRollbackResponse) Unmarshal 

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

func (*PessimisticRollbackResponse) XXX_DiscardUnknown 

func (m *PessimisticRollbackResponse) XXX_DiscardUnknown()

func (*PessimisticRollbackResponse) XXX_Marshal 

func (m *PessimisticRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PessimisticRollbackResponse) XXX_Merge 

func (dst *PessimisticRollbackResponse) XXX_Merge(src proto.Message)

func (*PessimisticRollbackResponse) XXX_Size 

func (m *PessimisticRollbackResponse) XXX_Size() int

func (*PessimisticRollbackResponse) XXX_Unmarshal 

func (m *PessimisticRollbackResponse) XXX_Unmarshal(b []byte) error

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"`
	// For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
	IsPessimisticLock []bool `protobuf:"varint,7,rep,packed,name=is_pessimistic_lock,json=isPessimisticLock" json:"is_pessimistic_lock,omitempty"`
	// How many keys this transaction involved.
	TxnSize uint64 `protobuf:"varint,8,opt,name=txn_size,json=txnSize,proto3" json:"txn_size,omitempty"`
	// Use for pessimistic transaction, used to check if a conflict lock is already committed.
	ForUpdateTs uint64 `protobuf:"varint,9,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
	// If min_commit_ts > 0, this is large transaction proto, the final commit_ts
	// would be infered from min_commit_ts.
	MinCommitTs          uint64   `protobuf:"varint,10,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
	CoordinatorId        uint64   `protobuf:"varint,11,opt,name=coordinator_id,json=coordinatorId,proto3" json:"coordinator_id,omitempty"`
	Participants         [][]byte `protobuf:"bytes,12,rep,name=participants" json:"participants,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrewriteRequest) Descriptor 

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

func (*PrewriteRequest) GetContext 

func (m *PrewriteRequest) GetContext() *Context

func (*PrewriteRequest) GetCoordinatorId 

func (m *PrewriteRequest) GetCoordinatorId() uint64

func (*PrewriteRequest) GetForUpdateTs 

func (m *PrewriteRequest) GetForUpdateTs() uint64

func (*PrewriteRequest) GetIsPessimisticLock 

func (m *PrewriteRequest) GetIsPessimisticLock() []bool

func (*PrewriteRequest) GetLockTtl 

func (m *PrewriteRequest) GetLockTtl() uint64

func (*PrewriteRequest) GetMinCommitTs 

func (m *PrewriteRequest) GetMinCommitTs() uint64

func (*PrewriteRequest) GetMutations 

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

func (*PrewriteRequest) GetParticipants 

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

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) GetTxnSize 

func (m *PrewriteRequest) GetTxnSize() 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

func (*PrewriteRequest) XXX_DiscardUnknown 

func (m *PrewriteRequest) XXX_DiscardUnknown()

func (*PrewriteRequest) XXX_Marshal 

func (m *PrewriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrewriteRequest) XXX_Merge 

func (dst *PrewriteRequest) XXX_Merge(src proto.Message)

func (*PrewriteRequest) XXX_Size 

func (m *PrewriteRequest) XXX_Size() int

func (*PrewriteRequest) XXX_Unmarshal 

func (m *PrewriteRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*PrewriteResponse) XXX_DiscardUnknown 

func (m *PrewriteResponse) XXX_DiscardUnknown()

func (*PrewriteResponse) XXX_Marshal 

func (m *PrewriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrewriteResponse) XXX_Merge 

func (dst *PrewriteResponse) XXX_Merge(src proto.Message)

func (*PrewriteResponse) XXX_Size 

func (m *PrewriteResponse) XXX_Size() int

func (*PrewriteResponse) XXX_Unmarshal 

func (m *PrewriteResponse) XXX_Unmarshal(b []byte) error

type RawBatchDeleteRequest 

type RawBatchDeleteRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawBatchDeleteRequest) Descriptor 

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

func (*RawBatchDeleteRequest) GetCf 

func (m *RawBatchDeleteRequest) GetCf() string

func (*RawBatchDeleteRequest) GetContext 

func (m *RawBatchDeleteRequest) GetContext() *Context

func (*RawBatchDeleteRequest) GetKeys 

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

func (*RawBatchDeleteRequest) Marshal 

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

func (*RawBatchDeleteRequest) MarshalTo 

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

func (*RawBatchDeleteRequest) ProtoMessage 

func (*RawBatchDeleteRequest) ProtoMessage()

func (*RawBatchDeleteRequest) Reset 

func (m *RawBatchDeleteRequest) Reset()

func (*RawBatchDeleteRequest) Size 

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

func (*RawBatchDeleteRequest) String 

func (m *RawBatchDeleteRequest) String() string

func (*RawBatchDeleteRequest) Unmarshal 

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

func (*RawBatchDeleteRequest) XXX_DiscardUnknown 

func (m *RawBatchDeleteRequest) XXX_DiscardUnknown()

func (*RawBatchDeleteRequest) XXX_Marshal 

func (m *RawBatchDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchDeleteRequest) XXX_Merge 

func (dst *RawBatchDeleteRequest) XXX_Merge(src proto.Message)

func (*RawBatchDeleteRequest) XXX_Size 

func (m *RawBatchDeleteRequest) XXX_Size() int

func (*RawBatchDeleteRequest) XXX_Unmarshal 

func (m *RawBatchDeleteRequest) XXX_Unmarshal(b []byte) error

type RawBatchDeleteResponse 

type RawBatchDeleteResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawBatchDeleteResponse) Descriptor 

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

func (*RawBatchDeleteResponse) GetError 

func (m *RawBatchDeleteResponse) GetError() string

func (*RawBatchDeleteResponse) GetRegionError 

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

func (*RawBatchDeleteResponse) Marshal 

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

func (*RawBatchDeleteResponse) MarshalTo 

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

func (*RawBatchDeleteResponse) ProtoMessage 

func (*RawBatchDeleteResponse) ProtoMessage()

func (*RawBatchDeleteResponse) Reset 

func (m *RawBatchDeleteResponse) Reset()

func (*RawBatchDeleteResponse) Size 

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

func (*RawBatchDeleteResponse) String 

func (m *RawBatchDeleteResponse) String() string

func (*RawBatchDeleteResponse) Unmarshal 

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

func (*RawBatchDeleteResponse) XXX_DiscardUnknown 

func (m *RawBatchDeleteResponse) XXX_DiscardUnknown()

func (*RawBatchDeleteResponse) XXX_Marshal 

func (m *RawBatchDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchDeleteResponse) XXX_Merge 

func (dst *RawBatchDeleteResponse) XXX_Merge(src proto.Message)

func (*RawBatchDeleteResponse) XXX_Size 

func (m *RawBatchDeleteResponse) XXX_Size() int

func (*RawBatchDeleteResponse) XXX_Unmarshal 

func (m *RawBatchDeleteResponse) XXX_Unmarshal(b []byte) error

type RawBatchGetRequest 

type RawBatchGetRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawBatchGetRequest) Descriptor 

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

func (*RawBatchGetRequest) GetCf 

func (m *RawBatchGetRequest) GetCf() string

func (*RawBatchGetRequest) GetContext 

func (m *RawBatchGetRequest) GetContext() *Context

func (*RawBatchGetRequest) GetKeys 

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

func (*RawBatchGetRequest) Marshal 

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

func (*RawBatchGetRequest) MarshalTo 

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

func (*RawBatchGetRequest) ProtoMessage 

func (*RawBatchGetRequest) ProtoMessage()

func (*RawBatchGetRequest) Reset 

func (m *RawBatchGetRequest) Reset()

func (*RawBatchGetRequest) Size 

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

func (*RawBatchGetRequest) String 

func (m *RawBatchGetRequest) String() string

func (*RawBatchGetRequest) Unmarshal 

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

func (*RawBatchGetRequest) XXX_DiscardUnknown 

func (m *RawBatchGetRequest) XXX_DiscardUnknown()

func (*RawBatchGetRequest) XXX_Marshal 

func (m *RawBatchGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchGetRequest) XXX_Merge 

func (dst *RawBatchGetRequest) XXX_Merge(src proto.Message)

func (*RawBatchGetRequest) XXX_Size 

func (m *RawBatchGetRequest) XXX_Size() int

func (*RawBatchGetRequest) XXX_Unmarshal 

func (m *RawBatchGetRequest) XXX_Unmarshal(b []byte) error

type RawBatchGetResponse 

type RawBatchGetResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawBatchGetResponse) Descriptor 

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

func (*RawBatchGetResponse) GetPairs 

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

func (*RawBatchGetResponse) GetRegionError 

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

func (*RawBatchGetResponse) Marshal 

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

func (*RawBatchGetResponse) MarshalTo 

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

func (*RawBatchGetResponse) ProtoMessage 

func (*RawBatchGetResponse) ProtoMessage()

func (*RawBatchGetResponse) Reset 

func (m *RawBatchGetResponse) Reset()

func (*RawBatchGetResponse) Size 

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

func (*RawBatchGetResponse) String 

func (m *RawBatchGetResponse) String() string

func (*RawBatchGetResponse) Unmarshal 

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

func (*RawBatchGetResponse) XXX_DiscardUnknown 

func (m *RawBatchGetResponse) XXX_DiscardUnknown()

func (*RawBatchGetResponse) XXX_Marshal 

func (m *RawBatchGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchGetResponse) XXX_Merge 

func (dst *RawBatchGetResponse) XXX_Merge(src proto.Message)

func (*RawBatchGetResponse) XXX_Size 

func (m *RawBatchGetResponse) XXX_Size() int

func (*RawBatchGetResponse) XXX_Unmarshal 

func (m *RawBatchGetResponse) XXX_Unmarshal(b []byte) error

type RawBatchPutRequest 

type RawBatchPutRequest struct {
	Context              *Context  `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Pairs                []*KvPair `protobuf:"bytes,2,rep,name=pairs" json:"pairs,omitempty"`
	Cf                   string    `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RawBatchPutRequest) Descriptor 

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

func (*RawBatchPutRequest) GetCf 

func (m *RawBatchPutRequest) GetCf() string

func (*RawBatchPutRequest) GetContext 

func (m *RawBatchPutRequest) GetContext() *Context

func (*RawBatchPutRequest) GetPairs 

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

func (*RawBatchPutRequest) Marshal 

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

func (*RawBatchPutRequest) MarshalTo 

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

func (*RawBatchPutRequest) ProtoMessage 

func (*RawBatchPutRequest) ProtoMessage()

func (*RawBatchPutRequest) Reset 

func (m *RawBatchPutRequest) Reset()

func (*RawBatchPutRequest) Size 

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

func (*RawBatchPutRequest) String 

func (m *RawBatchPutRequest) String() string

func (*RawBatchPutRequest) Unmarshal 

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

func (*RawBatchPutRequest) XXX_DiscardUnknown 

func (m *RawBatchPutRequest) XXX_DiscardUnknown()

func (*RawBatchPutRequest) XXX_Marshal 

func (m *RawBatchPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchPutRequest) XXX_Merge 

func (dst *RawBatchPutRequest) XXX_Merge(src proto.Message)

func (*RawBatchPutRequest) XXX_Size 

func (m *RawBatchPutRequest) XXX_Size() int

func (*RawBatchPutRequest) XXX_Unmarshal 

func (m *RawBatchPutRequest) XXX_Unmarshal(b []byte) error

type RawBatchPutResponse 

type RawBatchPutResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawBatchPutResponse) Descriptor 

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

func (*RawBatchPutResponse) GetError 

func (m *RawBatchPutResponse) GetError() string

func (*RawBatchPutResponse) GetRegionError 

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

func (*RawBatchPutResponse) Marshal 

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

func (*RawBatchPutResponse) MarshalTo 

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

func (*RawBatchPutResponse) ProtoMessage 

func (*RawBatchPutResponse) ProtoMessage()

func (*RawBatchPutResponse) Reset 

func (m *RawBatchPutResponse) Reset()

func (*RawBatchPutResponse) Size 

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

func (*RawBatchPutResponse) String 

func (m *RawBatchPutResponse) String() string

func (*RawBatchPutResponse) Unmarshal 

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

func (*RawBatchPutResponse) XXX_DiscardUnknown 

func (m *RawBatchPutResponse) XXX_DiscardUnknown()

func (*RawBatchPutResponse) XXX_Marshal 

func (m *RawBatchPutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchPutResponse) XXX_Merge 

func (dst *RawBatchPutResponse) XXX_Merge(src proto.Message)

func (*RawBatchPutResponse) XXX_Size 

func (m *RawBatchPutResponse) XXX_Size() int

func (*RawBatchPutResponse) XXX_Unmarshal 

func (m *RawBatchPutResponse) XXX_Unmarshal(b []byte) error

type RawBatchScanRequest 

type RawBatchScanRequest struct {
	Context              *Context    `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Ranges               []*KeyRange `protobuf:"bytes,2,rep,name=ranges" json:"ranges,omitempty"`
	EachLimit            uint32      `protobuf:"varint,3,opt,name=each_limit,json=eachLimit,proto3" json:"each_limit,omitempty"`
	KeyOnly              bool        `protobuf:"varint,4,opt,name=key_only,json=keyOnly,proto3" json:"key_only,omitempty"`
	Cf                   string      `protobuf:"bytes,5,opt,name=cf,proto3" json:"cf,omitempty"`
	Reverse              bool        `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RawBatchScanRequest) Descriptor 

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

func (*RawBatchScanRequest) GetCf 

func (m *RawBatchScanRequest) GetCf() string

func (*RawBatchScanRequest) GetContext 

func (m *RawBatchScanRequest) GetContext() *Context

func (*RawBatchScanRequest) GetEachLimit 

func (m *RawBatchScanRequest) GetEachLimit() uint32

func (*RawBatchScanRequest) GetKeyOnly 

func (m *RawBatchScanRequest) GetKeyOnly() bool

func (*RawBatchScanRequest) GetRanges 

func (m *RawBatchScanRequest) GetRanges() []*KeyRange

func (*RawBatchScanRequest) GetReverse 

func (m *RawBatchScanRequest) GetReverse() bool

func (*RawBatchScanRequest) Marshal 

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

func (*RawBatchScanRequest) MarshalTo 

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

func (*RawBatchScanRequest) ProtoMessage 

func (*RawBatchScanRequest) ProtoMessage()

func (*RawBatchScanRequest) Reset 

func (m *RawBatchScanRequest) Reset()

func (*RawBatchScanRequest) Size 

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

func (*RawBatchScanRequest) String 

func (m *RawBatchScanRequest) String() string

func (*RawBatchScanRequest) Unmarshal 

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

func (*RawBatchScanRequest) XXX_DiscardUnknown 

func (m *RawBatchScanRequest) XXX_DiscardUnknown()

func (*RawBatchScanRequest) XXX_Marshal 

func (m *RawBatchScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchScanRequest) XXX_Merge 

func (dst *RawBatchScanRequest) XXX_Merge(src proto.Message)

func (*RawBatchScanRequest) XXX_Size 

func (m *RawBatchScanRequest) XXX_Size() int

func (*RawBatchScanRequest) XXX_Unmarshal 

func (m *RawBatchScanRequest) XXX_Unmarshal(b []byte) error

type RawBatchScanResponse 

type RawBatchScanResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawBatchScanResponse) Descriptor 

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

func (*RawBatchScanResponse) GetKvs 

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

func (*RawBatchScanResponse) GetRegionError 

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

func (*RawBatchScanResponse) Marshal 

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

func (*RawBatchScanResponse) MarshalTo 

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

func (*RawBatchScanResponse) ProtoMessage 

func (*RawBatchScanResponse) ProtoMessage()

func (*RawBatchScanResponse) Reset 

func (m *RawBatchScanResponse) Reset()

func (*RawBatchScanResponse) Size 

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

func (*RawBatchScanResponse) String 

func (m *RawBatchScanResponse) String() string

func (*RawBatchScanResponse) Unmarshal 

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

func (*RawBatchScanResponse) XXX_DiscardUnknown 

func (m *RawBatchScanResponse) XXX_DiscardUnknown()

func (*RawBatchScanResponse) XXX_Marshal 

func (m *RawBatchScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawBatchScanResponse) XXX_Merge 

func (dst *RawBatchScanResponse) XXX_Merge(src proto.Message)

func (*RawBatchScanResponse) XXX_Size 

func (m *RawBatchScanResponse) XXX_Size() int

func (*RawBatchScanResponse) XXX_Unmarshal 

func (m *RawBatchScanResponse) XXX_Unmarshal(b []byte) error

type RawDeleteRangeRequest 

type RawDeleteRangeRequest 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"`
	Cf                   string   `protobuf:"bytes,4,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawDeleteRangeRequest) Descriptor 

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

func (*RawDeleteRangeRequest) GetCf 

func (m *RawDeleteRangeRequest) GetCf() string

func (*RawDeleteRangeRequest) GetContext 

func (m *RawDeleteRangeRequest) GetContext() *Context

func (*RawDeleteRangeRequest) GetEndKey 

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

func (*RawDeleteRangeRequest) GetStartKey 

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

func (*RawDeleteRangeRequest) Marshal 

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

func (*RawDeleteRangeRequest) MarshalTo 

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

func (*RawDeleteRangeRequest) ProtoMessage 

func (*RawDeleteRangeRequest) ProtoMessage()

func (*RawDeleteRangeRequest) Reset 

func (m *RawDeleteRangeRequest) Reset()

func (*RawDeleteRangeRequest) Size 

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

func (*RawDeleteRangeRequest) String 

func (m *RawDeleteRangeRequest) String() string

func (*RawDeleteRangeRequest) Unmarshal 

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

func (*RawDeleteRangeRequest) XXX_DiscardUnknown 

func (m *RawDeleteRangeRequest) XXX_DiscardUnknown()

func (*RawDeleteRangeRequest) XXX_Marshal 

func (m *RawDeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawDeleteRangeRequest) XXX_Merge 

func (dst *RawDeleteRangeRequest) XXX_Merge(src proto.Message)

func (*RawDeleteRangeRequest) XXX_Size 

func (m *RawDeleteRangeRequest) XXX_Size() int

func (*RawDeleteRangeRequest) XXX_Unmarshal 

func (m *RawDeleteRangeRequest) XXX_Unmarshal(b []byte) error

type RawDeleteRangeResponse 

type RawDeleteRangeResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawDeleteRangeResponse) Descriptor 

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

func (*RawDeleteRangeResponse) GetError 

func (m *RawDeleteRangeResponse) GetError() string

func (*RawDeleteRangeResponse) GetRegionError 

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

func (*RawDeleteRangeResponse) Marshal 

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

func (*RawDeleteRangeResponse) MarshalTo 

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

func (*RawDeleteRangeResponse) ProtoMessage 

func (*RawDeleteRangeResponse) ProtoMessage()

func (*RawDeleteRangeResponse) Reset 

func (m *RawDeleteRangeResponse) Reset()

func (*RawDeleteRangeResponse) Size 

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

func (*RawDeleteRangeResponse) String 

func (m *RawDeleteRangeResponse) String() string

func (*RawDeleteRangeResponse) Unmarshal 

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

func (*RawDeleteRangeResponse) XXX_DiscardUnknown 

func (m *RawDeleteRangeResponse) XXX_DiscardUnknown()

func (*RawDeleteRangeResponse) XXX_Marshal 

func (m *RawDeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawDeleteRangeResponse) XXX_Merge 

func (dst *RawDeleteRangeResponse) XXX_Merge(src proto.Message)

func (*RawDeleteRangeResponse) XXX_Size 

func (m *RawDeleteRangeResponse) XXX_Size() int

func (*RawDeleteRangeResponse) XXX_Unmarshal 

func (m *RawDeleteRangeResponse) XXX_Unmarshal(b []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"`
	Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawDeleteRequest) Descriptor 

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

func (*RawDeleteRequest) GetCf 

func (m *RawDeleteRequest) GetCf() string

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

func (*RawDeleteRequest) XXX_DiscardUnknown 

func (m *RawDeleteRequest) XXX_DiscardUnknown()

func (*RawDeleteRequest) XXX_Marshal 

func (m *RawDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawDeleteRequest) XXX_Merge 

func (dst *RawDeleteRequest) XXX_Merge(src proto.Message)

func (*RawDeleteRequest) XXX_Size 

func (m *RawDeleteRequest) XXX_Size() int

func (*RawDeleteRequest) XXX_Unmarshal 

func (m *RawDeleteRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*RawDeleteResponse) XXX_DiscardUnknown 

func (m *RawDeleteResponse) XXX_DiscardUnknown()

func (*RawDeleteResponse) XXX_Marshal 

func (m *RawDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawDeleteResponse) XXX_Merge 

func (dst *RawDeleteResponse) XXX_Merge(src proto.Message)

func (*RawDeleteResponse) XXX_Size 

func (m *RawDeleteResponse) XXX_Size() int

func (*RawDeleteResponse) XXX_Unmarshal 

func (m *RawDeleteResponse) XXX_Unmarshal(b []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"`
	Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawGetRequest) Descriptor 

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

func (*RawGetRequest) GetCf 

func (m *RawGetRequest) GetCf() string

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

func (*RawGetRequest) XXX_DiscardUnknown 

func (m *RawGetRequest) XXX_DiscardUnknown()

func (*RawGetRequest) XXX_Marshal 

func (m *RawGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawGetRequest) XXX_Merge 

func (dst *RawGetRequest) XXX_Merge(src proto.Message)

func (*RawGetRequest) XXX_Size 

func (m *RawGetRequest) XXX_Size() int

func (*RawGetRequest) XXX_Unmarshal 

func (m *RawGetRequest) XXX_Unmarshal(b []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"`
	NotFound             bool           `protobuf:"varint,4,opt,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RawGetResponse) Descriptor 

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

func (*RawGetResponse) GetError 

func (m *RawGetResponse) GetError() string

func (*RawGetResponse) GetNotFound 

func (m *RawGetResponse) GetNotFound() bool

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

func (*RawGetResponse) XXX_DiscardUnknown 

func (m *RawGetResponse) XXX_DiscardUnknown()

func (*RawGetResponse) XXX_Marshal 

func (m *RawGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawGetResponse) XXX_Merge 

func (dst *RawGetResponse) XXX_Merge(src proto.Message)

func (*RawGetResponse) XXX_Size 

func (m *RawGetResponse) XXX_Size() int

func (*RawGetResponse) XXX_Unmarshal 

func (m *RawGetResponse) XXX_Unmarshal(b []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"`
	Cf                   string   `protobuf:"bytes,4,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawPutRequest) Descriptor 

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

func (*RawPutRequest) GetCf 

func (m *RawPutRequest) GetCf() string

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

func (*RawPutRequest) XXX_DiscardUnknown 

func (m *RawPutRequest) XXX_DiscardUnknown()

func (*RawPutRequest) XXX_Marshal 

func (m *RawPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawPutRequest) XXX_Merge 

func (dst *RawPutRequest) XXX_Merge(src proto.Message)

func (*RawPutRequest) XXX_Size 

func (m *RawPutRequest) XXX_Size() int

func (*RawPutRequest) XXX_Unmarshal 

func (m *RawPutRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*RawPutResponse) XXX_DiscardUnknown 

func (m *RawPutResponse) XXX_DiscardUnknown()

func (*RawPutResponse) XXX_Marshal 

func (m *RawPutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawPutResponse) XXX_Merge 

func (dst *RawPutResponse) XXX_Merge(src proto.Message)

func (*RawPutResponse) XXX_Size 

func (m *RawPutResponse) XXX_Size() int

func (*RawPutResponse) XXX_Unmarshal 

func (m *RawPutResponse) XXX_Unmarshal(b []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"`
	KeyOnly  bool     `protobuf:"varint,4,opt,name=key_only,json=keyOnly,proto3" json:"key_only,omitempty"`
	Cf       string   `protobuf:"bytes,5,opt,name=cf,proto3" json:"cf,omitempty"`
	Reverse  bool     `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// For compatibility, when scanning forward, the range to scan is [start_key, end_key), where start_key < end_key;
	// and when scanning backward, it scans [end_key, start_key) in descending order, where end_key < start_key.
	EndKey               []byte   `protobuf:"bytes,7,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawScanRequest) Descriptor 

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

func (*RawScanRequest) GetCf 

func (m *RawScanRequest) GetCf() string

func (*RawScanRequest) GetContext 

func (m *RawScanRequest) GetContext() *Context

func (*RawScanRequest) GetEndKey 

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

func (*RawScanRequest) GetKeyOnly 

func (m *RawScanRequest) GetKeyOnly() bool

func (*RawScanRequest) GetLimit 

func (m *RawScanRequest) GetLimit() uint32

func (*RawScanRequest) GetReverse 

func (m *RawScanRequest) GetReverse() bool

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

func (*RawScanRequest) XXX_DiscardUnknown 

func (m *RawScanRequest) XXX_DiscardUnknown()

func (*RawScanRequest) XXX_Marshal 

func (m *RawScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawScanRequest) XXX_Merge 

func (dst *RawScanRequest) XXX_Merge(src proto.Message)

func (*RawScanRequest) XXX_Size 

func (m *RawScanRequest) XXX_Size() int

func (*RawScanRequest) XXX_Unmarshal 

func (m *RawScanRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*RawScanResponse) XXX_DiscardUnknown 

func (m *RawScanResponse) XXX_DiscardUnknown()

func (*RawScanResponse) XXX_Marshal 

func (m *RawScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawScanResponse) XXX_Merge 

func (dst *RawScanResponse) XXX_Merge(src proto.Message)

func (*RawScanResponse) XXX_Size 

func (m *RawScanResponse) XXX_Size() int

func (*RawScanResponse) XXX_Unmarshal 

func (m *RawScanResponse) XXX_Unmarshal(b []byte) error

type ReadIndexRequest 

type ReadIndexRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadIndexRequest) Descriptor 

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

func (*ReadIndexRequest) GetContext 

func (m *ReadIndexRequest) GetContext() *Context

func (*ReadIndexRequest) Marshal 

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

func (*ReadIndexRequest) MarshalTo 

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

func (*ReadIndexRequest) ProtoMessage 

func (*ReadIndexRequest) ProtoMessage()

func (*ReadIndexRequest) Reset 

func (m *ReadIndexRequest) Reset()

func (*ReadIndexRequest) Size 

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

func (*ReadIndexRequest) String 

func (m *ReadIndexRequest) String() string

func (*ReadIndexRequest) Unmarshal 

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

func (*ReadIndexRequest) XXX_DiscardUnknown 

func (m *ReadIndexRequest) XXX_DiscardUnknown()

func (*ReadIndexRequest) XXX_Marshal 

func (m *ReadIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadIndexRequest) XXX_Merge 

func (dst *ReadIndexRequest) XXX_Merge(src proto.Message)

func (*ReadIndexRequest) XXX_Size 

func (m *ReadIndexRequest) XXX_Size() int

func (*ReadIndexRequest) XXX_Unmarshal 

func (m *ReadIndexRequest) XXX_Unmarshal(b []byte) error

type ReadIndexResponse 

type ReadIndexResponse struct {
	RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	ReadIndex            uint64         `protobuf:"varint,2,opt,name=read_index,json=readIndex,proto3" json:"read_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ReadIndexResponse) Descriptor 

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

func (*ReadIndexResponse) GetReadIndex 

func (m *ReadIndexResponse) GetReadIndex() uint64

func (*ReadIndexResponse) GetRegionError 

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

func (*ReadIndexResponse) Marshal 

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

func (*ReadIndexResponse) MarshalTo 

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

func (*ReadIndexResponse) ProtoMessage 

func (*ReadIndexResponse) ProtoMessage()

func (*ReadIndexResponse) Reset 

func (m *ReadIndexResponse) Reset()

func (*ReadIndexResponse) Size 

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

func (*ReadIndexResponse) String 

func (m *ReadIndexResponse) String() string

func (*ReadIndexResponse) Unmarshal 

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

func (*ReadIndexResponse) XXX_DiscardUnknown 

func (m *ReadIndexResponse) XXX_DiscardUnknown()

func (*ReadIndexResponse) XXX_Marshal 

func (m *ReadIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadIndexResponse) XXX_Merge 

func (dst *ReadIndexResponse) XXX_Merge(src proto.Message)

func (*ReadIndexResponse) XXX_Size 

func (m *ReadIndexResponse) XXX_Size() int

func (*ReadIndexResponse) XXX_Unmarshal 

func (m *ReadIndexResponse) XXX_Unmarshal(b []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"`
	TxnInfos      []*TxnInfo `protobuf:"bytes,4,rep,name=txn_infos,json=txnInfos" json:"txn_infos,omitempty"`
	// Only resolve specified keys.
	Keys                 [][]byte `protobuf:"bytes,5,rep,name=keys" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetKeys 

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

func (*ResolveLockRequest) GetStartVersion 

func (m *ResolveLockRequest) GetStartVersion() uint64

func (*ResolveLockRequest) GetTxnInfos 

func (m *ResolveLockRequest) GetTxnInfos() []*TxnInfo

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

func (*ResolveLockRequest) XXX_DiscardUnknown 

func (m *ResolveLockRequest) XXX_DiscardUnknown()

func (*ResolveLockRequest) XXX_Marshal 

func (m *ResolveLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveLockRequest) XXX_Merge 

func (dst *ResolveLockRequest) XXX_Merge(src proto.Message)

func (*ResolveLockRequest) XXX_Size 

func (m *ResolveLockRequest) XXX_Size() int

func (*ResolveLockRequest) XXX_Unmarshal 

func (m *ResolveLockRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*ResolveLockResponse) XXX_DiscardUnknown 

func (m *ResolveLockResponse) XXX_DiscardUnknown()

func (*ResolveLockResponse) XXX_Marshal 

func (m *ResolveLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveLockResponse) XXX_Merge 

func (dst *ResolveLockResponse) XXX_Merge(src proto.Message)

func (*ResolveLockResponse) XXX_Size 

func (m *ResolveLockResponse) XXX_Size() int

func (*ResolveLockResponse) XXX_Unmarshal 

func (m *ResolveLockResponse) XXX_Unmarshal(b []byte) error

type ScanDetail 

type ScanDetail struct {
	Write                *ScanInfo `protobuf:"bytes,1,opt,name=write" json:"write,omitempty"`
	Lock                 *ScanInfo `protobuf:"bytes,2,opt,name=lock" json:"lock,omitempty"`
	Data                 *ScanInfo `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ScanDetail) Descriptor 

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

func (*ScanDetail) GetData 

func (m *ScanDetail) GetData() *ScanInfo

func (*ScanDetail) GetLock 

func (m *ScanDetail) GetLock() *ScanInfo

func (*ScanDetail) GetWrite 

func (m *ScanDetail) GetWrite() *ScanInfo

func (*ScanDetail) Marshal 

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

func (*ScanDetail) MarshalTo 

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

func (*ScanDetail) ProtoMessage 

func (*ScanDetail) ProtoMessage()

func (*ScanDetail) Reset 

func (m *ScanDetail) Reset()

func (*ScanDetail) Size 

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

func (*ScanDetail) String 

func (m *ScanDetail) String() string

func (*ScanDetail) Unmarshal 

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

func (*ScanDetail) XXX_DiscardUnknown 

func (m *ScanDetail) XXX_DiscardUnknown()

func (*ScanDetail) XXX_Marshal 

func (m *ScanDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanDetail) XXX_Merge 

func (dst *ScanDetail) XXX_Merge(src proto.Message)

func (*ScanDetail) XXX_Size 

func (m *ScanDetail) XXX_Size() int

func (*ScanDetail) XXX_Unmarshal 

func (m *ScanDetail) XXX_Unmarshal(b []byte) error

type ScanInfo 

type ScanInfo struct {
	Total                int64    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Processed            int64    `protobuf:"varint,2,opt,name=processed,proto3" json:"processed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScanInfo) Descriptor 

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

func (*ScanInfo) GetProcessed 

func (m *ScanInfo) GetProcessed() int64

func (*ScanInfo) GetTotal 

func (m *ScanInfo) GetTotal() int64

func (*ScanInfo) Marshal 

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

func (*ScanInfo) MarshalTo 

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

func (*ScanInfo) ProtoMessage 

func (*ScanInfo) ProtoMessage()

func (*ScanInfo) Reset 

func (m *ScanInfo) Reset()

func (*ScanInfo) Size 

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

func (*ScanInfo) String 

func (m *ScanInfo) String() string

func (*ScanInfo) Unmarshal 

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

func (*ScanInfo) XXX_DiscardUnknown 

func (m *ScanInfo) XXX_DiscardUnknown()

func (*ScanInfo) XXX_Marshal 

func (m *ScanInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanInfo) XXX_Merge 

func (dst *ScanInfo) XXX_Merge(src proto.Message)

func (*ScanInfo) XXX_Size 

func (m *ScanInfo) XXX_Size() int

func (*ScanInfo) XXX_Unmarshal 

func (m *ScanInfo) XXX_Unmarshal(b []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"`
	StartKey             []byte   `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	Limit                uint32   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScanLockRequest) Descriptor 

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

func (*ScanLockRequest) GetContext 

func (m *ScanLockRequest) GetContext() *Context

func (*ScanLockRequest) GetLimit 

func (m *ScanLockRequest) GetLimit() uint32

func (*ScanLockRequest) GetMaxVersion 

func (m *ScanLockRequest) GetMaxVersion() uint64

func (*ScanLockRequest) GetStartKey 

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

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

func (*ScanLockRequest) XXX_DiscardUnknown 

func (m *ScanLockRequest) XXX_DiscardUnknown()

func (*ScanLockRequest) XXX_Marshal 

func (m *ScanLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanLockRequest) XXX_Merge 

func (dst *ScanLockRequest) XXX_Merge(src proto.Message)

func (*ScanLockRequest) XXX_Size 

func (m *ScanLockRequest) XXX_Size() int

func (*ScanLockRequest) XXX_Unmarshal 

func (m *ScanLockRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*ScanLockResponse) XXX_DiscardUnknown 

func (m *ScanLockResponse) XXX_DiscardUnknown()

func (*ScanLockResponse) XXX_Marshal 

func (m *ScanLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanLockResponse) XXX_Merge 

func (dst *ScanLockResponse) XXX_Merge(src proto.Message)

func (*ScanLockResponse) XXX_Size 

func (m *ScanLockResponse) XXX_Size() int

func (*ScanLockResponse) XXX_Unmarshal 

func (m *ScanLockResponse) XXX_Unmarshal(b []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"`
	Reverse  bool     `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// For compatibility, when scanning forward, the range to scan is [start_key, end_key), where start_key < end_key;
	// and when scanning backward, it scans [end_key, start_key) in descending order, where end_key < start_key.
	EndKey               []byte   `protobuf:"bytes,7,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	ReadOnly             bool     `protobuf:"varint,8,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScanRequest) Descriptor 

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

func (*ScanRequest) GetContext 

func (m *ScanRequest) GetContext() *Context

func (*ScanRequest) GetEndKey 

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

func (*ScanRequest) GetKeyOnly 

func (m *ScanRequest) GetKeyOnly() bool

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() uint32

func (*ScanRequest) GetReadOnly 

func (m *ScanRequest) GetReadOnly() bool

func (*ScanRequest) GetReverse 

func (m *ScanRequest) GetReverse() bool

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

func (*ScanRequest) XXX_DiscardUnknown 

func (m *ScanRequest) XXX_DiscardUnknown()

func (*ScanRequest) XXX_Marshal 

func (m *ScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanRequest) XXX_Merge 

func (dst *ScanRequest) XXX_Merge(src proto.Message)

func (*ScanRequest) XXX_Size 

func (m *ScanRequest) XXX_Size() int

func (*ScanRequest) XXX_Unmarshal 

func (m *ScanRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*ScanResponse) XXX_DiscardUnknown 

func (m *ScanResponse) XXX_DiscardUnknown()

func (*ScanResponse) XXX_Marshal 

func (m *ScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanResponse) XXX_Merge 

func (dst *ScanResponse) XXX_Merge(src proto.Message)

func (*ScanResponse) XXX_Size 

func (m *ScanResponse) XXX_Size() int

func (*ScanResponse) XXX_Unmarshal 

func (m *ScanResponse) XXX_Unmarshal(b []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"` // Deprecated: Do not use.
	SplitKeys            [][]byte `protobuf:"bytes,3,rep,name=split_keys,json=splitKeys" json:"split_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SplitRegionRequest) Descriptor 

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

func (*SplitRegionRequest) GetContext 

func (m *SplitRegionRequest) GetContext() *Context

func (*SplitRegionRequest) GetSplitKey deprecated 

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

Deprecated: Do not use.

func (*SplitRegionRequest) GetSplitKeys 

func (m *SplitRegionRequest) GetSplitKeys() [][]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

func (*SplitRegionRequest) XXX_DiscardUnknown 

func (m *SplitRegionRequest) XXX_DiscardUnknown()

func (*SplitRegionRequest) XXX_Marshal 

func (m *SplitRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SplitRegionRequest) XXX_Merge 

func (dst *SplitRegionRequest) XXX_Merge(src proto.Message)

func (*SplitRegionRequest) XXX_Size 

func (m *SplitRegionRequest) XXX_Size() int

func (*SplitRegionRequest) XXX_Unmarshal 

func (m *SplitRegionRequest) XXX_Unmarshal(b []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"`   // Deprecated: Do not use.
	Right                *metapb.Region   `protobuf:"bytes,3,opt,name=right" json:"right,omitempty"` // Deprecated: Do not use.
	Regions              []*metapb.Region `protobuf:"bytes,4,rep,name=regions" json:"regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SplitRegionResponse) Descriptor 

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

func (*SplitRegionResponse) GetLeft deprecated 

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

Deprecated: Do not use.

func (*SplitRegionResponse) GetRegionError 

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

func (*SplitRegionResponse) GetRegions 

func (m *SplitRegionResponse) GetRegions() []*metapb.Region

func (*SplitRegionResponse) GetRight deprecated 

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

Deprecated: Do not use.

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

func (*SplitRegionResponse) XXX_DiscardUnknown 

func (m *SplitRegionResponse) XXX_DiscardUnknown()

func (*SplitRegionResponse) XXX_Marshal 

func (m *SplitRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SplitRegionResponse) XXX_Merge 

func (dst *SplitRegionResponse) XXX_Merge(src proto.Message)

func (*SplitRegionResponse) XXX_Size 

func (m *SplitRegionResponse) XXX_Size() int

func (*SplitRegionResponse) XXX_Unmarshal 

func (m *SplitRegionResponse) XXX_Unmarshal(b []byte) error

type TxnHeartBeatRequest 

type TxnHeartBeatRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	PrimaryLock          []byte   `protobuf:"bytes,2,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
	StartVersion         uint64   `protobuf:"varint,3,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	AdviseLockTtl        uint64   `protobuf:"varint,4,opt,name=advise_lock_ttl,json=adviseLockTtl,proto3" json:"advise_lock_ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Used to update the lock_ttl of a large transaction to prevent it from been killed.

func (*TxnHeartBeatRequest) Descriptor 

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

func (*TxnHeartBeatRequest) GetAdviseLockTtl 

func (m *TxnHeartBeatRequest) GetAdviseLockTtl() uint64

func (*TxnHeartBeatRequest) GetContext 

func (m *TxnHeartBeatRequest) GetContext() *Context

func (*TxnHeartBeatRequest) GetPrimaryLock 

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

func (*TxnHeartBeatRequest) GetStartVersion 

func (m *TxnHeartBeatRequest) GetStartVersion() uint64

func (*TxnHeartBeatRequest) Marshal 

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

func (*TxnHeartBeatRequest) MarshalTo 

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

func (*TxnHeartBeatRequest) ProtoMessage 

func (*TxnHeartBeatRequest) ProtoMessage()

func (*TxnHeartBeatRequest) Reset 

func (m *TxnHeartBeatRequest) Reset()

func (*TxnHeartBeatRequest) Size 

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

func (*TxnHeartBeatRequest) String 

func (m *TxnHeartBeatRequest) String() string

func (*TxnHeartBeatRequest) Unmarshal 

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

func (*TxnHeartBeatRequest) XXX_DiscardUnknown 

func (m *TxnHeartBeatRequest) XXX_DiscardUnknown()

func (*TxnHeartBeatRequest) XXX_Marshal 

func (m *TxnHeartBeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnHeartBeatRequest) XXX_Merge 

func (dst *TxnHeartBeatRequest) XXX_Merge(src proto.Message)

func (*TxnHeartBeatRequest) XXX_Size 

func (m *TxnHeartBeatRequest) XXX_Size() int

func (*TxnHeartBeatRequest) XXX_Unmarshal 

func (m *TxnHeartBeatRequest) XXX_Unmarshal(b []byte) error

type TxnHeartBeatResponse 

type TxnHeartBeatResponse 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"`
	LockTtl              uint64         `protobuf:"varint,3,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TxnHeartBeatResponse) Descriptor 

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

func (*TxnHeartBeatResponse) GetError 

func (m *TxnHeartBeatResponse) GetError() *KeyError

func (*TxnHeartBeatResponse) GetLockTtl 

func (m *TxnHeartBeatResponse) GetLockTtl() uint64

func (*TxnHeartBeatResponse) GetRegionError 

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

func (*TxnHeartBeatResponse) Marshal 

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

func (*TxnHeartBeatResponse) MarshalTo 

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

func (*TxnHeartBeatResponse) ProtoMessage 

func (*TxnHeartBeatResponse) ProtoMessage()

func (*TxnHeartBeatResponse) Reset 

func (m *TxnHeartBeatResponse) Reset()

func (*TxnHeartBeatResponse) Size 

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

func (*TxnHeartBeatResponse) String 

func (m *TxnHeartBeatResponse) String() string

func (*TxnHeartBeatResponse) Unmarshal 

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

func (*TxnHeartBeatResponse) XXX_DiscardUnknown 

func (m *TxnHeartBeatResponse) XXX_DiscardUnknown()

func (*TxnHeartBeatResponse) XXX_Marshal 

func (m *TxnHeartBeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnHeartBeatResponse) XXX_Merge 

func (dst *TxnHeartBeatResponse) XXX_Merge(src proto.Message)

func (*TxnHeartBeatResponse) XXX_Size 

func (m *TxnHeartBeatResponse) XXX_Size() int

func (*TxnHeartBeatResponse) XXX_Unmarshal 

func (m *TxnHeartBeatResponse) XXX_Unmarshal(b []byte) error

type TxnInfo 

type TxnInfo struct {
	Txn                  uint64   `protobuf:"varint,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Status               uint64   `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxnInfo) Descriptor 

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

func (*TxnInfo) GetStatus 

func (m *TxnInfo) GetStatus() uint64

func (*TxnInfo) GetTxn 

func (m *TxnInfo) GetTxn() uint64

func (*TxnInfo) Marshal 

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

func (*TxnInfo) MarshalTo 

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

func (*TxnInfo) ProtoMessage 

func (*TxnInfo) ProtoMessage()

func (*TxnInfo) Reset 

func (m *TxnInfo) Reset()

func (*TxnInfo) Size 

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

func (*TxnInfo) String 

func (m *TxnInfo) String() string

func (*TxnInfo) Unmarshal 

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

func (*TxnInfo) XXX_DiscardUnknown 

func (m *TxnInfo) XXX_DiscardUnknown()

func (*TxnInfo) XXX_Marshal 

func (m *TxnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnInfo) XXX_Merge 

func (dst *TxnInfo) XXX_Merge(src proto.Message)

func (*TxnInfo) XXX_Size 

func (m *TxnInfo) XXX_Size() int

func (*TxnInfo) XXX_Unmarshal 

func (m *TxnInfo) XXX_Unmarshal(b []byte) error

type UnsafeDestroyRangeRequest 

type UnsafeDestroyRangeRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnsafeDestroyRangeRequest) Descriptor 

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

func (*UnsafeDestroyRangeRequest) GetContext 

func (m *UnsafeDestroyRangeRequest) GetContext() *Context

func (*UnsafeDestroyRangeRequest) GetEndKey 

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

func (*UnsafeDestroyRangeRequest) GetStartKey 

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

func (*UnsafeDestroyRangeRequest) Marshal 

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

func (*UnsafeDestroyRangeRequest) MarshalTo 

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

func (*UnsafeDestroyRangeRequest) ProtoMessage 

func (*UnsafeDestroyRangeRequest) ProtoMessage()

func (*UnsafeDestroyRangeRequest) Reset 

func (m *UnsafeDestroyRangeRequest) Reset()

func (*UnsafeDestroyRangeRequest) Size 

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

func (*UnsafeDestroyRangeRequest) String 

func (m *UnsafeDestroyRangeRequest) String() string

func (*UnsafeDestroyRangeRequest) Unmarshal 

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

func (*UnsafeDestroyRangeRequest) XXX_DiscardUnknown 

func (m *UnsafeDestroyRangeRequest) XXX_DiscardUnknown()

func (*UnsafeDestroyRangeRequest) XXX_Marshal 

func (m *UnsafeDestroyRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeDestroyRangeRequest) XXX_Merge 

func (dst *UnsafeDestroyRangeRequest) XXX_Merge(src proto.Message)

func (*UnsafeDestroyRangeRequest) XXX_Size 

func (m *UnsafeDestroyRangeRequest) XXX_Size() int

func (*UnsafeDestroyRangeRequest) XXX_Unmarshal 

func (m *UnsafeDestroyRangeRequest) XXX_Unmarshal(b []byte) error

type UnsafeDestroyRangeResponse 

type UnsafeDestroyRangeResponse 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UnsafeDestroyRangeResponse) Descriptor 

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

func (*UnsafeDestroyRangeResponse) GetError 

func (m *UnsafeDestroyRangeResponse) GetError() string

func (*UnsafeDestroyRangeResponse) GetRegionError 

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

func (*UnsafeDestroyRangeResponse) Marshal 

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

func (*UnsafeDestroyRangeResponse) MarshalTo 

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

func (*UnsafeDestroyRangeResponse) ProtoMessage 

func (*UnsafeDestroyRangeResponse) ProtoMessage()

func (*UnsafeDestroyRangeResponse) Reset 

func (m *UnsafeDestroyRangeResponse) Reset()

func (*UnsafeDestroyRangeResponse) Size 

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

func (*UnsafeDestroyRangeResponse) String 

func (m *UnsafeDestroyRangeResponse) String() string

func (*UnsafeDestroyRangeResponse) Unmarshal 

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

func (*UnsafeDestroyRangeResponse) XXX_DiscardUnknown 

func (m *UnsafeDestroyRangeResponse) XXX_DiscardUnknown()

func (*UnsafeDestroyRangeResponse) XXX_Marshal 

func (m *UnsafeDestroyRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeDestroyRangeResponse) XXX_Merge 

func (dst *UnsafeDestroyRangeResponse) XXX_Merge(src proto.Message)

func (*UnsafeDestroyRangeResponse) XXX_Size 

func (m *UnsafeDestroyRangeResponse) XXX_Size() int

func (*UnsafeDestroyRangeResponse) XXX_Unmarshal 

func (m *UnsafeDestroyRangeResponse) XXX_Unmarshal(b []byte) error

type WriteConflict 

type WriteConflict struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	ConflictTs           uint64   `protobuf:"varint,2,opt,name=conflict_ts,json=conflictTs,proto3" json:"conflict_ts,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Primary              []byte   `protobuf:"bytes,4,opt,name=primary,proto3" json:"primary,omitempty"`
	ConflictCommitTs     uint64   `protobuf:"varint,5,opt,name=conflict_commit_ts,json=conflictCommitTs,proto3" json:"conflict_commit_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteConflict) Descriptor 

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

func (*WriteConflict) GetConflictCommitTs 

func (m *WriteConflict) GetConflictCommitTs() uint64

func (*WriteConflict) GetConflictTs 

func (m *WriteConflict) GetConflictTs() uint64

func (*WriteConflict) GetKey 

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

func (*WriteConflict) GetPrimary 

func (m *WriteConflict) GetPrimary() []byte

func (*WriteConflict) GetStartTs 

func (m *WriteConflict) GetStartTs() uint64

func (*WriteConflict) Marshal 

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

func (*WriteConflict) MarshalTo 

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

func (*WriteConflict) ProtoMessage 

func (*WriteConflict) ProtoMessage()

func (*WriteConflict) Reset 

func (m *WriteConflict) Reset()

func (*WriteConflict) Size 

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

func (*WriteConflict) String 

func (m *WriteConflict) String() string

func (*WriteConflict) Unmarshal 

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

func (*WriteConflict) XXX_DiscardUnknown 

func (m *WriteConflict) XXX_DiscardUnknown()

func (*WriteConflict) XXX_Marshal 

func (m *WriteConflict) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteConflict) XXX_Merge 

func (dst *WriteConflict) XXX_Merge(src proto.Message)

func (*WriteConflict) XXX_Size 

func (m *WriteConflict) XXX_Size() int

func (*WriteConflict) XXX_Unmarshal 

func (m *WriteConflict) XXX_Unmarshal(b []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.