kvrpcpb

package
v0.6.4 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2018 License: Apache-2.0 Imports: 8 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: 

KvPair
RequestHeader
ResponseHeader
DsKvRawGetRequest
DsKvRawGetResponse
KvRawGetRequest
KvRawGetResponse
DsKvRawPutRequest
DsKvRawPutResponse
KvRawPutRequest
KvRawPutResponse
DsKvRawDeleteRequest
DsKvRawDeleteResponse
KvRawDeleteRequest
KvRawDeleteResponse
KvPairRawExecute
DsKvRawExecuteRequest
DsKvRawExecuteResponse
KvRawExecuteRequest
KvRawExecuteResponse
Scope
SelectField
Match
Limit
DsSelectRequest
SelectRequest
Row
DsSelectResponse
SelectResponse
KeyValue
DsInsertRequest
DsInsertResponse
InsertRequest
InsertResponse
BatchInsertRequest
BatchInsertResponse
DsDeleteRequest
DsDeleteResponse
DeleteRequest
DeleteResponse
Field
RedisKeyValue
RedisDo
KvSetRequest
KvSetResponse
DsKvSetRequest
DsKvSetResponse
KvGetRequest
KvGetResponse
DsKvGetRequest
DsKvGetResponse
KvBatchSetRequest
KvBatchSetResponse
DsKvBatchSetRequest
DsKvBatchSetResponse
KvBatchGetRequest
KvBatchGetResponse
DsKvBatchGetRequest
DsKvBatchGetResponse
KvScanRequest
KvScanResponse
DsKvScanRequest
DsKvScanResponse
KvDeleteRequest
KvDeleteResponse
DsKvDeleteRequest
DsKvDeleteResponse
KvBatchDeleteRequest
KvBatchDeleteResponse
DsKvBatchDeleteRequest
DsKvBatchDeleteResponse
KvRangeDeleteRequest
KvRangeDeleteResponse
DsKvRangeDeleteRequest
DsKvRangeDeleteResponse
LockValue
LockRequest
DsLockRequest
LockResponse
LockInfo
LockScanResponse
DsLockResponse
LockUpdateRequest
DsLockUpdateRequest
DsLockUpdateResponse
UnlockRequest
DsUnlockRequest
DsUnlockResponse
UnlockForceRequest
DsUnlockForceRequest
DsUnlockForceResponse
LockScanRequest
DsLockScanRequest
DsLockScanResponse

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 ExecuteType_name = map[int32]string{
	0: "ExecInvalid",
	1: "ExecPut",
	2: "ExecDelete",
}
View Source 
var ExecuteType_value = map[string]int32{
	"ExecInvalid": 0,
	"ExecPut":     1,
	"ExecDelete":  2,
}
View Source 
var ExistCase_name = map[int32]string{
	0: "EC_Invalid",
	1: "EC_NotExists",
	2: "EC_Exists",
	3: "EC_AnyCase",
	4: "EC_Force",
}
View Source 
var ExistCase_value = map[string]int32{
	"EC_Invalid":   0,
	"EC_NotExists": 1,
	"EC_Exists":    2,
	"EC_AnyCase":   3,
	"EC_Force":     4,
}
View Source 
var MatchType_name = map[int32]string{
	0: "Invalid",
	1: "Equal",
	2: "NotEqual",
	3: "Less",
	4: "LessOrEqual",
	5: "Larger",
	6: "LargerOrEqual",
}
View Source 
var MatchType_value = map[string]int32{
	"Invalid":       0,
	"Equal":         1,
	"NotEqual":      2,
	"Less":          3,
	"LessOrEqual":   4,
	"Larger":        5,
	"LargerOrEqual": 6,
}
View Source 
var Operation_name = map[int32]string{
	0: "OP_Invalid",
	1: "OP_Set",
	2: "OP_Delete",
	3: "OP_Get",
}
View Source 
var Operation_value = map[string]int32{
	"OP_Invalid": 0,
	"OP_Set":     1,
	"OP_Delete":  2,
	"OP_Get":     3,
}
View Source 
var SelectField_Type_name = map[int32]string{
	0: "Column",
	1: "AggreFunction",
}
View Source 
var SelectField_Type_value = map[string]int32{
	"Column":        0,
	"AggreFunction": 1,
}

Functions

This section is empty.

Types

type BatchInsertRequest 

type BatchInsertRequest struct {
	Reqs []*InsertRequest `protobuf:"bytes,1,rep,name=reqs" json:"reqs,omitempty"`
}

func (*BatchInsertRequest) Descriptor 

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

func (*BatchInsertRequest) GetReqs 

func (m *BatchInsertRequest) GetReqs() []*InsertRequest

func (*BatchInsertRequest) Marshal 

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

func (*BatchInsertRequest) MarshalTo 

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

func (*BatchInsertRequest) ProtoMessage 

func (*BatchInsertRequest) ProtoMessage()

func (*BatchInsertRequest) Reset 

func (m *BatchInsertRequest) Reset()

func (*BatchInsertRequest) Size 

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

func (*BatchInsertRequest) String 

func (m *BatchInsertRequest) String() string

func (*BatchInsertRequest) Unmarshal 

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

type BatchInsertResponse 

type BatchInsertResponse struct {
	Resps []*InsertResponse `protobuf:"bytes,2,rep,name=resps" json:"resps,omitempty"`
}

func (*BatchInsertResponse) Descriptor 

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

func (*BatchInsertResponse) GetResps 

func (m *BatchInsertResponse) GetResps() []*InsertResponse

func (*BatchInsertResponse) Marshal 

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

func (*BatchInsertResponse) MarshalTo 

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

func (*BatchInsertResponse) ProtoMessage 

func (*BatchInsertResponse) ProtoMessage()

func (*BatchInsertResponse) Reset 

func (m *BatchInsertResponse) Reset()

func (*BatchInsertResponse) Size 

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

func (*BatchInsertResponse) String 

func (m *BatchInsertResponse) String() string

func (*BatchInsertResponse) Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Key          []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Scope        *Scope               `protobuf:"bytes,2,opt,name=scope" json:"scope,omitempty"`
	WhereFilters []*Match             `protobuf:"bytes,3,rep,name=where_filters,json=whereFilters" json:"where_filters,omitempty"`
	Indexs       []uint64             `protobuf:"varint,4,rep,packed,name=indexs" json:"indexs,omitempty"`
	Timestamp    *timestamp.Timestamp `protobuf:"bytes,10,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetIndexs 

func (m *DeleteRequest) GetIndexs() []uint64

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) GetScope 

func (m *DeleteRequest) GetScope() *Scope

func (*DeleteRequest) GetTimestamp 

func (m *DeleteRequest) GetTimestamp() *timestamp.Timestamp

func (*DeleteRequest) GetWhereFilters 

func (m *DeleteRequest) GetWhereFilters() []*Match

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 受影响的KV
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetAffectedKeys 

func (m *DeleteResponse) GetAffectedKeys() uint64

func (*DeleteResponse) GetCode 

func (m *DeleteResponse) GetCode() int32

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

type DsDeleteRequest 

type DsDeleteRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *DeleteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsDeleteRequest) Descriptor 

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

func (*DsDeleteRequest) GetHeader 

func (m *DsDeleteRequest) GetHeader() *RequestHeader

func (*DsDeleteRequest) GetReq 

func (m *DsDeleteRequest) GetReq() *DeleteRequest

func (*DsDeleteRequest) Marshal 

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

func (*DsDeleteRequest) MarshalTo 

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

func (*DsDeleteRequest) ProtoMessage 

func (*DsDeleteRequest) ProtoMessage()

func (*DsDeleteRequest) Reset 

func (m *DsDeleteRequest) Reset()

func (*DsDeleteRequest) Size 

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

func (*DsDeleteRequest) String 

func (m *DsDeleteRequest) String() string

func (*DsDeleteRequest) Unmarshal 

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

type DsDeleteResponse 

type DsDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *DeleteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsDeleteResponse) Descriptor 

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

func (*DsDeleteResponse) GetHeader 

func (m *DsDeleteResponse) GetHeader() *ResponseHeader

func (*DsDeleteResponse) GetResp 

func (m *DsDeleteResponse) GetResp() *DeleteResponse

func (*DsDeleteResponse) Marshal 

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

func (*DsDeleteResponse) MarshalTo 

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

func (*DsDeleteResponse) ProtoMessage 

func (*DsDeleteResponse) ProtoMessage()

func (*DsDeleteResponse) Reset 

func (m *DsDeleteResponse) Reset()

func (*DsDeleteResponse) Size 

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

func (*DsDeleteResponse) String 

func (m *DsDeleteResponse) String() string

func (*DsDeleteResponse) Unmarshal 

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

type DsInsertRequest 

type DsInsertRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *InsertRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsInsertRequest) Descriptor 

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

func (*DsInsertRequest) GetHeader 

func (m *DsInsertRequest) GetHeader() *RequestHeader

func (*DsInsertRequest) GetReq 

func (m *DsInsertRequest) GetReq() *InsertRequest

func (*DsInsertRequest) Marshal 

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

func (*DsInsertRequest) MarshalTo 

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

func (*DsInsertRequest) ProtoMessage 

func (*DsInsertRequest) ProtoMessage()

func (*DsInsertRequest) Reset 

func (m *DsInsertRequest) Reset()

func (*DsInsertRequest) Size 

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

func (*DsInsertRequest) String 

func (m *DsInsertRequest) String() string

func (*DsInsertRequest) Unmarshal 

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

type DsInsertResponse 

type DsInsertResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *InsertResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsInsertResponse) Descriptor 

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

func (*DsInsertResponse) GetHeader 

func (m *DsInsertResponse) GetHeader() *ResponseHeader

func (*DsInsertResponse) GetResp 

func (m *DsInsertResponse) GetResp() *InsertResponse

func (*DsInsertResponse) Marshal 

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

func (*DsInsertResponse) MarshalTo 

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

func (*DsInsertResponse) ProtoMessage 

func (*DsInsertResponse) ProtoMessage()

func (*DsInsertResponse) Reset 

func (m *DsInsertResponse) Reset()

func (*DsInsertResponse) Size 

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

func (*DsInsertResponse) String 

func (m *DsInsertResponse) String() string

func (*DsInsertResponse) Unmarshal 

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

type DsKvBatchDeleteRequest 

type DsKvBatchDeleteRequest struct {
	Header *RequestHeader        `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvBatchDeleteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvBatchDeleteRequest) Descriptor 

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

func (*DsKvBatchDeleteRequest) GetHeader 

func (m *DsKvBatchDeleteRequest) GetHeader() *RequestHeader

func (*DsKvBatchDeleteRequest) GetReq 

func (m *DsKvBatchDeleteRequest) GetReq() *KvBatchDeleteRequest

func (*DsKvBatchDeleteRequest) Marshal 

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

func (*DsKvBatchDeleteRequest) MarshalTo 

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

func (*DsKvBatchDeleteRequest) ProtoMessage 

func (*DsKvBatchDeleteRequest) ProtoMessage()

func (*DsKvBatchDeleteRequest) Reset 

func (m *DsKvBatchDeleteRequest) Reset()

func (*DsKvBatchDeleteRequest) Size 

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

func (*DsKvBatchDeleteRequest) String 

func (m *DsKvBatchDeleteRequest) String() string

func (*DsKvBatchDeleteRequest) Unmarshal 

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

type DsKvBatchDeleteResponse 

