kvrpcpb

package
v0.0.0-...-cb7c7b8 Latest Latest
Warning

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

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

Documentation

Overview

Package kvrpcpb is a generated protocol buffer package.

It is generated from these files: 

kvrpcpb.proto

It has these top-level messages: 

LockInfo
KeyError
Context
CmdGetRequest
CmdGetResponse
CmdScanRequest
KvPair
CmdScanResponse
Mutation
CmdPrewriteRequest
CmdPrewriteResponse
CmdCommitRequest
CmdCommitResponse
CmdBatchRollbackRequest
CmdBatchRollbackResponse
CmdCleanupRequest
CmdCleanupResponse
CmdBatchGetRequest
CmdBatchGetResponse
CmdScanLockRequest
CmdScanLockResponse
CmdResolveLockRequest
CmdResolveLockResponse
CmdGCRequest
CmdGCResponse
CmdRawGetRequest
CmdRawGetResponse
CmdRawPutRequest
CmdRawPutResponse
CmdRawDeleteRequest
CmdRawDeleteResponse
Request
Response

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 MessageType_name = map[int32]string{
	0:   "CmdGet",
	1:   "CmdScan",
	2:   "CmdPrewrite",
	3:   "CmdCommit",
	4:   "CmdCleanup",
	7:   "CmdBatchGet",
	8:   "CmdBatchRollback",
	9:   "CmdScanLock",
	10:  "CmdResolveLock",
	11:  "CmdGC",
	256: "CmdRawGet",
	257: "CmdRawPut",
	258: "CmdRawDelete",
}
View Source 
var MessageType_value = map[string]int32{
	"CmdGet":           0,
	"CmdScan":          1,
	"CmdPrewrite":      2,
	"CmdCommit":        3,
	"CmdCleanup":       4,
	"CmdBatchGet":      7,
	"CmdBatchRollback": 8,
	"CmdScanLock":      9,
	"CmdResolveLock":   10,
	"CmdGC":            11,
	"CmdRawGet":        256,
	"CmdRawPut":        257,
	"CmdRawDelete":     258,
}
View Source 
var Op_name = map[int32]string{
	0: "Put",
	1: "Del",
	2: "Lock",
}
View Source 
var Op_value = map[string]int32{
	"Put":  0,
	"Del":  1,
	"Lock": 2,
}

Functions

This section is empty.

Types

type CmdBatchGetRequest 

type CmdBatchGetRequest struct {
	Keys             [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	Version          uint64   `protobuf:"varint,2,opt,name=version" json:"version"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CmdBatchGetRequest) Descriptor 

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

func (*CmdBatchGetRequest) GetKeys 

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

func (*CmdBatchGetRequest) GetVersion 

func (m *CmdBatchGetRequest) GetVersion() uint64

func (*CmdBatchGetRequest) Marshal 

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

func (*CmdBatchGetRequest) MarshalTo 

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

func (*CmdBatchGetRequest) ProtoMessage 

func (*CmdBatchGetRequest) ProtoMessage()

func (*CmdBatchGetRequest) Reset 

func (m *CmdBatchGetRequest) Reset()

func (*CmdBatchGetRequest) Size 

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

func (*CmdBatchGetRequest) String 

func (m *CmdBatchGetRequest) String() string

func (*CmdBatchGetRequest) Unmarshal 

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

type CmdBatchGetResponse 

type CmdBatchGetResponse struct {
	Pairs            []*KvPair `protobuf:"bytes,1,rep,name=pairs" json:"pairs,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdBatchGetResponse) Descriptor 

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

func (*CmdBatchGetResponse) GetPairs 

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

func (*CmdBatchGetResponse) Marshal 

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

func (*CmdBatchGetResponse) MarshalTo 

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

func (*CmdBatchGetResponse) ProtoMessage 

func (*CmdBatchGetResponse) ProtoMessage()

func (*CmdBatchGetResponse) Reset 

func (m *CmdBatchGetResponse) Reset()

func (*CmdBatchGetResponse) Size 

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

func (*CmdBatchGetResponse) String 

func (m *CmdBatchGetResponse) String() string

func (*CmdBatchGetResponse) Unmarshal 

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

type CmdBatchRollbackRequest 

type CmdBatchRollbackRequest struct {
	StartVersion     uint64   `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"`
	Keys             [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CmdBatchRollbackRequest) Descriptor 

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

func (*CmdBatchRollbackRequest) GetKeys 

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

func (*CmdBatchRollbackRequest) GetStartVersion 

func (m *CmdBatchRollbackRequest) GetStartVersion() uint64

func (*CmdBatchRollbackRequest) Marshal 

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

func (*CmdBatchRollbackRequest) MarshalTo 

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

func (*CmdBatchRollbackRequest) ProtoMessage 

func (*CmdBatchRollbackRequest) ProtoMessage()

func (*CmdBatchRollbackRequest) Reset 

func (m *CmdBatchRollbackRequest) Reset()

func (*CmdBatchRollbackRequest) Size 

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

func (*CmdBatchRollbackRequest) String 

func (m *CmdBatchRollbackRequest) String() string

func (*CmdBatchRollbackRequest) Unmarshal 

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

type CmdBatchRollbackResponse 

type CmdBatchRollbackResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdBatchRollbackResponse) Descriptor 

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

func (*CmdBatchRollbackResponse) GetError 

func (m *CmdBatchRollbackResponse) GetError() *KeyError

func (*CmdBatchRollbackResponse) Marshal 

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

func (*CmdBatchRollbackResponse) MarshalTo 

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

func (*CmdBatchRollbackResponse) ProtoMessage 

func (*CmdBatchRollbackResponse) ProtoMessage()

func (*CmdBatchRollbackResponse) Reset 

func (m *CmdBatchRollbackResponse) Reset()

func (*CmdBatchRollbackResponse) Size 

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

func (*CmdBatchRollbackResponse) String 

func (m *CmdBatchRollbackResponse) String() string

func (*CmdBatchRollbackResponse) Unmarshal 

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

type CmdCleanupRequest 

type CmdCleanupRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	StartVersion     uint64 `protobuf:"varint,2,opt,name=start_version,json=startVersion" json:"start_version"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdCleanupRequest) Descriptor 

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

func (*CmdCleanupRequest) GetKey 

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

func (*CmdCleanupRequest) GetStartVersion 

func (m *CmdCleanupRequest) GetStartVersion() uint64

func (*CmdCleanupRequest) Marshal 

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

func (*CmdCleanupRequest) MarshalTo 

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

func (*CmdCleanupRequest) ProtoMessage 

func (*CmdCleanupRequest) ProtoMessage()

func (*CmdCleanupRequest) Reset 

func (m *CmdCleanupRequest) Reset()

func (*CmdCleanupRequest) Size 

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

func (*CmdCleanupRequest) String 

func (m *CmdCleanupRequest) String() string

func (*CmdCleanupRequest) Unmarshal 

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

type CmdCleanupResponse 

type CmdCleanupResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	CommitVersion    uint64    `protobuf:"varint,2,opt,name=commit_version,json=commitVersion" json:"commit_version"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdCleanupResponse) Descriptor 

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

func (*CmdCleanupResponse) GetCommitVersion 

func (m *CmdCleanupResponse) GetCommitVersion() uint64

func (*CmdCleanupResponse) GetError 

func (m *CmdCleanupResponse) GetError() *KeyError

func (*CmdCleanupResponse) Marshal 

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

func (*CmdCleanupResponse) MarshalTo 

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

func (*CmdCleanupResponse) ProtoMessage 

func (*CmdCleanupResponse) ProtoMessage()

func (*CmdCleanupResponse) Reset 

func (m *CmdCleanupResponse) Reset()

func (*CmdCleanupResponse) Size 

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

func (*CmdCleanupResponse) String 

func (m *CmdCleanupResponse) String() string

func (*CmdCleanupResponse) Unmarshal 

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

type CmdCommitRequest 

type CmdCommitRequest struct {
	StartVersion     uint64   `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"`
	Keys             [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
	CommitVersion    uint64   `protobuf:"varint,3,opt,name=commit_version,json=commitVersion" json:"commit_version"`
	Binlog           []byte   `protobuf:"bytes,4,opt,name=binlog" json:"binlog,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CmdCommitRequest) Descriptor 

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

func (*CmdCommitRequest) GetBinlog 

func (m *CmdCommitRequest) GetBinlog() []byte

func (*CmdCommitRequest) GetCommitVersion 

func (m *CmdCommitRequest) GetCommitVersion() uint64

func (*CmdCommitRequest) GetKeys 

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

func (*CmdCommitRequest) GetStartVersion 

func (m *CmdCommitRequest) GetStartVersion() uint64

func (*CmdCommitRequest) Marshal 

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

func (*CmdCommitRequest) MarshalTo 

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

func (*CmdCommitRequest) ProtoMessage 

func (*CmdCommitRequest) ProtoMessage()

func (*CmdCommitRequest) Reset 

func (m *CmdCommitRequest) Reset()

func (*CmdCommitRequest) Size 

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

func (*CmdCommitRequest) String 

func (m *CmdCommitRequest) String() string

func (*CmdCommitRequest) Unmarshal 

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

type CmdCommitResponse 

type CmdCommitResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdCommitResponse) Descriptor 

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

func (*CmdCommitResponse) GetError 

func (m *CmdCommitResponse) GetError() *KeyError

func (*CmdCommitResponse) Marshal 

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

func (*CmdCommitResponse) MarshalTo 

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

func (*CmdCommitResponse) ProtoMessage 

func (*CmdCommitResponse) ProtoMessage()

func (*CmdCommitResponse) Reset 

func (m *CmdCommitResponse) Reset()

func (*CmdCommitResponse) Size 

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

func (*CmdCommitResponse) String 

func (m *CmdCommitResponse) String() string

func (*CmdCommitResponse) Unmarshal 

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

type CmdGCRequest 

type CmdGCRequest struct {
	SafePoint        uint64 `protobuf:"varint,1,opt,name=safe_point,json=safePoint" json:"safe_point"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdGCRequest) Descriptor 

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

func (*CmdGCRequest) GetSafePoint 

func (m *CmdGCRequest) GetSafePoint() uint64

func (*CmdGCRequest) Marshal 

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

func (*CmdGCRequest) MarshalTo 

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

func (*CmdGCRequest) ProtoMessage 

func (*CmdGCRequest) ProtoMessage()

func (*CmdGCRequest) Reset 

func (m *CmdGCRequest) Reset()

func (*CmdGCRequest) Size 

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

func (*CmdGCRequest) String 

func (m *CmdGCRequest) String() string

func (*CmdGCRequest) Unmarshal 

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

type CmdGCResponse 

type CmdGCResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdGCResponse) Descriptor 

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

func (*CmdGCResponse) GetError 

func (m *CmdGCResponse) GetError() *KeyError

func (*CmdGCResponse) Marshal 

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

func (*CmdGCResponse) MarshalTo 

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

func (*CmdGCResponse) ProtoMessage 

func (*CmdGCResponse) ProtoMessage()

func (*CmdGCResponse) Reset 

func (m *CmdGCResponse) Reset()

func (*CmdGCResponse) Size 

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

func (*CmdGCResponse) String 

func (m *CmdGCResponse) String() string

func (*CmdGCResponse) Unmarshal 

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

type CmdGetRequest 

type CmdGetRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Version          uint64 `protobuf:"varint,2,opt,name=version" json:"version"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdGetRequest) Descriptor 

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

func (*CmdGetRequest) GetKey 

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

func (*CmdGetRequest) GetVersion 

func (m *CmdGetRequest) GetVersion() uint64

func (*CmdGetRequest) Marshal 

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

func (*CmdGetRequest) MarshalTo 

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

func (*CmdGetRequest) ProtoMessage 

func (*CmdGetRequest) ProtoMessage()

func (*CmdGetRequest) Reset 

func (m *CmdGetRequest) Reset()

func (*CmdGetRequest) Size 

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

func (*CmdGetRequest) String 

func (m *CmdGetRequest) String() string

func (*CmdGetRequest) Unmarshal 

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

type CmdGetResponse 

type CmdGetResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Value            []byte    `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdGetResponse) Descriptor 

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