type DsKvBatchDeleteResponse struct {
	Header *ResponseHeader        `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvBatchDeleteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvBatchDeleteResponse) Descriptor 

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

func (*DsKvBatchDeleteResponse) GetHeader 

func (m *DsKvBatchDeleteResponse) GetHeader() *ResponseHeader

func (*DsKvBatchDeleteResponse) GetResp 

func (m *DsKvBatchDeleteResponse) GetResp() *KvBatchDeleteResponse

func (*DsKvBatchDeleteResponse) Marshal 

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

func (*DsKvBatchDeleteResponse) MarshalTo 

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

func (*DsKvBatchDeleteResponse) ProtoMessage 

func (*DsKvBatchDeleteResponse) ProtoMessage()

func (*DsKvBatchDeleteResponse) Reset 

func (m *DsKvBatchDeleteResponse) Reset()

func (*DsKvBatchDeleteResponse) Size 

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

func (*DsKvBatchDeleteResponse) String 

func (m *DsKvBatchDeleteResponse) String() string

func (*DsKvBatchDeleteResponse) Unmarshal 

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

type DsKvBatchGetRequest 

type DsKvBatchGetRequest struct {
	Header *RequestHeader     `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvBatchGetRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvBatchGetRequest) Descriptor 

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

func (*DsKvBatchGetRequest) GetHeader 

func (m *DsKvBatchGetRequest) GetHeader() *RequestHeader

func (*DsKvBatchGetRequest) GetReq 

func (m *DsKvBatchGetRequest) GetReq() *KvBatchGetRequest

func (*DsKvBatchGetRequest) Marshal 

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

func (*DsKvBatchGetRequest) MarshalTo 

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

func (*DsKvBatchGetRequest) ProtoMessage 

func (*DsKvBatchGetRequest) ProtoMessage()

func (*DsKvBatchGetRequest) Reset 

func (m *DsKvBatchGetRequest) Reset()

func (*DsKvBatchGetRequest) Size 

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

func (*DsKvBatchGetRequest) String 

func (m *DsKvBatchGetRequest) String() string

func (*DsKvBatchGetRequest) Unmarshal 

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

type DsKvBatchGetResponse 

type DsKvBatchGetResponse struct {
	Header *ResponseHeader     `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvBatchGetResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvBatchGetResponse) Descriptor 

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

func (*DsKvBatchGetResponse) GetHeader 

func (m *DsKvBatchGetResponse) GetHeader() *ResponseHeader

func (*DsKvBatchGetResponse) GetResp 

func (m *DsKvBatchGetResponse) GetResp() *KvBatchGetResponse

func (*DsKvBatchGetResponse) Marshal 

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

func (*DsKvBatchGetResponse) MarshalTo 

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

func (*DsKvBatchGetResponse) ProtoMessage 

func (*DsKvBatchGetResponse) ProtoMessage()

func (*DsKvBatchGetResponse) Reset 

func (m *DsKvBatchGetResponse) Reset()

func (*DsKvBatchGetResponse) Size 

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

func (*DsKvBatchGetResponse) String 

func (m *DsKvBatchGetResponse) String() string

func (*DsKvBatchGetResponse) Unmarshal 

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

type DsKvBatchSetRequest 

type DsKvBatchSetRequest struct {
	Header *RequestHeader     `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvBatchSetRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvBatchSetRequest) Descriptor 

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

func (*DsKvBatchSetRequest) GetHeader 

func (m *DsKvBatchSetRequest) GetHeader() *RequestHeader

func (*DsKvBatchSetRequest) GetReq 

func (m *DsKvBatchSetRequest) GetReq() *KvBatchSetRequest

func (*DsKvBatchSetRequest) Marshal 

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

func (*DsKvBatchSetRequest) MarshalTo 

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

func (*DsKvBatchSetRequest) ProtoMessage 

func (*DsKvBatchSetRequest) ProtoMessage()

func (*DsKvBatchSetRequest) Reset 

func (m *DsKvBatchSetRequest) Reset()

func (*DsKvBatchSetRequest) Size 

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

func (*DsKvBatchSetRequest) String 

func (m *DsKvBatchSetRequest) String() string

func (*DsKvBatchSetRequest) Unmarshal 

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

type DsKvBatchSetResponse 

type DsKvBatchSetResponse struct {
	Header *ResponseHeader     `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvBatchSetResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvBatchSetResponse) Descriptor 

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

func (*DsKvBatchSetResponse) GetHeader 

func (m *DsKvBatchSetResponse) GetHeader() *ResponseHeader

func (*DsKvBatchSetResponse) GetResp 

func (m *DsKvBatchSetResponse) GetResp() *KvBatchSetResponse

func (*DsKvBatchSetResponse) Marshal 

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

func (*DsKvBatchSetResponse) MarshalTo 

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

func (*DsKvBatchSetResponse) ProtoMessage 

func (*DsKvBatchSetResponse) ProtoMessage()

func (*DsKvBatchSetResponse) Reset 

func (m *DsKvBatchSetResponse) Reset()

func (*DsKvBatchSetResponse) Size 

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

func (*DsKvBatchSetResponse) String 

func (m *DsKvBatchSetResponse) String() string

func (*DsKvBatchSetResponse) Unmarshal 

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

type DsKvDeleteRequest 

type DsKvDeleteRequest struct {
	Header *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvDeleteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvDeleteRequest) Descriptor 

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

func (*DsKvDeleteRequest) GetHeader 

func (m *DsKvDeleteRequest) GetHeader() *RequestHeader

func (*DsKvDeleteRequest) GetReq 

func (m *DsKvDeleteRequest) GetReq() *KvDeleteRequest

func (*DsKvDeleteRequest) Marshal 

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

func (*DsKvDeleteRequest) MarshalTo 

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

func (*DsKvDeleteRequest) ProtoMessage 

func (*DsKvDeleteRequest) ProtoMessage()

func (*DsKvDeleteRequest) Reset 

func (m *DsKvDeleteRequest) Reset()

func (*DsKvDeleteRequest) Size 

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

func (*DsKvDeleteRequest) String 

func (m *DsKvDeleteRequest) String() string

func (*DsKvDeleteRequest) Unmarshal 

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

type DsKvDeleteResponse 

type DsKvDeleteResponse struct {
	Header *ResponseHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvDeleteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvDeleteResponse) Descriptor 

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

func (*DsKvDeleteResponse) GetHeader 

func (m *DsKvDeleteResponse) GetHeader() *ResponseHeader

func (*DsKvDeleteResponse) GetResp 

func (m *DsKvDeleteResponse) GetResp() *KvDeleteResponse

func (*DsKvDeleteResponse) Marshal 

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

func (*DsKvDeleteResponse) MarshalTo 

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

func (*DsKvDeleteResponse) ProtoMessage 

func (*DsKvDeleteResponse) ProtoMessage()

func (*DsKvDeleteResponse) Reset 

func (m *DsKvDeleteResponse) Reset()

func (*DsKvDeleteResponse) Size 

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

func (*DsKvDeleteResponse) String 

func (m *DsKvDeleteResponse) String() string

func (*DsKvDeleteResponse) Unmarshal 

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

type DsKvGetRequest 

type DsKvGetRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvGetRequest  `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvGetRequest) Descriptor 

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

func (*DsKvGetRequest) GetHeader 

func (m *DsKvGetRequest) GetHeader() *RequestHeader

func (*DsKvGetRequest) GetReq 

func (m *DsKvGetRequest) GetReq() *KvGetRequest

func (*DsKvGetRequest) Marshal 

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

func (*DsKvGetRequest) MarshalTo 

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

func (*DsKvGetRequest) ProtoMessage 

func (*DsKvGetRequest) ProtoMessage()

func (*DsKvGetRequest) Reset 

func (m *DsKvGetRequest) Reset()

func (*DsKvGetRequest) Size 

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

func (*DsKvGetRequest) String 

func (m *DsKvGetRequest) String() string

func (*DsKvGetRequest) Unmarshal 

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

type DsKvGetResponse 

type DsKvGetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvGetResponse  `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvGetResponse) Descriptor 

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

func (*DsKvGetResponse) GetHeader 

func (m *DsKvGetResponse) GetHeader() *ResponseHeader

func (*DsKvGetResponse) GetResp 

func (m *DsKvGetResponse) GetResp() *KvGetResponse

func (*DsKvGetResponse) Marshal 

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

func (*DsKvGetResponse) MarshalTo 

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

func (*DsKvGetResponse) ProtoMessage 

func (*DsKvGetResponse) ProtoMessage()

func (*DsKvGetResponse) Reset 

func (m *DsKvGetResponse) Reset()

func (*DsKvGetResponse) Size 

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

func (*DsKvGetResponse) String 

func (m *DsKvGetResponse) String() string

func (*DsKvGetResponse) Unmarshal 

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

type DsKvRangeDeleteRequest 

type DsKvRangeDeleteRequest struct {
	Header *RequestHeader        `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvRangeDeleteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvRangeDeleteRequest) Descriptor 

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

func (*DsKvRangeDeleteRequest) GetHeader 

func (m *DsKvRangeDeleteRequest) GetHeader() *RequestHeader

func (*DsKvRangeDeleteRequest) GetReq 

func (m *DsKvRangeDeleteRequest) GetReq() *KvRangeDeleteRequest

func (*DsKvRangeDeleteRequest) Marshal 

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

func (*DsKvRangeDeleteRequest) MarshalTo 

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

func (*DsKvRangeDeleteRequest) ProtoMessage 

func (*DsKvRangeDeleteRequest) ProtoMessage()

func (*DsKvRangeDeleteRequest) Reset 

func (m *DsKvRangeDeleteRequest) Reset()

func (*DsKvRangeDeleteRequest) Size 

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

func (*DsKvRangeDeleteRequest) String 

func (m *DsKvRangeDeleteRequest) String() string

func (*DsKvRangeDeleteRequest) Unmarshal 

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

type DsKvRangeDeleteResponse 

type DsKvRangeDeleteResponse struct {
	Header *ResponseHeader        `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvRangeDeleteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvRangeDeleteResponse) Descriptor 

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

func (*DsKvRangeDeleteResponse) GetHeader 

func (m *DsKvRangeDeleteResponse) GetHeader() *ResponseHeader

func (*DsKvRangeDeleteResponse) GetResp 

func (m *DsKvRangeDeleteResponse) GetResp() *KvRangeDeleteResponse

func (*DsKvRangeDeleteResponse) Marshal 

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

func (*DsKvRangeDeleteResponse) MarshalTo 

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

func (*DsKvRangeDeleteResponse) ProtoMessage 

func (*DsKvRangeDeleteResponse) ProtoMessage()

func (*DsKvRangeDeleteResponse) Reset 

func (m *DsKvRangeDeleteResponse) Reset()

func (*DsKvRangeDeleteResponse) Size 

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

func (*DsKvRangeDeleteResponse) String 

func (m *DsKvRangeDeleteResponse) String() string

func (*DsKvRangeDeleteResponse) Unmarshal 

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

type DsKvRawDeleteRequest 

type DsKvRawDeleteRequest struct {
	Header *RequestHeader      `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvRawDeleteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvRawDeleteRequest) Descriptor 

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

func (*DsKvRawDeleteRequest) GetHeader 

func (m *DsKvRawDeleteRequest) GetHeader() *RequestHeader

func (*DsKvRawDeleteRequest) GetReq 

func (m *DsKvRawDeleteRequest) GetReq() *KvRawDeleteRequest

func (*DsKvRawDeleteRequest) Marshal 

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

func (*DsKvRawDeleteRequest) MarshalTo 

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

func (*DsKvRawDeleteRequest) ProtoMessage 

func (*DsKvRawDeleteRequest) ProtoMessage()

func (*DsKvRawDeleteRequest) Reset 

func (m *DsKvRawDeleteRequest) Reset()

func (*DsKvRawDeleteRequest) Size 

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

func (*DsKvRawDeleteRequest) String 

func (m *DsKvRawDeleteRequest) String() string

func (*DsKvRawDeleteRequest) Unmarshal 

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

type DsKvRawDeleteResponse 

type DsKvRawDeleteResponse struct {
	Header *ResponseHeader      `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvRawDeleteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvRawDeleteResponse) Descriptor 

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

func (*DsKvRawDeleteResponse) GetHeader 

func (m *DsKvRawDeleteResponse) GetHeader() *ResponseHeader

func (*DsKvRawDeleteResponse) GetResp 

func (m *DsKvRawDeleteResponse) GetResp() *KvRawDeleteResponse

func (*DsKvRawDeleteResponse) Marshal 

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

func (*DsKvRawDeleteResponse) MarshalTo 

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

func (*DsKvRawDeleteResponse) ProtoMessage 

func (*DsKvRawDeleteResponse) ProtoMessage()

func (*DsKvRawDeleteResponse) Reset 

func (m *DsKvRawDeleteResponse) Reset()

func (*DsKvRawDeleteResponse) Size 

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

func (*DsKvRawDeleteResponse) String 

func (m *DsKvRawDeleteResponse) String() string

func (*DsKvRawDeleteResponse) Unmarshal 

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

type DsKvRawExecuteRequest 

type DsKvRawExecuteRequest struct {
	Header *RequestHeader       `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvRawExecuteRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvRawExecuteRequest) Descriptor 

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

func (*DsKvRawExecuteRequest) GetHeader 

func (m *DsKvRawExecuteRequest) GetHeader() *RequestHeader

func (*DsKvRawExecuteRequest) GetReq 

func (m *DsKvRawExecuteRequest) GetReq() *KvRawExecuteRequest

func (*DsKvRawExecuteRequest) Marshal 

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

func (*DsKvRawExecuteRequest) MarshalTo 

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

func (*DsKvRawExecuteRequest) ProtoMessage 

func (*DsKvRawExecuteRequest) ProtoMessage()

func (*DsKvRawExecuteRequest) Reset 

func (m *DsKvRawExecuteRequest) Reset()

func (*DsKvRawExecuteRequest) Size 

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

func (*DsKvRawExecuteRequest) String 

func (m *DsKvRawExecuteRequest) String() string

func (*DsKvRawExecuteRequest) Unmarshal 

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

type DsKvRawExecuteResponse 

type DsKvRawExecuteResponse struct {
	Header *ResponseHeader       `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvRawExecuteResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvRawExecuteResponse) Descriptor 

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

func (*DsKvRawExecuteResponse) GetHeader 

func (m *DsKvRawExecuteResponse) GetHeader() *ResponseHeader

func (*DsKvRawExecuteResponse) GetResp 

func (m *DsKvRawExecuteResponse) GetResp() *KvRawExecuteResponse

func (*DsKvRawExecuteResponse) Marshal 

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

func (*DsKvRawExecuteResponse) MarshalTo 

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

func (*DsKvRawExecuteResponse) ProtoMessage 

func (*DsKvRawExecuteResponse) ProtoMessage()

func (*DsKvRawExecuteResponse) Reset 

func (m *DsKvRawExecuteResponse) Reset()

func (*DsKvRawExecuteResponse) Size 

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

func (*DsKvRawExecuteResponse) String 

func (m *DsKvRawExecuteResponse) String() string

func (*DsKvRawExecuteResponse) Unmarshal 

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

type DsKvRawGetRequest 

type DsKvRawGetRequest struct {
	Header *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvRawGetRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvRawGetRequest) Descriptor 

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

func (*DsKvRawGetRequest) GetHeader 

func (m *DsKvRawGetRequest) GetHeader() *RequestHeader

func (*DsKvRawGetRequest) GetReq 

func (m *DsKvRawGetRequest) GetReq() *KvRawGetRequest

func (*DsKvRawGetRequest) Marshal 

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

func (*DsKvRawGetRequest) MarshalTo 

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

func (*DsKvRawGetRequest) ProtoMessage 

func (*DsKvRawGetRequest) ProtoMessage()

func (*DsKvRawGetRequest) Reset 

func (m *DsKvRawGetRequest) Reset()

func (*DsKvRawGetRequest) Size 

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

func (*DsKvRawGetRequest) String 

func (m *DsKvRawGetRequest) String() string

func (*DsKvRawGetRequest) Unmarshal 

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

type DsKvRawGetResponse 

type DsKvRawGetResponse struct {
	Header *ResponseHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvRawGetResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvRawGetResponse) Descriptor 

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

func (*DsKvRawGetResponse) GetHeader 

func (m *DsKvRawGetResponse) GetHeader() *ResponseHeader

func (*DsKvRawGetResponse) GetResp 

func (m *DsKvRawGetResponse) GetResp() *KvRawGetResponse

func (*DsKvRawGetResponse) Marshal 

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

func (*DsKvRawGetResponse) MarshalTo 

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

func (*DsKvRawGetResponse) ProtoMessage 

func (*DsKvRawGetResponse) ProtoMessage()

func (*DsKvRawGetResponse) Reset 

func (m *DsKvRawGetResponse) Reset()

func (*DsKvRawGetResponse) Size 

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

func (*DsKvRawGetResponse) String 

func (m *DsKvRawGetResponse) String() string

func (*DsKvRawGetResponse) Unmarshal 

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

type DsKvRawPutRequest 

type DsKvRawPutRequest struct {
	Header *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvRawPutRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvRawPutRequest) Descriptor 

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

func (*DsKvRawPutRequest) GetHeader 

func (m *DsKvRawPutRequest) GetHeader() *RequestHeader

func (*DsKvRawPutRequest) GetReq 

func (m *DsKvRawPutRequest) GetReq() *KvRawPutRequest

func (*DsKvRawPutRequest) Marshal 

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

func (*DsKvRawPutRequest) MarshalTo 

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

func (*DsKvRawPutRequest) ProtoMessage 

func (*DsKvRawPutRequest) ProtoMessage()

func (*DsKvRawPutRequest) Reset 

func (m *DsKvRawPutRequest) Reset()

func (*DsKvRawPutRequest) Size 

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

func (*DsKvRawPutRequest) String 

func (m *DsKvRawPutRequest) String() string

func (*DsKvRawPutRequest) Unmarshal 

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

type DsKvRawPutResponse 

type DsKvRawPutResponse struct {
	Header *ResponseHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvRawPutResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvRawPutResponse) Descriptor 

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

func (*DsKvRawPutResponse) GetHeader 

func (m *DsKvRawPutResponse) GetHeader() *ResponseHeader

func (*DsKvRawPutResponse) GetResp 

func (m *DsKvRawPutResponse) GetResp() *KvRawPutResponse

func (*DsKvRawPutResponse) Marshal 

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

func (*DsKvRawPutResponse) MarshalTo 

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

func (*DsKvRawPutResponse) ProtoMessage 

func (*DsKvRawPutResponse) ProtoMessage()

func (*DsKvRawPutResponse) Reset 

func (m *DsKvRawPutResponse) Reset()

func (*DsKvRawPutResponse) Size 

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

func (*DsKvRawPutResponse) String 

func (m *DsKvRawPutResponse) String() string

func (*DsKvRawPutResponse) Unmarshal 

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

type DsKvScanRequest 

type DsKvScanRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvScanRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvScanRequest) Descriptor 

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

func (*DsKvScanRequest) GetHeader 

func (m *DsKvScanRequest) GetHeader() *RequestHeader

func (*DsKvScanRequest) GetReq 

func (m *DsKvScanRequest) GetReq() *KvScanRequest

func (*DsKvScanRequest) Marshal 

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

func (*DsKvScanRequest) MarshalTo 

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

func (*DsKvScanRequest) ProtoMessage 

func (*DsKvScanRequest) ProtoMessage()

func (*DsKvScanRequest) Reset 

func (m *DsKvScanRequest) Reset()

func (*DsKvScanRequest) Size 

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

func (*DsKvScanRequest) String 

func (m *DsKvScanRequest) String() string

func (*DsKvScanRequest) Unmarshal 

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

type DsKvScanResponse 

type DsKvScanResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvScanResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvScanResponse) Descriptor 

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

func (*DsKvScanResponse) GetHeader 

func (m *DsKvScanResponse) GetHeader() *ResponseHeader

func (*DsKvScanResponse) GetResp 

func (m *DsKvScanResponse) GetResp() *KvScanResponse

func (*DsKvScanResponse) Marshal 

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

func (*DsKvScanResponse) MarshalTo 

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

func (*DsKvScanResponse) ProtoMessage 

func (*DsKvScanResponse) ProtoMessage()

func (*DsKvScanResponse) Reset 

func (m *DsKvScanResponse) Reset()

func (*DsKvScanResponse) Size 

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

func (*DsKvScanResponse) String 

func (m *DsKvScanResponse) String() string

func (*DsKvScanResponse) Unmarshal 

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

type DsKvSetRequest 

type DsKvSetRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *KvSetRequest  `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsKvSetRequest) Descriptor 

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

func (*DsKvSetRequest) GetHeader 

func (m *DsKvSetRequest) GetHeader() *RequestHeader

func (*DsKvSetRequest) GetReq 

func (m *DsKvSetRequest) GetReq() *KvSetRequest

func (*DsKvSetRequest) Marshal 

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

func (*DsKvSetRequest) MarshalTo 

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

func (*DsKvSetRequest) ProtoMessage 

func (*DsKvSetRequest) ProtoMessage()

func (*DsKvSetRequest) Reset 

func (m *DsKvSetRequest) Reset()

func (*DsKvSetRequest) Size 

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

func (*DsKvSetRequest) String 

func (m *DsKvSetRequest) String() string

func (*DsKvSetRequest) Unmarshal 

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

type DsKvSetResponse 

type DsKvSetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *KvSetResponse  `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsKvSetResponse) Descriptor 

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

func (*DsKvSetResponse) GetHeader 

func (m *DsKvSetResponse) GetHeader() *ResponseHeader

func (*DsKvSetResponse) GetResp 

func (m *DsKvSetResponse) GetResp() *KvSetResponse

func (*DsKvSetResponse) Marshal 

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

func (*DsKvSetResponse) MarshalTo 

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

func (*DsKvSetResponse) ProtoMessage 

func (*DsKvSetResponse) ProtoMessage()

func (*DsKvSetResponse) Reset 

func (m *DsKvSetResponse) Reset()

func (*DsKvSetResponse) Size 

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

func (*DsKvSetResponse) String 

func (m *DsKvSetResponse) String() string

func (*DsKvSetResponse) Unmarshal 

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

type DsLockRequest 

type DsLockRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *LockRequest   `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsLockRequest) Descriptor 

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

func (*DsLockRequest) GetHeader 

func (m *DsLockRequest) GetHeader() *RequestHeader

func (*DsLockRequest) GetReq 

func (m *DsLockRequest) GetReq() *LockRequest

func (*DsLockRequest) Marshal 

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

func (*DsLockRequest) MarshalTo 

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

func (*DsLockRequest) ProtoMessage 

func (*DsLockRequest) ProtoMessage()

func (*DsLockRequest) Reset 

func (m *DsLockRequest) Reset()

func (*DsLockRequest) Size 

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

func (*DsLockRequest) String 

func (m *DsLockRequest) String() string

func (*DsLockRequest) Unmarshal 

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

type DsLockResponse 

type DsLockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *LockResponse   `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsLockResponse) Descriptor 

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

func (*DsLockResponse) GetHeader 

func (m *DsLockResponse) GetHeader() *ResponseHeader

func (*DsLockResponse) GetResp 

func (m *DsLockResponse) GetResp() *LockResponse

func (*DsLockResponse) Marshal 

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

func (*DsLockResponse) MarshalTo 

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

func (*DsLockResponse) ProtoMessage 

func (*DsLockResponse) ProtoMessage()

func (*DsLockResponse) Reset 

func (m *DsLockResponse) Reset()

func (*DsLockResponse) Size 

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

func (*DsLockResponse) String 

func (m *DsLockResponse) String() string

func (*DsLockResponse) Unmarshal 

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

type DsLockScanRequest added in v0.6.3 

type DsLockScanRequest struct {
	Header *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *LockScanRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsLockScanRequest) Descriptor added in v0.6.3 

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

func (*DsLockScanRequest) GetHeader added in v0.6.3 

func (m *DsLockScanRequest) GetHeader() *RequestHeader

func (*DsLockScanRequest) GetReq added in v0.6.3 

func (m *DsLockScanRequest) GetReq() *LockScanRequest

func (*DsLockScanRequest) Marshal added in v0.6.3 

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

func (*DsLockScanRequest) MarshalTo added in v0.6.3 

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

func (*DsLockScanRequest) ProtoMessage added in v0.6.3 

func (*DsLockScanRequest) ProtoMessage()

func (*DsLockScanRequest) Reset added in v0.6.3 

func (m *DsLockScanRequest) Reset()

func (*DsLockScanRequest) Size added in v0.6.3 

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

func (*DsLockScanRequest) String added in v0.6.3 

func (m *DsLockScanRequest) String() string

func (*DsLockScanRequest) Unmarshal added in v0.6.3 

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

type DsLockScanResponse added in v0.6.3 

type DsLockScanResponse struct {
	Header *ResponseHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *LockScanResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsLockScanResponse) Descriptor added in v0.6.3 

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

func (*DsLockScanResponse) GetHeader added in v0.6.3 

func (m *DsLockScanResponse) GetHeader() *ResponseHeader

func (*DsLockScanResponse) GetResp added in v0.6.3 

func (m *DsLockScanResponse) GetResp() *LockScanResponse

func (*DsLockScanResponse) Marshal added in v0.6.3 

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

func (*DsLockScanResponse) MarshalTo added in v0.6.3 

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

func (*DsLockScanResponse) ProtoMessage added in v0.6.3 

func (*DsLockScanResponse) ProtoMessage()

func (*DsLockScanResponse) Reset added in v0.6.3 

func (m *DsLockScanResponse) Reset()

func (*DsLockScanResponse) Size added in v0.6.3 

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

func (*DsLockScanResponse) String added in v0.6.3 

func (m *DsLockScanResponse) String() string

func (*DsLockScanResponse) Unmarshal added in v0.6.3 

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

type DsLockUpdateRequest 

type DsLockUpdateRequest struct {
	Header *RequestHeader     `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *LockUpdateRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsLockUpdateRequest) Descriptor 

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

func (*DsLockUpdateRequest) GetHeader 

func (m *DsLockUpdateRequest) GetHeader() *RequestHeader

func (*DsLockUpdateRequest) GetReq 

func (m *DsLockUpdateRequest) GetReq() *LockUpdateRequest

func (*DsLockUpdateRequest) Marshal 

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

func (*DsLockUpdateRequest) MarshalTo 

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

func (*DsLockUpdateRequest) ProtoMessage 

func (*DsLockUpdateRequest) ProtoMessage()

func (*DsLockUpdateRequest) Reset 

func (m *DsLockUpdateRequest) Reset()

func (*DsLockUpdateRequest) Size 

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

func (*DsLockUpdateRequest) String 

func (m *DsLockUpdateRequest) String() string

func (*DsLockUpdateRequest) Unmarshal 

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

type DsLockUpdateResponse 

type DsLockUpdateResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *LockResponse   `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsLockUpdateResponse) Descriptor 

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

func (*DsLockUpdateResponse) GetHeader 

func (m *DsLockUpdateResponse) GetHeader() *ResponseHeader

func (*DsLockUpdateResponse) GetResp 

func (m *DsLockUpdateResponse) GetResp() *LockResponse

func (*DsLockUpdateResponse) Marshal 

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

func (*DsLockUpdateResponse) MarshalTo 

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

func (*DsLockUpdateResponse) ProtoMessage 

func (*DsLockUpdateResponse) ProtoMessage()

func (*DsLockUpdateResponse) Reset 

func (m *DsLockUpdateResponse) Reset()

func (*DsLockUpdateResponse) Size 

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

func (*DsLockUpdateResponse) String 

func (m *DsLockUpdateResponse) String() string

func (*DsLockUpdateResponse) Unmarshal 

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

type DsSelectRequest 

type DsSelectRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *SelectRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsSelectRequest) Descriptor 

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

func (*DsSelectRequest) GetHeader 

func (m *DsSelectRequest) GetHeader() *RequestHeader

func (*DsSelectRequest) GetReq 

func (m *DsSelectRequest) GetReq() *SelectRequest

func (*DsSelectRequest) Marshal 

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

func (*DsSelectRequest) MarshalTo 

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

func (*DsSelectRequest) ProtoMessage 

func (*DsSelectRequest) ProtoMessage()

func (*DsSelectRequest) Reset 

func (m *DsSelectRequest) Reset()

func (*DsSelectRequest) Size 

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

func (*DsSelectRequest) String 

func (m *DsSelectRequest) String() string

func (*DsSelectRequest) Unmarshal 

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

type DsSelectResponse 

type DsSelectResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *SelectResponse `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsSelectResponse) Descriptor 

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

func (*DsSelectResponse) GetHeader 

func (m *DsSelectResponse) GetHeader() *ResponseHeader

func (*DsSelectResponse) GetResp 

func (m *DsSelectResponse) GetResp() *SelectResponse

func (*DsSelectResponse) Marshal 

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

func (*DsSelectResponse) MarshalTo 

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

func (*DsSelectResponse) ProtoMessage 

func (*DsSelectResponse) ProtoMessage()

func (*DsSelectResponse) Reset 

func (m *DsSelectResponse) Reset()

func (*DsSelectResponse) Size 

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

func (*DsSelectResponse) String 

func (m *DsSelectResponse) String() string

func (*DsSelectResponse) Unmarshal 

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

type DsUnlockForceRequest 

type DsUnlockForceRequest struct {
	Header *RequestHeader      `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *UnlockForceRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsUnlockForceRequest) Descriptor 

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

func (*DsUnlockForceRequest) GetHeader 

func (m *DsUnlockForceRequest) GetHeader() *RequestHeader

func (*DsUnlockForceRequest) GetReq 

func (m *DsUnlockForceRequest) GetReq() *UnlockForceRequest

func (*DsUnlockForceRequest) Marshal 

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

func (*DsUnlockForceRequest) MarshalTo 

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

func (*DsUnlockForceRequest) ProtoMessage 

func (*DsUnlockForceRequest) ProtoMessage()

func (*DsUnlockForceRequest) Reset 

func (m *DsUnlockForceRequest) Reset()

func (*DsUnlockForceRequest) Size 

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

func (*DsUnlockForceRequest) String 

func (m *DsUnlockForceRequest) String() string

func (*DsUnlockForceRequest) Unmarshal 

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

type DsUnlockForceResponse 

type DsUnlockForceResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *LockResponse   `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsUnlockForceResponse) Descriptor 

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

func (*DsUnlockForceResponse) GetHeader 

func (m *DsUnlockForceResponse) GetHeader() *ResponseHeader

func (*DsUnlockForceResponse) GetResp 

func (m *DsUnlockForceResponse) GetResp() *LockResponse

func (*DsUnlockForceResponse) Marshal 

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

func (*DsUnlockForceResponse) MarshalTo 

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

func (*DsUnlockForceResponse) ProtoMessage 

func (*DsUnlockForceResponse) ProtoMessage()

func (*DsUnlockForceResponse) Reset 

func (m *DsUnlockForceResponse) Reset()

func (*DsUnlockForceResponse) Size 

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

func (*DsUnlockForceResponse) String 

func (m *DsUnlockForceResponse) String() string

func (*DsUnlockForceResponse) Unmarshal 

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

type DsUnlockRequest 

type DsUnlockRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Req    *UnlockRequest `protobuf:"bytes,2,opt,name=req" json:"req,omitempty"`
}

func (*DsUnlockRequest) Descriptor 

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

func (*DsUnlockRequest) GetHeader 

func (m *DsUnlockRequest) GetHeader() *RequestHeader

func (*DsUnlockRequest) GetReq 

func (m *DsUnlockRequest) GetReq() *UnlockRequest

func (*DsUnlockRequest) Marshal 

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

func (*DsUnlockRequest) MarshalTo 

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

func (*DsUnlockRequest) ProtoMessage 

func (*DsUnlockRequest) ProtoMessage()

func (*DsUnlockRequest) Reset 

func (m *DsUnlockRequest) Reset()

func (*DsUnlockRequest) Size 

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

func (*DsUnlockRequest) String 

func (m *DsUnlockRequest) String() string

func (*DsUnlockRequest) Unmarshal 

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

type DsUnlockResponse 

type DsUnlockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Resp   *LockResponse   `protobuf:"bytes,2,opt,name=resp" json:"resp,omitempty"`
}

func (*DsUnlockResponse) Descriptor 

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

func (*DsUnlockResponse) GetHeader 

func (m *DsUnlockResponse) GetHeader() *ResponseHeader

func (*DsUnlockResponse) GetResp 

func (m *DsUnlockResponse) GetResp() *LockResponse

func (*DsUnlockResponse) Marshal 

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

func (*DsUnlockResponse) MarshalTo 

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

func (*DsUnlockResponse) ProtoMessage 

func (*DsUnlockResponse) ProtoMessage()

func (*DsUnlockResponse) Reset 

func (m *DsUnlockResponse) Reset()

func (*DsUnlockResponse) Size 

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

func (*DsUnlockResponse) String 

func (m *DsUnlockResponse) String() string

func (*DsUnlockResponse) Unmarshal 

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

type ExecuteType 

type ExecuteType int32
const (
	ExecuteType_ExecInvalid ExecuteType = 0
	ExecuteType_ExecPut     ExecuteType = 1
	ExecuteType_ExecDelete  ExecuteType = 2
)

func (ExecuteType) EnumDescriptor 

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

func (ExecuteType) String 

func (x ExecuteType) String() string

type ExistCase 

type ExistCase int32

++++++++++++++++++++++++for jimdb-proxy protocol begin+++++++++++++++++++++++++++++++++++++ 

const (
	ExistCase_EC_Invalid ExistCase = 0
	// 当且仅当key不存在
	ExistCase_EC_NotExists ExistCase = 1
	// 当且仅当key存在
	ExistCase_EC_Exists ExistCase = 2
	// 需要检查key是否存在,无论key是否存在都写入, 并返回affected count
	ExistCase_EC_AnyCase ExistCase = 3
	// 不检查key是否存在,直接写入,不返回affected count
	ExistCase_EC_Force ExistCase = 4
)

func (ExistCase) EnumDescriptor 

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

func (ExistCase) String 

func (x ExistCase) String() string

type Field 

type Field struct {
	ColumnId uint64 `protobuf:"varint,1,opt,name=column_id,json=columnId,proto3" json:"column_id,omitempty"`
	// value是gateway server编码后的数据， data server不解析
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Field) Descriptor 

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

func (*Field) GetColumnId 

func (m *Field) GetColumnId() uint64

func (*Field) GetValue 

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

func (*Field) Marshal 

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

func (*Field) MarshalTo 

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

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

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

func (*Field) String 

func (m *Field) String() string

func (*Field) Unmarshal 

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

type InsertRequest 

type InsertRequest struct {
	Rows           []*KeyValue          `protobuf:"bytes,1,rep,name=rows" json:"rows,omitempty"`
	CheckDuplicate bool                 `protobuf:"varint,2,opt,name=check_duplicate,json=checkDuplicate,proto3" json:"check_duplicate,omitempty"`
	Timestamp      *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*InsertRequest) Descriptor 

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

func (*InsertRequest) GetCheckDuplicate 