func (*CmdGetResponse) GetError 

func (m *CmdGetResponse) GetError() *KeyError

func (*CmdGetResponse) GetValue 

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

func (*CmdGetResponse) Marshal 

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

func (*CmdGetResponse) MarshalTo 

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

func (*CmdGetResponse) ProtoMessage 

func (*CmdGetResponse) ProtoMessage()

func (*CmdGetResponse) Reset 

func (m *CmdGetResponse) Reset()

func (*CmdGetResponse) Size 

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

func (*CmdGetResponse) String 

func (m *CmdGetResponse) String() string

func (*CmdGetResponse) Unmarshal 

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

type CmdPrewriteRequest 

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

func (*CmdPrewriteRequest) Descriptor 

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

func (*CmdPrewriteRequest) GetLockTtl 

func (m *CmdPrewriteRequest) GetLockTtl() uint64

func (*CmdPrewriteRequest) GetMutations 

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

func (*CmdPrewriteRequest) GetPrimaryLock 

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

func (*CmdPrewriteRequest) GetSkipConstraintCheck 

func (m *CmdPrewriteRequest) GetSkipConstraintCheck() bool

func (*CmdPrewriteRequest) GetStartVersion 

func (m *CmdPrewriteRequest) GetStartVersion() uint64

func (*CmdPrewriteRequest) Marshal 

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

func (*CmdPrewriteRequest) MarshalTo 

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

func (*CmdPrewriteRequest) ProtoMessage 

func (*CmdPrewriteRequest) ProtoMessage()

func (*CmdPrewriteRequest) Reset 

func (m *CmdPrewriteRequest) Reset()

func (*CmdPrewriteRequest) Size 

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

func (*CmdPrewriteRequest) String 

func (m *CmdPrewriteRequest) String() string

func (*CmdPrewriteRequest) Unmarshal 

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

type CmdPrewriteResponse 

type CmdPrewriteResponse struct {
	Errors           []*KeyError `protobuf:"bytes,1,rep,name=errors" json:"errors,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*CmdPrewriteResponse) Descriptor 

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

func (*CmdPrewriteResponse) GetErrors 

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

func (*CmdPrewriteResponse) Marshal 

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

func (*CmdPrewriteResponse) MarshalTo 

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

func (*CmdPrewriteResponse) ProtoMessage 

func (*CmdPrewriteResponse) ProtoMessage()

func (*CmdPrewriteResponse) Reset 

func (m *CmdPrewriteResponse) Reset()

func (*CmdPrewriteResponse) Size 

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

func (*CmdPrewriteResponse) String 

func (m *CmdPrewriteResponse) String() string

func (*CmdPrewriteResponse) Unmarshal 

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

type CmdRawDeleteRequest 

type CmdRawDeleteRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdRawDeleteRequest) Descriptor 

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

func (*CmdRawDeleteRequest) GetKey 

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

func (*CmdRawDeleteRequest) Marshal 

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

func (*CmdRawDeleteRequest) MarshalTo 

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

func (*CmdRawDeleteRequest) ProtoMessage 

func (*CmdRawDeleteRequest) ProtoMessage()

func (*CmdRawDeleteRequest) Reset 

func (m *CmdRawDeleteRequest) Reset()

func (*CmdRawDeleteRequest) Size 

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

func (*CmdRawDeleteRequest) String 

func (m *CmdRawDeleteRequest) String() string

func (*CmdRawDeleteRequest) Unmarshal 

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

type CmdRawDeleteResponse 

type CmdRawDeleteResponse struct {
	Error            *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CmdRawDeleteResponse) Descriptor 

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

func (*CmdRawDeleteResponse) GetError 

func (m *CmdRawDeleteResponse) GetError() string

func (*CmdRawDeleteResponse) Marshal 

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

func (*CmdRawDeleteResponse) MarshalTo 

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

func (*CmdRawDeleteResponse) ProtoMessage 

func (*CmdRawDeleteResponse) ProtoMessage()

func (*CmdRawDeleteResponse) Reset 

func (m *CmdRawDeleteResponse) Reset()

func (*CmdRawDeleteResponse) Size 

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

func (*CmdRawDeleteResponse) String 

func (m *CmdRawDeleteResponse) String() string

func (*CmdRawDeleteResponse) Unmarshal 

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

type CmdRawGetRequest 

type CmdRawGetRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdRawGetRequest) Descriptor 

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

func (*CmdRawGetRequest) GetKey 

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

func (*CmdRawGetRequest) Marshal 

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

func (*CmdRawGetRequest) MarshalTo 

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

func (*CmdRawGetRequest) ProtoMessage 

func (*CmdRawGetRequest) ProtoMessage()

func (*CmdRawGetRequest) Reset 

func (m *CmdRawGetRequest) Reset()

func (*CmdRawGetRequest) Size 

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

func (*CmdRawGetRequest) String 

func (m *CmdRawGetRequest) String() string

func (*CmdRawGetRequest) Unmarshal 

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

type CmdRawGetResponse 

type CmdRawGetResponse struct {
	Error            *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Value            []byte  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CmdRawGetResponse) Descriptor 

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

func (*CmdRawGetResponse) GetError 

func (m *CmdRawGetResponse) GetError() string

func (*CmdRawGetResponse) GetValue 

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

func (*CmdRawGetResponse) Marshal 

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

func (*CmdRawGetResponse) MarshalTo 

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

func (*CmdRawGetResponse) ProtoMessage 

func (*CmdRawGetResponse) ProtoMessage()

func (*CmdRawGetResponse) Reset 

func (m *CmdRawGetResponse) Reset()

func (*CmdRawGetResponse) Size 

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

func (*CmdRawGetResponse) String 

func (m *CmdRawGetResponse) String() string

func (*CmdRawGetResponse) Unmarshal 

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

type CmdRawPutRequest 

type CmdRawPutRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value            []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdRawPutRequest) Descriptor 

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

func (*CmdRawPutRequest) GetKey 

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

func (*CmdRawPutRequest) GetValue 

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

func (*CmdRawPutRequest) Marshal 

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

func (*CmdRawPutRequest) MarshalTo 

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

func (*CmdRawPutRequest) ProtoMessage 

func (*CmdRawPutRequest) ProtoMessage()

func (*CmdRawPutRequest) Reset 

func (m *CmdRawPutRequest) Reset()

func (*CmdRawPutRequest) Size 

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

func (*CmdRawPutRequest) String 

func (m *CmdRawPutRequest) String() string

func (*CmdRawPutRequest) Unmarshal 

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

type CmdRawPutResponse 

type CmdRawPutResponse struct {
	Error            *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CmdRawPutResponse) Descriptor 

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

func (*CmdRawPutResponse) GetError 

func (m *CmdRawPutResponse) GetError() string

func (*CmdRawPutResponse) Marshal 

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

func (*CmdRawPutResponse) MarshalTo 

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

func (*CmdRawPutResponse) ProtoMessage 

func (*CmdRawPutResponse) ProtoMessage()

func (*CmdRawPutResponse) Reset 

func (m *CmdRawPutResponse) Reset()

func (*CmdRawPutResponse) Size 

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

func (*CmdRawPutResponse) String 

func (m *CmdRawPutResponse) String() string

func (*CmdRawPutResponse) Unmarshal 

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

type CmdResolveLockRequest 

type CmdResolveLockRequest struct {
	StartVersion uint64 `protobuf:"varint,1,opt,name=start_version,json=startVersion" json:"start_version"`
	// If the txn is rolled back, do not set it.
	CommitVersion    uint64 `protobuf:"varint,2,opt,name=commit_version,json=commitVersion" json:"commit_version"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdResolveLockRequest) Descriptor 

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