func (m *InsertRequest) GetCheckDuplicate() bool

func (*InsertRequest) GetRows 

func (m *InsertRequest) GetRows() []*KeyValue

func (*InsertRequest) GetTimestamp 

func (m *InsertRequest) GetTimestamp() *timestamp.Timestamp

func (*InsertRequest) Marshal 

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

func (*InsertRequest) MarshalTo 

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

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) Reset 

func (m *InsertRequest) Reset()

func (*InsertRequest) Size 

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

func (*InsertRequest) String 

func (m *InsertRequest) String() string

func (*InsertRequest) Unmarshal 

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

type InsertResponse 

type InsertResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 受影响的KV
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
	// code != 0有效
	DuplicateKey []byte `protobuf:"bytes,3,opt,name=duplicate_key,json=duplicateKey,proto3" json:"duplicate_key,omitempty"`
}

func (*InsertResponse) Descriptor 

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

func (*InsertResponse) GetAffectedKeys 

func (m *InsertResponse) GetAffectedKeys() uint64

func (*InsertResponse) GetCode 

func (m *InsertResponse) GetCode() int32

func (*InsertResponse) GetDuplicateKey 

func (m *InsertResponse) GetDuplicateKey() []byte

func (*InsertResponse) Marshal 

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

func (*InsertResponse) MarshalTo 

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

func (*InsertResponse) ProtoMessage 

func (*InsertResponse) ProtoMessage()

func (*InsertResponse) Reset 

func (m *InsertResponse) Reset()

func (*InsertResponse) Size 

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

func (*InsertResponse) String 

func (m *InsertResponse) String() string

func (*InsertResponse) Unmarshal 

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

type KeyValue 

type KeyValue struct {
	Key      []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value    []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	ExpireAt int64  `protobuf:"varint,3,opt,name=ExpireAt,proto3" json:"ExpireAt,omitempty"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetExpireAt 

func (m *KeyValue) GetExpireAt() int64

func (*KeyValue) GetKey 

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

func (*KeyValue) GetValue 

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

func (*KeyValue) Marshal 

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

func (*KeyValue) MarshalTo 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

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

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

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

type KvBatchDeleteRequest 

type KvBatchDeleteRequest struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	// 暂时忽略,按照any case处理
	Case ExistCase `protobuf:"varint,2,opt,name=case,proto3,enum=kvrpcpb.ExistCase" json:"case,omitempty"`
}

func (*KvBatchDeleteRequest) Descriptor 

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

func (*KvBatchDeleteRequest) GetCase 

func (m *KvBatchDeleteRequest) GetCase() ExistCase

func (*KvBatchDeleteRequest) GetKeys 

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

func (*KvBatchDeleteRequest) Marshal 

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

func (*KvBatchDeleteRequest) MarshalTo 

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

func (*KvBatchDeleteRequest) ProtoMessage 

func (*KvBatchDeleteRequest) ProtoMessage()

func (*KvBatchDeleteRequest) Reset 

func (m *KvBatchDeleteRequest) Reset()

func (*KvBatchDeleteRequest) Size 

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

func (*KvBatchDeleteRequest) String 

func (m *KvBatchDeleteRequest) String() string

func (*KvBatchDeleteRequest) Unmarshal 

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

type KvBatchDeleteResponse 

type KvBatchDeleteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 删除key的个数，不包括被忽略的key
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
}

func (*KvBatchDeleteResponse) Descriptor 

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

func (*KvBatchDeleteResponse) GetAffectedKeys 

func (m *KvBatchDeleteResponse) GetAffectedKeys() uint64

func (*KvBatchDeleteResponse) GetCode 

func (m *KvBatchDeleteResponse) GetCode() int32

func (*KvBatchDeleteResponse) Marshal 

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

func (*KvBatchDeleteResponse) MarshalTo 

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

func (*KvBatchDeleteResponse) ProtoMessage 

func (*KvBatchDeleteResponse) ProtoMessage()

func (*KvBatchDeleteResponse) Reset 

func (m *KvBatchDeleteResponse) Reset()

func (*KvBatchDeleteResponse) Size 

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

func (*KvBatchDeleteResponse) String 

func (m *KvBatchDeleteResponse) String() string

func (*KvBatchDeleteResponse) Unmarshal 

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

type KvBatchGetRequest 

type KvBatchGetRequest struct {
	Code int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Keys [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
}

func (*KvBatchGetRequest) Descriptor 

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

func (*KvBatchGetRequest) GetCode 

func (m *KvBatchGetRequest) GetCode() int32

func (*KvBatchGetRequest) GetKeys 

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

func (*KvBatchGetRequest) Marshal 

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

func (*KvBatchGetRequest) MarshalTo 

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

func (*KvBatchGetRequest) ProtoMessage 

func (*KvBatchGetRequest) ProtoMessage()

func (*KvBatchGetRequest) Reset 

func (m *KvBatchGetRequest) Reset()

func (*KvBatchGetRequest) Size 

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

func (*KvBatchGetRequest) String 

func (m *KvBatchGetRequest) String() string

func (*KvBatchGetRequest) Unmarshal 

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

type KvBatchGetResponse 

type KvBatchGetResponse struct {
	Code int32            `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Kvs  []*RedisKeyValue `protobuf:"bytes,2,rep,name=kvs" json:"kvs,omitempty"`
}

func (*KvBatchGetResponse) Descriptor 

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

func (*KvBatchGetResponse) GetCode 

func (m *KvBatchGetResponse) GetCode() int32

func (*KvBatchGetResponse) GetKvs 

func (m *KvBatchGetResponse) GetKvs() []*RedisKeyValue

func (*KvBatchGetResponse) Marshal 

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

func (*KvBatchGetResponse) MarshalTo 

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

func (*KvBatchGetResponse) ProtoMessage 

func (*KvBatchGetResponse) ProtoMessage()

func (*KvBatchGetResponse) Reset 

func (m *KvBatchGetResponse) Reset()

func (*KvBatchGetResponse) Size 

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

func (*KvBatchGetResponse) String 

func (m *KvBatchGetResponse) String() string

func (*KvBatchGetResponse) Unmarshal 

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

type KvBatchSetRequest 

type KvBatchSetRequest struct {
	Kvs []*RedisKeyValue `protobuf:"bytes,1,rep,name=kvs" json:"kvs,omitempty"`
	// 如果case 是EC_NotExists
	// 首先需要检查读,一旦发现有key,则终止执行,并且返回存在重复的key的数量
	Case ExistCase `protobuf:"varint,2,opt,name=case,proto3,enum=kvrpcpb.ExistCase" json:"case,omitempty"`
}

func (*KvBatchSetRequest) Descriptor 

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

func (*KvBatchSetRequest) GetCase 

func (m *KvBatchSetRequest) GetCase() ExistCase

func (*KvBatchSetRequest) GetKvs 

func (m *KvBatchSetRequest) GetKvs() []*RedisKeyValue

func (*KvBatchSetRequest) Marshal 

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

func (*KvBatchSetRequest) MarshalTo 

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

func (*KvBatchSetRequest) ProtoMessage 

func (*KvBatchSetRequest) ProtoMessage()

func (*KvBatchSetRequest) Reset 

func (m *KvBatchSetRequest) Reset()

func (*KvBatchSetRequest) Size 

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

func (*KvBatchSetRequest) String 

func (m *KvBatchSetRequest) String() string

func (*KvBatchSetRequest) Unmarshal 

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

type KvBatchSetResponse 

type KvBatchSetResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 受影响的KV
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
}

func (*KvBatchSetResponse) Descriptor 

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

func (*KvBatchSetResponse) GetAffectedKeys 

func (m *KvBatchSetResponse) GetAffectedKeys() uint64

func (*KvBatchSetResponse) GetCode 

func (m *KvBatchSetResponse) GetCode() int32

func (*KvBatchSetResponse) Marshal 

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

func (*KvBatchSetResponse) MarshalTo 

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

func (*KvBatchSetResponse) ProtoMessage 

func (*KvBatchSetResponse) ProtoMessage()

func (*KvBatchSetResponse) Reset 

func (m *KvBatchSetResponse) Reset()

func (*KvBatchSetResponse) Size 

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

func (*KvBatchSetResponse) String 

func (m *KvBatchSetResponse) String() string

func (*KvBatchSetResponse) Unmarshal 

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

type KvDeleteRequest 

type KvDeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 暂时忽略,按照any case处理
	Case ExistCase `protobuf:"varint,2,opt,name=case,proto3,enum=kvrpcpb.ExistCase" json:"case,omitempty"`
}

func (*KvDeleteRequest) Descriptor 

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

func (*KvDeleteRequest) GetCase 

func (m *KvDeleteRequest) GetCase() ExistCase

func (*KvDeleteRequest) GetKey 

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

func (*KvDeleteRequest) Marshal 

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

func (*KvDeleteRequest) MarshalTo 

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

func (*KvDeleteRequest) ProtoMessage 

func (*KvDeleteRequest) ProtoMessage()

func (*KvDeleteRequest) Reset 

func (m *KvDeleteRequest) Reset()

func (*KvDeleteRequest) Size 

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

func (*KvDeleteRequest) String 

func (m *KvDeleteRequest) String() string

func (*KvDeleteRequest) Unmarshal 

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

type KvDeleteResponse 

type KvDeleteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 受影响的KV
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
}

func (*KvDeleteResponse) Descriptor 

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

func (*KvDeleteResponse) GetAffectedKeys 

func (m *KvDeleteResponse) GetAffectedKeys() uint64

func (*KvDeleteResponse) GetCode 

func (m *KvDeleteResponse) GetCode() int32

func (*KvDeleteResponse) Marshal 

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

func (*KvDeleteResponse) MarshalTo 

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

func (*KvDeleteResponse) ProtoMessage 

func (*KvDeleteResponse) ProtoMessage()

func (*KvDeleteResponse) Reset 

func (m *KvDeleteResponse) Reset()

func (*KvDeleteResponse) Size 

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

func (*KvDeleteResponse) String 

func (m *KvDeleteResponse) String() string

func (*KvDeleteResponse) Unmarshal 

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

type KvGetRequest 

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

func (*KvGetRequest) Descriptor 

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

func (*KvGetRequest) GetKey 

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

func (*KvGetRequest) Marshal 

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

func (*KvGetRequest) MarshalTo 

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

func (*KvGetRequest) ProtoMessage 

func (*KvGetRequest) ProtoMessage()

func (*KvGetRequest) Reset 

func (m *KvGetRequest) Reset()

func (*KvGetRequest) Size 

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

func (*KvGetRequest) String 

func (m *KvGetRequest) String() string

func (*KvGetRequest) Unmarshal 

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

type KvGetResponse 

type KvGetResponse struct {
	Code  int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KvGetResponse) Descriptor 

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

func (*KvGetResponse) GetCode 

func (m *KvGetResponse) GetCode() int32

func (*KvGetResponse) GetValue 

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

func (*KvGetResponse) Marshal 

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

func (*KvGetResponse) MarshalTo 

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

func (*KvGetResponse) ProtoMessage 

func (*KvGetResponse) ProtoMessage()

func (*KvGetResponse) Reset 

func (m *KvGetResponse) Reset()

func (*KvGetResponse) Size 

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

func (*KvGetResponse) String 

func (m *KvGetResponse) String() string

func (*KvGetResponse) Unmarshal 

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

type KvPair 

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

func (*KvPair) Descriptor 

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

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 KvPairRawExecute 

type KvPairRawExecute struct {
	Do     ExecuteType `protobuf:"varint,1,opt,name=do,proto3,enum=kvrpcpb.ExecuteType" json:"do,omitempty"`
	KvPair *KvPair     `protobuf:"bytes,2,opt,name=kv_pair,json=kvPair" json:"kv_pair,omitempty"`
}

func (*KvPairRawExecute) Descriptor 

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

func (*KvPairRawExecute) GetDo 

func (m *KvPairRawExecute) GetDo() ExecuteType

func (*KvPairRawExecute) GetKvPair 

func (m *KvPairRawExecute) GetKvPair() *KvPair

func (*KvPairRawExecute) Marshal 

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

func (*KvPairRawExecute) MarshalTo 

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

func (*KvPairRawExecute) ProtoMessage 

func (*KvPairRawExecute) ProtoMessage()

func (*KvPairRawExecute) Reset 

func (m *KvPairRawExecute) Reset()

func (*KvPairRawExecute) Size 

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

func (*KvPairRawExecute) String 

func (m *KvPairRawExecute) String() string

func (*KvPairRawExecute) Unmarshal 

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

type KvRangeDeleteRequest 

type KvRangeDeleteRequest struct {
	Start    []byte    `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit    []byte    `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	MaxCount int64     `protobuf:"varint,3,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	Case     ExistCase `protobuf:"varint,4,opt,name=case,proto3,enum=kvrpcpb.ExistCase" json:"case,omitempty"`
}

func (*KvRangeDeleteRequest) Descriptor 

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

func (*KvRangeDeleteRequest) GetCase 

func (m *KvRangeDeleteRequest) GetCase() ExistCase

func (*KvRangeDeleteRequest) GetLimit 

func (m *KvRangeDeleteRequest) GetLimit() []byte

func (*KvRangeDeleteRequest) GetMaxCount 

func (m *KvRangeDeleteRequest) GetMaxCount() int64

func (*KvRangeDeleteRequest) GetStart 

func (m *KvRangeDeleteRequest) GetStart() []byte

func (*KvRangeDeleteRequest) Marshal 

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

func (*KvRangeDeleteRequest) MarshalTo 

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

func (*KvRangeDeleteRequest) ProtoMessage 

func (*KvRangeDeleteRequest) ProtoMessage()

func (*KvRangeDeleteRequest) Reset 

func (m *KvRangeDeleteRequest) Reset()

func (*KvRangeDeleteRequest) Size 

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

func (*KvRangeDeleteRequest) String 

func (m *KvRangeDeleteRequest) String() string

func (*KvRangeDeleteRequest) Unmarshal 

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

type KvRangeDeleteResponse 

type KvRangeDeleteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 删除key的个数
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
	// 　最后一个被删除的key
	LastKey []byte `protobuf:"bytes,3,opt,name=last_key,json=lastKey,proto3" json:"last_key,omitempty"`
}

func (*KvRangeDeleteResponse) Descriptor 

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

func (*KvRangeDeleteResponse) GetAffectedKeys 

func (m *KvRangeDeleteResponse) GetAffectedKeys() uint64

func (*KvRangeDeleteResponse) GetCode 

func (m *KvRangeDeleteResponse) GetCode() int32

func (*KvRangeDeleteResponse) GetLastKey 

func (m *KvRangeDeleteResponse) GetLastKey() []byte

func (*KvRangeDeleteResponse) Marshal 

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

func (*KvRangeDeleteResponse) MarshalTo 

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

func (*KvRangeDeleteResponse) ProtoMessage 

func (*KvRangeDeleteResponse) ProtoMessage()

func (*KvRangeDeleteResponse) Reset 

func (m *KvRangeDeleteResponse) Reset()

func (*KvRangeDeleteResponse) Size 

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

func (*KvRangeDeleteResponse) String 

func (m *KvRangeDeleteResponse) String() string

func (*KvRangeDeleteResponse) Unmarshal 

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

type KvRawDeleteRequest 

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

func (*KvRawDeleteRequest) Descriptor 

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

func (*KvRawDeleteRequest) GetKey 

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

func (*KvRawDeleteRequest) Marshal 

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

func (*KvRawDeleteRequest) MarshalTo 

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

func (*KvRawDeleteRequest) ProtoMessage 

func (*KvRawDeleteRequest) ProtoMessage()

func (*KvRawDeleteRequest) Reset 

func (m *KvRawDeleteRequest) Reset()

func (*KvRawDeleteRequest) Size 

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

func (*KvRawDeleteRequest) String 

func (m *KvRawDeleteRequest) String() string

func (*KvRawDeleteRequest) Unmarshal 

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

type KvRawDeleteResponse 

type KvRawDeleteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
}

func (*KvRawDeleteResponse) Descriptor 

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

func (*KvRawDeleteResponse) GetCode 

func (m *KvRawDeleteResponse) GetCode() int32

func (*KvRawDeleteResponse) Marshal 

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

func (*KvRawDeleteResponse) MarshalTo 

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

func (*KvRawDeleteResponse) ProtoMessage 

func (*KvRawDeleteResponse) ProtoMessage()

func (*KvRawDeleteResponse) Reset 

func (m *KvRawDeleteResponse) Reset()

func (*KvRawDeleteResponse) Size 

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

func (*KvRawDeleteResponse) String 

func (m *KvRawDeleteResponse) String() string

func (*KvRawDeleteResponse) Unmarshal 

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

type KvRawExecuteRequest 

type KvRawExecuteRequest struct {
	// 历史原因，只能是2
	Execs []*KvPairRawExecute `protobuf:"bytes,1,rep,name=execs" json:"execs,omitempty"`
}

func (*KvRawExecuteRequest) Descriptor 

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

func (*KvRawExecuteRequest) GetExecs 

func (m *KvRawExecuteRequest) GetExecs() []*KvPairRawExecute

func (*KvRawExecuteRequest) Marshal 

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

func (*KvRawExecuteRequest) MarshalTo 

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

func (*KvRawExecuteRequest) ProtoMessage 

func (*KvRawExecuteRequest) ProtoMessage()

func (*KvRawExecuteRequest) Reset 

func (m *KvRawExecuteRequest) Reset()

func (*KvRawExecuteRequest) Size 

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

func (*KvRawExecuteRequest) String 

func (m *KvRawExecuteRequest) String() string

func (*KvRawExecuteRequest) Unmarshal 

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

type KvRawExecuteResponse 

type KvRawExecuteResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
}

func (*KvRawExecuteResponse) Descriptor 

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

func (*KvRawExecuteResponse) GetCode 

func (m *KvRawExecuteResponse) GetCode() int32

func (*KvRawExecuteResponse) Marshal 

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

func (*KvRawExecuteResponse) MarshalTo 

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

func (*KvRawExecuteResponse) ProtoMessage 

func (*KvRawExecuteResponse) ProtoMessage()

func (*KvRawExecuteResponse) Reset 

func (m *KvRawExecuteResponse) Reset()

func (*KvRawExecuteResponse) Size 

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

func (*KvRawExecuteResponse) String 

func (m *KvRawExecuteResponse) String() string

func (*KvRawExecuteResponse) Unmarshal 

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

type KvRawGetRequest 

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

func (*KvRawGetRequest) Descriptor 

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

func (*KvRawGetRequest) GetKey 

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

func (*KvRawGetRequest) Marshal 

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

func (*KvRawGetRequest) MarshalTo 

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

func (*KvRawGetRequest) ProtoMessage 

func (*KvRawGetRequest) ProtoMessage()

func (*KvRawGetRequest) Reset 

func (m *KvRawGetRequest) Reset()

func (*KvRawGetRequest) Size 

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

func (*KvRawGetRequest) String 

func (m *KvRawGetRequest) String() string

func (*KvRawGetRequest) Unmarshal 

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

type KvRawGetResponse 

type KvRawGetResponse struct {
	// 0: success 1: not leader 2: raft busy 3: other error
	Code  int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KvRawGetResponse) Descriptor 

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

func (*KvRawGetResponse) GetCode 

func (m *KvRawGetResponse) GetCode() int32

func (*KvRawGetResponse) GetValue 

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

func (*KvRawGetResponse) Marshal 

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

func (*KvRawGetResponse) MarshalTo 

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

func (*KvRawGetResponse) ProtoMessage 

func (*KvRawGetResponse) ProtoMessage()

func (*KvRawGetResponse) Reset 

func (m *KvRawGetResponse) Reset()

func (*KvRawGetResponse) Size 

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

func (*KvRawGetResponse) String 

func (m *KvRawGetResponse) String() string

func (*KvRawGetResponse) Unmarshal 

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

type KvRawPutRequest 

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

func (*KvRawPutRequest) Descriptor 

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

func (*KvRawPutRequest) GetKey 

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

func (*KvRawPutRequest) GetValue 

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

func (*KvRawPutRequest) Marshal 

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

func (*KvRawPutRequest) MarshalTo 

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

func (*KvRawPutRequest) ProtoMessage 

func (*KvRawPutRequest) ProtoMessage()

func (*KvRawPutRequest) Reset 

func (m *KvRawPutRequest) Reset()

func (*KvRawPutRequest) Size 

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

func (*KvRawPutRequest) String 

func (m *KvRawPutRequest) String() string

func (*KvRawPutRequest) Unmarshal 

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

type KvRawPutResponse 

type KvRawPutResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
}

func (*KvRawPutResponse) Descriptor 

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

func (*KvRawPutResponse) GetCode 

func (m *KvRawPutResponse) GetCode() int32

func (*KvRawPutResponse) Marshal 

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

func (*KvRawPutResponse) MarshalTo 

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

func (*KvRawPutResponse) ProtoMessage 

func (*KvRawPutResponse) ProtoMessage()

func (*KvRawPutResponse) Reset 

func (m *KvRawPutResponse) Reset()

func (*KvRawPutResponse) Size 

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

func (*KvRawPutResponse) String 

func (m *KvRawPutResponse) String() string

func (*KvRawPutResponse) Unmarshal 

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

type KvScanRequest 

type KvScanRequest struct {
	Start     []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit     []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	CountOnly bool   `protobuf:"varint,3,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// count_only与key_only冲突，二选一
	KeyOnly bool `protobuf:"varint,4,opt,name=key_only,json=keyOnly,proto3" json:"key_only,omitempty"`
	// -1 表示不限制
	MaxCount int64 `protobuf:"varint,5,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
}

迭代一个较大的范围，可以设置一个比较合适的max_count, 根据上次的last key作为下一次请求的start　key即可.

func (*KvScanRequest) Descriptor 

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

func (*KvScanRequest) GetCountOnly 

func (m *KvScanRequest) GetCountOnly() bool

func (*KvScanRequest) GetKeyOnly 

func (m *KvScanRequest) GetKeyOnly() bool

func (*KvScanRequest) GetLimit 

func (m *KvScanRequest) GetLimit() []byte

func (*KvScanRequest) GetMaxCount 

func (m *KvScanRequest) GetMaxCount() int64

func (*KvScanRequest) GetStart 

func (m *KvScanRequest) GetStart() []byte

func (*KvScanRequest) Marshal 

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

func (*KvScanRequest) MarshalTo 

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

func (*KvScanRequest) ProtoMessage 

func (*KvScanRequest) ProtoMessage()

func (*KvScanRequest) Reset 

func (m *KvScanRequest) Reset()

func (*KvScanRequest) Size 

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

func (*KvScanRequest) String 

func (m *KvScanRequest) String() string

func (*KvScanRequest) Unmarshal 

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

type KvScanResponse 

type KvScanResponse struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// when count_only  == true
	Count int64            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Kvs   []*RedisKeyValue `protobuf:"bytes,3,rep,name=kvs" json:"kvs,omitempty"`
	// 可能扫描返回的数据量很大，需要迭代
	LastKey []byte `protobuf:"bytes,4,opt,name=last_key,json=lastKey,proto3" json:"last_key,omitempty"`
}

func (*KvScanResponse) Descriptor 

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

func (*KvScanResponse) GetCode 

func (m *KvScanResponse) GetCode() int32

func (*KvScanResponse) GetCount 

func (m *KvScanResponse) GetCount() int64

func (*KvScanResponse) GetKvs 

func (m *KvScanResponse) GetKvs() []*RedisKeyValue

func (*KvScanResponse) GetLastKey 

func (m *KvScanResponse) GetLastKey() []byte

func (*KvScanResponse) Marshal 

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

func (*KvScanResponse) MarshalTo 

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

func (*KvScanResponse) ProtoMessage 

func (*KvScanResponse) ProtoMessage()

func (*KvScanResponse) Reset 

func (m *KvScanResponse) Reset()

func (*KvScanResponse) Size 

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

func (*KvScanResponse) String 

func (m *KvScanResponse) String() string

func (*KvScanResponse) Unmarshal 

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

type KvSetRequest 

type KvSetRequest struct {
	Kv   *RedisKeyValue `protobuf:"bytes,1,opt,name=kv" json:"kv,omitempty"`
	Case ExistCase      `protobuf:"varint,2,opt,name=case,proto3,enum=kvrpcpb.ExistCase" json:"case,omitempty"`
}

func (*KvSetRequest) Descriptor 

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

func (*KvSetRequest) GetCase 

func (m *KvSetRequest) GetCase() ExistCase

func (*KvSetRequest) GetKv 

func (m *KvSetRequest) GetKv() *RedisKeyValue

func (*KvSetRequest) Marshal 

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

func (*KvSetRequest) MarshalTo 

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

func (*KvSetRequest) ProtoMessage 

func (*KvSetRequest) ProtoMessage()

func (*KvSetRequest) Reset 

func (m *KvSetRequest) Reset()

func (*KvSetRequest) Size 

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

func (*KvSetRequest) String 

func (m *KvSetRequest) String() string

func (*KvSetRequest) Unmarshal 

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

type KvSetResponse 

type KvSetResponse struct {
	// 0: 成功; other: 失败
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// 受影响的KV
	AffectedKeys uint64 `protobuf:"varint,2,opt,name=affected_keys,json=affectedKeys,proto3" json:"affected_keys,omitempty"`
}

func (*KvSetResponse) Descriptor 

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

func (*KvSetResponse) GetAffectedKeys 

func (m *KvSetResponse) GetAffectedKeys() uint64

func (*KvSetResponse) GetCode 

func (m *KvSetResponse) GetCode() int32

func (*KvSetResponse) Marshal 

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

func (*KvSetResponse) MarshalTo 

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

func (*KvSetResponse) ProtoMessage 

func (*KvSetResponse) ProtoMessage()

func (*KvSetResponse) Reset 

func (m *KvSetResponse) Reset()

func (*KvSetResponse) Size 

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

func (*KvSetResponse) String 

func (m *KvSetResponse) String() string

func (*KvSetResponse) Unmarshal 

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

type Limit 

type Limit struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count  uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

func (*Limit) Descriptor 

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

func (*Limit) GetCount 

func (m *Limit) GetCount() uint64

func (*Limit) GetOffset 

func (m *Limit) GetOffset() uint64

func (*Limit) Marshal 

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

func (*Limit) MarshalTo 

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

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) Reset 

func (m *Limit) Reset()

func (*Limit) Size 

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

func (*Limit) String 

func (m *Limit) String() string

func (*Limit) Unmarshal 

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

type LockInfo added in v0.6.3 

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

func (*LockInfo) Descriptor added in v0.6.3 

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

func (*LockInfo) GetKey added in v0.6.3 

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

func (*LockInfo) GetValue added in v0.6.3 

func (m *LockInfo) GetValue() *LockValue

func (*LockInfo) Marshal added in v0.6.3 

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

func (*LockInfo) MarshalTo added in v0.6.3 

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

func (*LockInfo) ProtoMessage added in v0.6.3 

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset added in v0.6.3 

func (m *LockInfo) Reset()

func (*LockInfo) Size added in v0.6.3 

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

func (*LockInfo) String added in v0.6.3 

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal added in v0.6.3 

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

type LockRequest 

type LockRequest struct {
	Key       []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     *LockValue           `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,10,opt,name=timestamp" json:"timestamp,omitempty"`
	By        string               `protobuf:"bytes,11,opt,name=by,proto3" json:"by,omitempty"`
}