func (*CmdResolveLockRequest) GetCommitVersion 

func (m *CmdResolveLockRequest) GetCommitVersion() uint64

func (*CmdResolveLockRequest) GetStartVersion 

func (m *CmdResolveLockRequest) GetStartVersion() uint64

func (*CmdResolveLockRequest) Marshal 

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

func (*CmdResolveLockRequest) MarshalTo 

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

func (*CmdResolveLockRequest) ProtoMessage 

func (*CmdResolveLockRequest) ProtoMessage()

func (*CmdResolveLockRequest) Reset 

func (m *CmdResolveLockRequest) Reset()

func (*CmdResolveLockRequest) Size 

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

func (*CmdResolveLockRequest) String 

func (m *CmdResolveLockRequest) String() string

func (*CmdResolveLockRequest) Unmarshal 

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

type CmdResolveLockResponse 

type CmdResolveLockResponse struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdResolveLockResponse) Descriptor 

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

func (*CmdResolveLockResponse) GetError 

func (m *CmdResolveLockResponse) GetError() *KeyError

func (*CmdResolveLockResponse) Marshal 

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

func (*CmdResolveLockResponse) MarshalTo 

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

func (*CmdResolveLockResponse) ProtoMessage 

func (*CmdResolveLockResponse) ProtoMessage()

func (*CmdResolveLockResponse) Reset 

func (m *CmdResolveLockResponse) Reset()

func (*CmdResolveLockResponse) Size 

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

func (*CmdResolveLockResponse) String 

func (m *CmdResolveLockResponse) String() string

func (*CmdResolveLockResponse) Unmarshal 

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

type CmdScanLockRequest 