func (*LockRequest) Descriptor 

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

func (*LockRequest) GetBy 

func (m *LockRequest) GetBy() string

func (*LockRequest) GetKey 

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

func (*LockRequest) GetTimestamp 

func (m *LockRequest) GetTimestamp() *timestamp.Timestamp

func (*LockRequest) GetValue 

func (m *LockRequest) GetValue() *LockValue

func (*LockRequest) Marshal 

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

func (*LockRequest) MarshalTo 

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

func (*LockRequest) ProtoMessage 

func (*LockRequest) ProtoMessage()

func (*LockRequest) Reset 

func (m *LockRequest) Reset()

func (*LockRequest) Size 

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

func (*LockRequest) String 

func (m *LockRequest) String() string

func (*LockRequest) Unmarshal 

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

type LockResponse 

type LockResponse struct {
	Code       int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,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"`
	UpdateTime int64  `protobuf:"varint,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
}

func (*LockResponse) Descriptor 

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

func (*LockResponse) GetCode 

func (m *LockResponse) GetCode() int64

func (*LockResponse) GetError 

func (m *LockResponse) GetError() string

func (*LockResponse) GetUpdateTime 

func (m *LockResponse) GetUpdateTime() int64

func (*LockResponse) GetValue 

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

func (*LockResponse) Marshal 

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

func (*LockResponse) MarshalTo 

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

func (*LockResponse) ProtoMessage 

func (*LockResponse) ProtoMessage()

func (*LockResponse) Reset 

func (m *LockResponse) Reset()

func (*LockResponse) Size 

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

func (*LockResponse) String 

func (m *LockResponse) String() string

func (*LockResponse) Unmarshal 

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

type LockScanRequest added in v0.6.3 

type LockScanRequest struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Count uint32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
}

func (*LockScanRequest) Descriptor added in v0.6.3 

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

func (*LockScanRequest) GetCount added in v0.6.3 

func (m *LockScanRequest) GetCount() uint32

func (*LockScanRequest) GetLimit added in v0.6.3 

func (m *LockScanRequest) GetLimit() []byte

func (*LockScanRequest) GetStart added in v0.6.3 

func (m *LockScanRequest) GetStart() []byte

func (*LockScanRequest) Marshal added in v0.6.3 

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

func (*LockScanRequest) MarshalTo added in v0.6.3 

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

func (*LockScanRequest) ProtoMessage added in v0.6.3 

func (*LockScanRequest) ProtoMessage()

func (*LockScanRequest) Reset added in v0.6.3 

func (m *LockScanRequest) Reset()

func (*LockScanRequest) Size added in v0.6.3 

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

func (*LockScanRequest) String added in v0.6.3 

func (m *LockScanRequest) String() string

func (*LockScanRequest) Unmarshal added in v0.6.3 

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

type LockScanResponse added in v0.6.3 

type LockScanResponse struct {
	Info    []*LockInfo `protobuf:"bytes,1,rep,name=info" json:"info,omitempty"`
	LastKey []byte      `protobuf:"bytes,2,opt,name=last_key,json=lastKey,proto3" json:"last_key,omitempty"`
}

func (*LockScanResponse) Descriptor added in v0.6.3 

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

func (*LockScanResponse) GetInfo added in v0.6.3 

func (m *LockScanResponse) GetInfo() []*LockInfo

func (*LockScanResponse) GetLastKey added in v0.6.3 

func (m *LockScanResponse) GetLastKey() []byte

func (*LockScanResponse) Marshal added in v0.6.3 

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

func (*LockScanResponse) MarshalTo added in v0.6.3 

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

func (*LockScanResponse) ProtoMessage added in v0.6.3 

func (*LockScanResponse) ProtoMessage()

func (*LockScanResponse) Reset added in v0.6.3 

func (m *LockScanResponse) Reset()

func (*LockScanResponse) Size added in v0.6.3 

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

func (*LockScanResponse) String added in v0.6.3 

func (m *LockScanResponse) String() string

func (*LockScanResponse) Unmarshal added in v0.6.3 

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

type LockUpdateRequest 

type LockUpdateRequest struct {
	Key         []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Id          string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	UpdateTime  int64                `protobuf:"varint,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	UpdateValue []byte               `protobuf:"bytes,6,opt,name=update_value,json=updateValue,proto3" json:"update_value,omitempty"`
	Timestamp   *timestamp.Timestamp `protobuf:"bytes,10,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*LockUpdateRequest) Descriptor 

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

func (*LockUpdateRequest) GetId 

func (m *LockUpdateRequest) GetId() string

func (*LockUpdateRequest) GetKey 

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

func (*LockUpdateRequest) GetTimestamp 

func (m *LockUpdateRequest) GetTimestamp() *timestamp.Timestamp

func (*LockUpdateRequest) GetUpdateTime 

func (m *LockUpdateRequest) GetUpdateTime() int64

func (*LockUpdateRequest) GetUpdateValue 

func (m *LockUpdateRequest) GetUpdateValue() []byte

func (*LockUpdateRequest) Marshal 

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

func (*LockUpdateRequest) MarshalTo 

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

func (*LockUpdateRequest) ProtoMessage 

func (*LockUpdateRequest) ProtoMessage()

func (*LockUpdateRequest) Reset 

func (m *LockUpdateRequest) Reset()

func (*LockUpdateRequest) Size 

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

func (*LockUpdateRequest) String 

func (m *LockUpdateRequest) String() string

func (*LockUpdateRequest) Unmarshal 

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

type LockValue 

type LockValue struct {
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Id         string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	DeleteTime int64  `protobuf:"varint,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	UpdateTime int64  `protobuf:"varint,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	DeleteFlag bool   `protobuf:"varint,6,opt,name=delete_flag,json=deleteFlag,proto3" json:"delete_flag,omitempty"`
}

func (*LockValue) Descriptor 

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

func (*LockValue) GetDeleteFlag 

func (m *LockValue) GetDeleteFlag() bool

func (*LockValue) GetDeleteTime 

func (m *LockValue) GetDeleteTime() int64

func (*LockValue) GetId 

func (m *LockValue) GetId() string

func (*LockValue) GetUpdateTime 

func (m *LockValue) GetUpdateTime() int64

func (*LockValue) GetValue 

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

func (*LockValue) Marshal 

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

func (*LockValue) MarshalTo 

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

func (*LockValue) ProtoMessage 

func (*LockValue) ProtoMessage()

func (*LockValue) Reset 

func (m *LockValue) Reset()

func (*LockValue) Size 

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

func (*LockValue) String 

func (m *LockValue) String() string

func (*LockValue) Unmarshal 

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

type Match 