type CmdScanLockRequest struct {
	MaxVersion       uint64 `protobuf:"varint,1,opt,name=max_version,json=maxVersion" json:"max_version"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CmdScanLockRequest) Descriptor 

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

func (*CmdScanLockRequest) GetMaxVersion 

func (m *CmdScanLockRequest) GetMaxVersion() uint64

func (*CmdScanLockRequest) Marshal 

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

func (*CmdScanLockRequest) MarshalTo 

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

func (*CmdScanLockRequest) ProtoMessage 

func (*CmdScanLockRequest) ProtoMessage()

func (*CmdScanLockRequest) Reset 

func (m *CmdScanLockRequest) Reset()

func (*CmdScanLockRequest) Size 

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

func (*CmdScanLockRequest) String 

func (m *CmdScanLockRequest) String() string

func (*CmdScanLockRequest) Unmarshal 

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

type CmdScanLockResponse 

type CmdScanLockResponse struct {
	Error            *KeyError   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Locks            []*LockInfo `protobuf:"bytes,2,rep,name=locks" json:"locks,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*CmdScanLockResponse) Descriptor 

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

func (*CmdScanLockResponse) GetError 

func (m *CmdScanLockResponse) GetError() *KeyError

func (*CmdScanLockResponse) GetLocks 

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

func (*CmdScanLockResponse) Marshal 

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

func (*CmdScanLockResponse) MarshalTo 

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

func (*CmdScanLockResponse) ProtoMessage 

func (*CmdScanLockResponse) ProtoMessage()

func (*CmdScanLockResponse) Reset 

func (m *CmdScanLockResponse) Reset()

func (*CmdScanLockResponse) Size 

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

func (*CmdScanLockResponse) String 

func (m *CmdScanLockResponse) String() string

func (*CmdScanLockResponse) Unmarshal 

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

type CmdScanRequest 

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

func (*CmdScanRequest) Descriptor 

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

func (*CmdScanRequest) GetKeyOnly 

func (m *CmdScanRequest) GetKeyOnly() bool

func (*CmdScanRequest) GetLimit 

func (m *CmdScanRequest) GetLimit() uint32

func (*CmdScanRequest) GetStartKey 

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

func (*CmdScanRequest) GetVersion 

func (m *CmdScanRequest) GetVersion() uint64

func (*CmdScanRequest) Marshal 

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

func (*CmdScanRequest) MarshalTo 

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

func (*CmdScanRequest) ProtoMessage 

func (*CmdScanRequest) ProtoMessage()

func (*CmdScanRequest) Reset 

func (m *CmdScanRequest) Reset()

func (*CmdScanRequest) Size 

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

func (*CmdScanRequest) String 

func (m *CmdScanRequest) String() string

func (*CmdScanRequest) Unmarshal 

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

type CmdScanResponse 

type CmdScanResponse struct {
	Pairs            []*KvPair `protobuf:"bytes,1,rep,name=pairs" json:"pairs,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*CmdScanResponse) Descriptor 

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

func (*CmdScanResponse) GetPairs 

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

func (*CmdScanResponse) Marshal 

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

func (*CmdScanResponse) MarshalTo 

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

func (*CmdScanResponse) ProtoMessage 

func (*CmdScanResponse) ProtoMessage()

func (*CmdScanResponse) Reset 

func (m *CmdScanResponse) Reset()

func (*CmdScanResponse) Size 

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

func (*CmdScanResponse) String 

func (m *CmdScanResponse) String() string

func (*CmdScanResponse) Unmarshal 

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

type Context 

type Context struct {
	RegionId         uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId" json:"region_id"`
	RegionEpoch      *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
	Peer             *metapb.Peer        `protobuf:"bytes,3,opt,name=peer" json:"peer,omitempty"`
	ReadQuorum       bool                `protobuf:"varint,4,opt,name=read_quorum,json=readQuorum" json:"read_quorum"`
	Term             uint64              `protobuf:"varint,5,opt,name=term" json:"term"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*Context) Descriptor 

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

func (*Context) GetPeer 

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

func (*Context) GetReadQuorum 

func (m *Context) GetReadQuorum() bool

func (*Context) GetRegionEpoch 

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

func (*Context) GetRegionId 

func (m *Context) GetRegionId() uint64

func (*Context) GetTerm 

func (m *Context) GetTerm() uint64

func (*Context) Marshal 

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

func (*Context) MarshalTo 

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

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) Reset 

func (m *Context) Reset()

func (*Context) Size 

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

func (*Context) String 

func (m *Context) String() string

func (*Context) Unmarshal 

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

type KeyError 

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

func (*KeyError) Descriptor 

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

func (*KeyError) GetAbort 

func (m *KeyError) GetAbort() string

func (*KeyError) GetLocked 

func (m *KeyError) GetLocked() *LockInfo

func (*KeyError) GetRetryable 

func (m *KeyError) GetRetryable() string

func (*KeyError) Marshal 

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

func (*KeyError) MarshalTo 

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

func (*KeyError) ProtoMessage 

func (*KeyError) ProtoMessage()

func (*KeyError) Reset 

func (m *KeyError) Reset()

func (*KeyError) Size 

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

func (*KeyError) String 

func (m *KeyError) String() string

func (*KeyError) Unmarshal 

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

type KvPair 

type KvPair struct {
	Error            *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Key              []byte    `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value            []byte    `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte    `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

type LockInfo 

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

func (*LockInfo) Descriptor 

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

func (*LockInfo) GetKey 

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

func (*LockInfo) GetLockTtl 

func (m *LockInfo) GetLockTtl() uint64

func (*LockInfo) GetLockVersion 

func (m *LockInfo) GetLockVersion() uint64

func (*LockInfo) GetPrimaryLock 

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

func (*LockInfo) Marshal 

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

func (*LockInfo) MarshalTo 

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

func (*LockInfo) ProtoMessage 

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset 

func (m *LockInfo) Reset()

func (*LockInfo) Size 

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

func (*LockInfo) String 

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal 

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

type MessageType 

type MessageType int32
const (
	MessageType_CmdGet           MessageType = 0
	MessageType_CmdScan          MessageType = 1
	MessageType_CmdPrewrite      MessageType = 2
	MessageType_CmdCommit        MessageType = 3
	MessageType_CmdCleanup       MessageType = 4
	MessageType_CmdBatchGet      MessageType = 7
	MessageType_CmdBatchRollback MessageType = 8
	MessageType_CmdScanLock      MessageType = 9
	MessageType_CmdResolveLock   MessageType = 10
	MessageType_CmdGC            MessageType = 11
	// These 3 raw APIs are for raw kv operations which do not contain
	// transactions or MVCC. They should not be mixed with other commands in the
	// same cluster.
	MessageType_CmdRawGet    MessageType = 256
	MessageType_CmdRawPut    MessageType = 257
	MessageType_CmdRawDelete MessageType = 258
)

func (MessageType) Enum 

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

func (*MessageType) UnmarshalJSON 

func (x *MessageType) UnmarshalJSON(data []byte) error

type Mutation 

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

func (*Mutation) Descriptor 

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

func (*Mutation) GetKey 

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

func (*Mutation) GetOp 

func (m *Mutation) GetOp() Op

func (*Mutation) GetValue 

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

func (*Mutation) Marshal 

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

func (*Mutation) MarshalTo 

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

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) Reset 

func (m *Mutation) Reset()

func (*Mutation) Size 

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

func (*Mutation) String 

func (m *Mutation) String() string

func (*Mutation) Unmarshal 

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

type Op 

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

func (Op) Enum 

func (x Op) Enum() *Op

func (Op) EnumDescriptor 

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

func (Op) String 

func (x Op) String() string

func (*Op) UnmarshalJSON 

func (x *Op) UnmarshalJSON(data []byte) error

type Request 

type Request struct {
	Type                MessageType              `protobuf:"varint,1,opt,name=type,enum=kvrpcpb.MessageType" json:"type"`
	Context             *Context                 `protobuf:"bytes,2,opt,name=context" json:"context,omitempty"`
	CmdGetReq           *CmdGetRequest           `protobuf:"bytes,3,opt,name=cmd_get_req,json=cmdGetReq" json:"cmd_get_req,omitempty"`
	CmdScanReq          *CmdScanRequest          `protobuf:"bytes,4,opt,name=cmd_scan_req,json=cmdScanReq" json:"cmd_scan_req,omitempty"`
	CmdPrewriteReq      *CmdPrewriteRequest      `protobuf:"bytes,5,opt,name=cmd_prewrite_req,json=cmdPrewriteReq" json:"cmd_prewrite_req,omitempty"`
	CmdCommitReq        *CmdCommitRequest        `protobuf:"bytes,6,opt,name=cmd_commit_req,json=cmdCommitReq" json:"cmd_commit_req,omitempty"`
	CmdCleanupReq       *CmdCleanupRequest       `protobuf:"bytes,7,opt,name=cmd_cleanup_req,json=cmdCleanupReq" json:"cmd_cleanup_req,omitempty"`
	CmdBatchGetReq      *CmdBatchGetRequest      `protobuf:"bytes,10,opt,name=cmd_batch_get_req,json=cmdBatchGetReq" json:"cmd_batch_get_req,omitempty"`
	CmdBatchRollbackReq *CmdBatchRollbackRequest `protobuf:"bytes,11,opt,name=cmd_batch_rollback_req,json=cmdBatchRollbackReq" json:"cmd_batch_rollback_req,omitempty"`
	CmdScanLockReq      *CmdScanLockRequest      `protobuf:"bytes,12,opt,name=cmd_scan_lock_req,json=cmdScanLockReq" json:"cmd_scan_lock_req,omitempty"`
	CmdResolveLockReq   *CmdResolveLockRequest   `protobuf:"bytes,13,opt,name=cmd_resolve_lock_req,json=cmdResolveLockReq" json:"cmd_resolve_lock_req,omitempty"`
	CmdGcReq            *CmdGCRequest            `protobuf:"bytes,14,opt,name=cmd_gc_req,json=cmdGcReq" json:"cmd_gc_req,omitempty"`
	CmdRawGetReq        *CmdRawGetRequest        `protobuf:"bytes,256,opt,name=cmd_raw_get_req,json=cmdRawGetReq" json:"cmd_raw_get_req,omitempty"`
	CmdRawPutReq        *CmdRawPutRequest        `protobuf:"bytes,257,opt,name=cmd_raw_put_req,json=cmdRawPutReq" json:"cmd_raw_put_req,omitempty"`
	CmdRawDeleteReq     *CmdRawDeleteRequest     `protobuf:"bytes,258,opt,name=cmd_raw_delete_req,json=cmdRawDeleteReq" json:"cmd_raw_delete_req,omitempty"`
	XXX_unrecognized    []byte                   `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetCmdBatchGetReq 

func (m *Request) GetCmdBatchGetReq() *CmdBatchGetRequest

func (*Request) GetCmdBatchRollbackReq 

func (m *Request) GetCmdBatchRollbackReq() *CmdBatchRollbackRequest

func (*Request) GetCmdCleanupReq 

func (m *Request) GetCmdCleanupReq() *CmdCleanupRequest

func (*Request) GetCmdCommitReq 

func (m *Request) GetCmdCommitReq() *CmdCommitRequest

func (*Request) GetCmdGcReq 

func (m *Request) GetCmdGcReq() *CmdGCRequest

func (*Request) GetCmdGetReq 

func (m *Request) GetCmdGetReq() *CmdGetRequest

func (*Request) GetCmdPrewriteReq 

func (m *Request) GetCmdPrewriteReq() *CmdPrewriteRequest

func (*Request) GetCmdRawDeleteReq 

func (m *Request) GetCmdRawDeleteReq() *CmdRawDeleteRequest

func (*Request) GetCmdRawGetReq 

func (m *Request) GetCmdRawGetReq() *CmdRawGetRequest

func (*Request) GetCmdRawPutReq 

func (m *Request) GetCmdRawPutReq() *CmdRawPutRequest

func (*Request) GetCmdResolveLockReq 

func (m *Request) GetCmdResolveLockReq() *CmdResolveLockRequest

func (*Request) GetCmdScanLockReq 

func (m *Request) GetCmdScanLockReq() *CmdScanLockRequest

func (*Request) GetCmdScanReq 

func (m *Request) GetCmdScanReq() *CmdScanRequest

func (*Request) GetContext 

func (m *Request) GetContext() *Context

func (*Request) GetType 

func (m *Request) GetType() MessageType

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

type Response 

type Response struct {
	Type                 MessageType               `protobuf:"varint,1,opt,name=type,enum=kvrpcpb.MessageType" json:"type"`
	RegionError          *errorpb.Error            `protobuf:"bytes,2,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	CmdGetResp           *CmdGetResponse           `protobuf:"bytes,3,opt,name=cmd_get_resp,json=cmdGetResp" json:"cmd_get_resp,omitempty"`
	CmdScanResp          *CmdScanResponse          `protobuf:"bytes,4,opt,name=cmd_scan_resp,json=cmdScanResp" json:"cmd_scan_resp,omitempty"`
	CmdPrewriteResp      *CmdPrewriteResponse      `protobuf:"bytes,5,opt,name=cmd_prewrite_resp,json=cmdPrewriteResp" json:"cmd_prewrite_resp,omitempty"`
	CmdCommitResp        *CmdCommitResponse        `protobuf:"bytes,6,opt,name=cmd_commit_resp,json=cmdCommitResp" json:"cmd_commit_resp,omitempty"`
	CmdCleanupResp       *CmdCleanupResponse       `protobuf:"bytes,7,opt,name=cmd_cleanup_resp,json=cmdCleanupResp" json:"cmd_cleanup_resp,omitempty"`
	CmdBatchGetResp      *CmdBatchGetResponse      `protobuf:"bytes,10,opt,name=cmd_batch_get_resp,json=cmdBatchGetResp" json:"cmd_batch_get_resp,omitempty"`
	CmdBatchRollbackResp *CmdBatchRollbackResponse `protobuf:"bytes,11,opt,name=cmd_batch_rollback_resp,json=cmdBatchRollbackResp" json:"cmd_batch_rollback_resp,omitempty"`
	CmdScanLockResp      *CmdScanLockResponse      `protobuf:"bytes,12,opt,name=cmd_scan_lock_resp,json=cmdScanLockResp" json:"cmd_scan_lock_resp,omitempty"`
	CmdResolveLockResp   *CmdResolveLockResponse   `protobuf:"bytes,13,opt,name=cmd_resolve_lock_resp,json=cmdResolveLockResp" json:"cmd_resolve_lock_resp,omitempty"`
	CmdGcResp            *CmdGCResponse            `protobuf:"bytes,14,opt,name=cmd_gc_resp,json=cmdGcResp" json:"cmd_gc_resp,omitempty"`
	CmdRawGetResp        *CmdRawGetResponse        `protobuf:"bytes,256,opt,name=cmd_raw_get_resp,json=cmdRawGetResp" json:"cmd_raw_get_resp,omitempty"`
	CmdRawPutResp        *CmdRawPutResponse        `protobuf:"bytes,257,opt,name=cmd_raw_put_resp,json=cmdRawPutResp" json:"cmd_raw_put_resp,omitempty"`
	CmdRawDeleteResp     *CmdRawDeleteResponse     `protobuf:"bytes,258,opt,name=cmd_raw_delete_resp,json=cmdRawDeleteResp" json:"cmd_raw_delete_resp,omitempty"`
	XXX_unrecognized     []byte                    `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetCmdBatchGetResp 

func (m *Response) GetCmdBatchGetResp() *CmdBatchGetResponse

func (*Response) GetCmdBatchRollbackResp 

func (m *Response) GetCmdBatchRollbackResp() *CmdBatchRollbackResponse

func (*Response) GetCmdCleanupResp 

func (m *Response) GetCmdCleanupResp() *CmdCleanupResponse

func (*Response) GetCmdCommitResp 

func (m *Response) GetCmdCommitResp() *CmdCommitResponse

func (*Response) GetCmdGcResp 

func (m *Response) GetCmdGcResp() *CmdGCResponse

func (*Response) GetCmdGetResp 

func (m *Response) GetCmdGetResp() *CmdGetResponse

func (*Response) GetCmdPrewriteResp 

func (m *Response) GetCmdPrewriteResp() *CmdPrewriteResponse

func (*Response) GetCmdRawDeleteResp 

func (m *Response) GetCmdRawDeleteResp() *CmdRawDeleteResponse

func (*Response) GetCmdRawGetResp 

func (m *Response) GetCmdRawGetResp() *CmdRawGetResponse

func (*Response) GetCmdRawPutResp 

func (m *Response) GetCmdRawPutResp() *CmdRawPutResponse

func (*Response) GetCmdResolveLockResp 

func (m *Response) GetCmdResolveLockResp() *CmdResolveLockResponse

func (*Response) GetCmdScanLockResp 

func (m *Response) GetCmdScanLockResp() *CmdScanLockResponse

func (*Response) GetCmdScanResp 

func (m *Response) GetCmdScanResp() *CmdScanResponse

func (*Response) GetRegionError 

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

func (*Response) GetType 

func (m *Response) GetType() MessageType

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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