type Match struct {
	Column *metapb.Column `protobuf:"bytes,1,opt,name=column" json:"column,omitempty"`
	// 匹配对象
	Threshold []byte    `protobuf:"bytes,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	MatchType MatchType `protobuf:"varint,3,opt,name=match_type,json=matchType,proto3,enum=kvrpcpb.MatchType" json:"match_type,omitempty"`
}

func (*Match) Descriptor 

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

func (*Match) GetColumn 

func (m *Match) GetColumn() *metapb.Column

func (*Match) GetMatchType 

func (m *Match) GetMatchType() MatchType

func (*Match) GetThreshold 

func (m *Match) GetThreshold() []byte

func (*Match) Marshal 

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

func (*Match) MarshalTo 

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

func (*Match) ProtoMessage 

func (*Match) ProtoMessage()

func (*Match) Reset 

func (m *Match) Reset()

func (*Match) Size 

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

func (*Match) String 

func (m *Match) String() string

func (*Match) Unmarshal 

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

type MatchType 

type MatchType int32
const (
	MatchType_Invalid       MatchType = 0
	MatchType_Equal         MatchType = 1
	MatchType_NotEqual      MatchType = 2
	MatchType_Less          MatchType = 3
	MatchType_LessOrEqual   MatchType = 4
	MatchType_Larger        MatchType = 5
	MatchType_LargerOrEqual MatchType = 6
)

func (MatchType) EnumDescriptor 

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

func (MatchType) String 

func (x MatchType) String() string

type Operation 

type Operation int32
const (
	Operation_OP_Invalid Operation = 0
	Operation_OP_Set     Operation = 1
	Operation_OP_Delete  Operation = 2
	Operation_OP_Get     Operation = 3
)

func (Operation) EnumDescriptor 

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

func (Operation) String 

func (x Operation) String() string

type RedisDo 

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

func (*RedisDo) Descriptor 

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

func (*RedisDo) GetCase 

func (m *RedisDo) GetCase() ExistCase

func (*RedisDo) GetKey 

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

func (*RedisDo) GetOp 

func (m *RedisDo) GetOp() Operation

func (*RedisDo) GetValue 

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

func (*RedisDo) Marshal 

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

func (*RedisDo) MarshalTo 

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

func (*RedisDo) ProtoMessage 

func (*RedisDo) ProtoMessage()

func (*RedisDo) Reset 

func (m *RedisDo) Reset()

func (*RedisDo) Size 

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

func (*RedisDo) String 

func (m *RedisDo) String() string

func (*RedisDo) Unmarshal 

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

type RedisKeyValue 

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

func (*RedisKeyValue) Descriptor 

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

func (*RedisKeyValue) GetKey 

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

func (*RedisKeyValue) GetValue 

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

func (*RedisKeyValue) Marshal 

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

func (*RedisKeyValue) MarshalTo 

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

func (*RedisKeyValue) ProtoMessage 

func (*RedisKeyValue) ProtoMessage()

func (*RedisKeyValue) Reset 

func (m *RedisKeyValue) Reset()

func (*RedisKeyValue) Size 

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

func (*RedisKeyValue) String 

func (m *RedisKeyValue) String() string

func (*RedisKeyValue) Unmarshal 

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

type RequestHeader 

type RequestHeader struct {
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// timestamp specifies time at which read or writes should be
	// performed. If the timestamp is set to zero value, its value
	// is initialized to the wall time of the receiving node.
	Timestamp  *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	TraceId    uint64               `protobuf:"varint,3,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	RangeId    uint64               `protobuf:"varint,4,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	RangeEpoch *metapb.RangeEpoch   `protobuf:"bytes,5,opt,name=range_epoch,json=rangeEpoch" json:"range_epoch,omitempty"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) GetRangeEpoch 

func (m *RequestHeader) GetRangeEpoch() *metapb.RangeEpoch

func (*RequestHeader) GetRangeId 

func (m *RequestHeader) GetRangeId() uint64

func (*RequestHeader) GetTimestamp 

func (m *RequestHeader) GetTimestamp() *timestamp.Timestamp

func (*RequestHeader) GetTraceId 

func (m *RequestHeader) GetTraceId() uint64

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

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

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

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

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// timestamp is set only for non-transactional responses and denotes the
	// highest timestamp at which a command from the batch executed. At the
	// time of writing, it is used solely for informational purposes and tests.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	TraceId   uint64               `protobuf:"varint,3,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// now is the current time at the node sending the response,
	// which can be used by the receiver to update its local HLC.
	Now   *timestamp.Timestamp `protobuf:"bytes,4,opt,name=now" json:"now,omitempty"`
	Error *errorpb.Error       `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterId 

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() *errorpb.Error

func (*ResponseHeader) GetNow 

func (m *ResponseHeader) GetNow() *timestamp.Timestamp

func (*ResponseHeader) GetTimestamp 

func (m *ResponseHeader) GetTimestamp() *timestamp.Timestamp

func (*ResponseHeader) GetTraceId 

func (m *ResponseHeader) GetTraceId() uint64

func (*ResponseHeader) Marshal 

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

func (*ResponseHeader) MarshalTo 

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

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

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

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

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

type Row 

type Row struct {
	Key          []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Fields       []byte  `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	AggredCounts []int64 `protobuf:"varint,3,rep,packed,name=aggred_counts,json=aggredCounts" json:"aggred_counts,omitempty"`
}

func (*Row) Descriptor 

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

func (*Row) GetAggredCounts 

func (m *Row) GetAggredCounts() []int64

func (*Row) GetFields 

func (m *Row) GetFields() []byte

func (*Row) GetKey 

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

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (m *Row) String() string

func (*Row) Unmarshal 

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

type Scope 

type Scope struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
}

for SQL

func (*Scope) Descriptor 

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

func (*Scope) GetLimit 

func (m *Scope) GetLimit() []byte

func (*Scope) GetStart 

func (m *Scope) GetStart() []byte

func (*Scope) Marshal 

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

func (*Scope) MarshalTo 

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

func (*Scope) ProtoMessage 

func (*Scope) ProtoMessage()

func (*Scope) Reset 

func (m *Scope) Reset()

func (*Scope) Size 

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

func (*Scope) String 

func (m *Scope) String() string

func (*Scope) Unmarshal 

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

type SelectField 

type SelectField struct {
	Typ       SelectField_Type `protobuf:"varint,1,opt,name=typ,proto3,enum=kvrpcpb.SelectField_Type" json:"typ,omitempty"`
	AggreFunc string           `protobuf:"bytes,2,opt,name=aggre_func,json=aggreFunc,proto3" json:"aggre_func,omitempty"`
	Column    *metapb.Column   `protobuf:"bytes,3,opt,name=column" json:"column,omitempty"`
}

func (*SelectField) Descriptor 

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

func (*SelectField) GetAggreFunc 

func (m *SelectField) GetAggreFunc() string

func (*SelectField) GetColumn 

func (m *SelectField) GetColumn() *metapb.Column

func (*SelectField) GetTyp 

func (m *SelectField) GetTyp() SelectField_Type

func (*SelectField) Marshal 

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

func (*SelectField) MarshalTo 

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

func (*SelectField) ProtoMessage 

func (*SelectField) ProtoMessage()

func (*SelectField) Reset 

func (m *SelectField) Reset()

func (*SelectField) Size 

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

func (*SelectField) String 

func (m *SelectField) String() string

func (*SelectField) Unmarshal 

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

type SelectField_Type 

type SelectField_Type int32
const (
	SelectField_Column        SelectField_Type = 0
	SelectField_AggreFunction SelectField_Type = 1
)

func (SelectField_Type) EnumDescriptor 

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

func (SelectField_Type) String 

func (x SelectField_Type) String() string

type SelectRequest 

type SelectRequest struct {
	Key          []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Scope        *Scope               `protobuf:"bytes,2,opt,name=scope" json:"scope,omitempty"`
	FieldList    []*SelectField       `protobuf:"bytes,3,rep,name=field_list,json=fieldList" json:"field_list,omitempty"`
	WhereFilters []*Match             `protobuf:"bytes,4,rep,name=where_filters,json=whereFilters" json:"where_filters,omitempty"`
	GroupBys     []*metapb.Column     `protobuf:"bytes,5,rep,name=group_bys,json=groupBys" json:"group_bys,omitempty"`
	Limit        *Limit               `protobuf:"bytes,6,opt,name=limit" json:"limit,omitempty"`
	Timestamp    *timestamp.Timestamp `protobuf:"bytes,7,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*SelectRequest) Descriptor 

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

func (*SelectRequest) GetFieldList 

func (m *SelectRequest) GetFieldList() []*SelectField

func (*SelectRequest) GetGroupBys 

func (m *SelectRequest) GetGroupBys() []*metapb.Column

func (*SelectRequest) GetKey 

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

func (*SelectRequest) GetLimit 

func (m *SelectRequest) GetLimit() *Limit

func (*SelectRequest) GetScope 

func (m *SelectRequest) GetScope() *Scope

func (*SelectRequest) GetTimestamp 

func (m *SelectRequest) GetTimestamp() *timestamp.Timestamp

func (*SelectRequest) GetWhereFilters 

func (m *SelectRequest) GetWhereFilters() []*Match

func (*SelectRequest) Marshal 

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

func (*SelectRequest) MarshalTo 

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

func (*SelectRequest) ProtoMessage 

func (*SelectRequest) ProtoMessage()

func (*SelectRequest) Reset 

func (m *SelectRequest) Reset()

func (*SelectRequest) Size 

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

func (*SelectRequest) String 

func (m *SelectRequest) String() string

func (*SelectRequest) Unmarshal 

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

type SelectResponse 

type SelectResponse struct {
	// 0: success 1: not leader 2: raft busy 3: raft stop 4: read only 5: other error
	// >= 1000 SQL server error code
	// >= 2000 SQL client error code
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Rows []*Row `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	// for limit, offset in the range
	Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*SelectResponse) Descriptor 

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

func (*SelectResponse) GetCode 

func (m *SelectResponse) GetCode() int32

func (*SelectResponse) GetOffset 

func (m *SelectResponse) GetOffset() uint64

func (*SelectResponse) GetRows 

func (m *SelectResponse) GetRows() []*Row

func (*SelectResponse) Marshal 

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

func (*SelectResponse) MarshalTo 

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

func (*SelectResponse) ProtoMessage 

func (*SelectResponse) ProtoMessage()

func (*SelectResponse) Reset 

func (m *SelectResponse) Reset()

func (*SelectResponse) Size 

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

func (*SelectResponse) String 

func (m *SelectResponse) String() string

func (*SelectResponse) Unmarshal 

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

type UnlockForceRequest 

type UnlockForceRequest struct {
	Key       []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,10,opt,name=timestamp" json:"timestamp,omitempty"`
	By        string               `protobuf:"bytes,11,opt,name=by,proto3" json:"by,omitempty"`
}

func (*UnlockForceRequest) Descriptor 

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

func (*UnlockForceRequest) GetBy 

func (m *UnlockForceRequest) GetBy() string

func (*UnlockForceRequest) GetKey 

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

func (*UnlockForceRequest) GetTimestamp 

func (m *UnlockForceRequest) GetTimestamp() *timestamp.Timestamp

func (*UnlockForceRequest) Marshal 

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

func (*UnlockForceRequest) MarshalTo 

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

func (*UnlockForceRequest) ProtoMessage 

func (*UnlockForceRequest) ProtoMessage()

func (*UnlockForceRequest) Reset 

func (m *UnlockForceRequest) Reset()

func (*UnlockForceRequest) Size 

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

func (*UnlockForceRequest) String 

func (m *UnlockForceRequest) String() string

func (*UnlockForceRequest) Unmarshal 

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

type UnlockRequest 

type UnlockRequest struct {
	Key       []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Id        string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,10,opt,name=timestamp" json:"timestamp,omitempty"`
	By        string               `protobuf:"bytes,11,opt,name=by,proto3" json:"by,omitempty"`
}

func (*UnlockRequest) Descriptor 

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

func (*UnlockRequest) GetBy 

func (m *UnlockRequest) GetBy() string

func (*UnlockRequest) GetId 

func (m *UnlockRequest) GetId() string

func (*UnlockRequest) GetKey 

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

func (*UnlockRequest) GetTimestamp 

func (m *UnlockRequest) GetTimestamp() *timestamp.Timestamp

func (*UnlockRequest) Marshal 

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

func (*UnlockRequest) MarshalTo 

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

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) Reset 

func (m *UnlockRequest) Reset()

func (*UnlockRequest) Size 

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

func (*UnlockRequest) String 

func (m *UnlockRequest) String() string

func (*UnlockRequest) Unmarshal 

func (m *UnlockRequest) 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.