Documentation ¶
Overview ¶
Package raftcmdpb is a generated protocol buffer package.
It is generated from these files:
raftcmdpb.proto
It has these top-level messages:
RaftRequestHeader RaftResponseHeader RaftCMDRequest RaftCMDResponse AdminRequest AdminResponse ChangePeerRequest ChangePeerResponse SplitRequest SplitResponse TransferLeaderRequest TransferLeaderResponse RaftLogGCRequest RaftLogGCResponse FVPair ScorePair Request Response
Index ¶
- Variables
- type AdminCmdType
- type AdminRequest
- func (*AdminRequest) Descriptor() ([]byte, []int)
- func (m *AdminRequest) GetBody() []byte
- func (m *AdminRequest) GetType() AdminCmdType
- func (m *AdminRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminRequest) ProtoMessage()
- func (m *AdminRequest) Reset()
- func (m *AdminRequest) Size() (n int)
- func (m *AdminRequest) String() string
- func (m *AdminRequest) Unmarshal(dAtA []byte) error
- type AdminResponse
- func (*AdminResponse) Descriptor() ([]byte, []int)
- func (m *AdminResponse) GetBody() []byte
- func (m *AdminResponse) GetType() AdminCmdType
- func (m *AdminResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminResponse) ProtoMessage()
- func (m *AdminResponse) Reset()
- func (m *AdminResponse) Size() (n int)
- func (m *AdminResponse) String() string
- func (m *AdminResponse) Unmarshal(dAtA []byte) error
- type CMDType
- type ChangePeerRequest
- func (*ChangePeerRequest) Descriptor() ([]byte, []int)
- func (m *ChangePeerRequest) GetChangeType() pdpb.ConfChangeType
- func (m *ChangePeerRequest) GetPeer() metapb.Peer
- func (m *ChangePeerRequest) Marshal() (dAtA []byte, err error)
- func (m *ChangePeerRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ChangePeerRequest) ProtoMessage()
- func (m *ChangePeerRequest) Reset()
- func (m *ChangePeerRequest) Size() (n int)
- func (m *ChangePeerRequest) String() string
- func (m *ChangePeerRequest) Unmarshal(dAtA []byte) error
- type ChangePeerResponse
- func (*ChangePeerResponse) Descriptor() ([]byte, []int)
- func (m *ChangePeerResponse) GetCell() metapb.Cell
- func (m *ChangePeerResponse) Marshal() (dAtA []byte, err error)
- func (m *ChangePeerResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ChangePeerResponse) ProtoMessage()
- func (m *ChangePeerResponse) Reset()
- func (m *ChangePeerResponse) Size() (n int)
- func (m *ChangePeerResponse) String() string
- func (m *ChangePeerResponse) Unmarshal(dAtA []byte) error
- type FVPair
- func (*FVPair) Descriptor() ([]byte, []int)
- func (m *FVPair) GetField() []byte
- func (m *FVPair) GetValue() []byte
- func (m *FVPair) Marshal() (dAtA []byte, err error)
- func (m *FVPair) MarshalTo(dAtA []byte) (int, error)
- func (*FVPair) ProtoMessage()
- func (m *FVPair) Reset()
- func (m *FVPair) Size() (n int)
- func (m *FVPair) String() string
- func (m *FVPair) Unmarshal(dAtA []byte) error
- type RaftCMDRequest
- func (*RaftCMDRequest) Descriptor() ([]byte, []int)
- func (m *RaftCMDRequest) GetAdminRequest() *AdminRequest
- func (m *RaftCMDRequest) GetHeader() *RaftRequestHeader
- func (m *RaftCMDRequest) GetRequests() []*Request
- func (m *RaftCMDRequest) Marshal() (dAtA []byte, err error)
- func (m *RaftCMDRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RaftCMDRequest) ProtoMessage()
- func (m *RaftCMDRequest) Reset()
- func (m *RaftCMDRequest) Size() (n int)
- func (m *RaftCMDRequest) String() string
- func (m *RaftCMDRequest) Unmarshal(dAtA []byte) error
- type RaftCMDResponse
- func (*RaftCMDResponse) Descriptor() ([]byte, []int)
- func (m *RaftCMDResponse) GetAdminResponse() *AdminResponse
- func (m *RaftCMDResponse) GetHeader() *RaftResponseHeader
- func (m *RaftCMDResponse) GetResponses() []*Response
- func (m *RaftCMDResponse) Marshal() (dAtA []byte, err error)
- func (m *RaftCMDResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RaftCMDResponse) ProtoMessage()
- func (m *RaftCMDResponse) Reset()
- func (m *RaftCMDResponse) Size() (n int)
- func (m *RaftCMDResponse) String() string
- func (m *RaftCMDResponse) Unmarshal(dAtA []byte) error
- type RaftLogGCRequest
- func (*RaftLogGCRequest) Descriptor() ([]byte, []int)
- func (m *RaftLogGCRequest) GetCompactIndex() uint64
- func (m *RaftLogGCRequest) GetCompactTerm() uint64
- func (m *RaftLogGCRequest) Marshal() (dAtA []byte, err error)
- func (m *RaftLogGCRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RaftLogGCRequest) ProtoMessage()
- func (m *RaftLogGCRequest) Reset()
- func (m *RaftLogGCRequest) Size() (n int)
- func (m *RaftLogGCRequest) String() string
- func (m *RaftLogGCRequest) Unmarshal(dAtA []byte) error
- type RaftLogGCResponse
- func (*RaftLogGCResponse) Descriptor() ([]byte, []int)
- func (m *RaftLogGCResponse) Marshal() (dAtA []byte, err error)
- func (m *RaftLogGCResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RaftLogGCResponse) ProtoMessage()
- func (m *RaftLogGCResponse) Reset()
- func (m *RaftLogGCResponse) Size() (n int)
- func (m *RaftLogGCResponse) String() string
- func (m *RaftLogGCResponse) Unmarshal(dAtA []byte) error
- type RaftRequestHeader
- func (*RaftRequestHeader) Descriptor() ([]byte, []int)
- func (m *RaftRequestHeader) GetCellEpoch() metapb.CellEpoch
- func (m *RaftRequestHeader) GetCellId() uint64
- func (m *RaftRequestHeader) GetPeer() metapb.Peer
- func (m *RaftRequestHeader) GetReadQuorum() bool
- func (m *RaftRequestHeader) GetTerm() uint64
- func (m *RaftRequestHeader) GetUUID() []byte
- func (m *RaftRequestHeader) Marshal() (dAtA []byte, err error)
- func (m *RaftRequestHeader) MarshalTo(dAtA []byte) (int, error)
- func (*RaftRequestHeader) ProtoMessage()
- func (m *RaftRequestHeader) Reset()
- func (m *RaftRequestHeader) Size() (n int)
- func (m *RaftRequestHeader) String() string
- func (m *RaftRequestHeader) Unmarshal(dAtA []byte) error
- type RaftResponseHeader
- func (*RaftResponseHeader) Descriptor() ([]byte, []int)
- func (m *RaftResponseHeader) GetCurrentTerm() uint64
- func (m *RaftResponseHeader) GetError() errorpb.Error
- func (m *RaftResponseHeader) GetUUID() []byte
- func (m *RaftResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *RaftResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (*RaftResponseHeader) ProtoMessage()
- func (m *RaftResponseHeader) Reset()
- func (m *RaftResponseHeader) Size() (n int)
- func (m *RaftResponseHeader) String() string
- func (m *RaftResponseHeader) Unmarshal(dAtA []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetCmd() [][]byte
- func (m *Request) GetEpoch() uint64
- func (m *Request) GetLastStageAt() int64
- func (m *Request) GetSessionID() int64
- func (m *Request) GetStartAt() int64
- func (m *Request) GetType() CMDType
- func (m *Request) GetUUID() []byte
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetBulkResult() []byte
- func (m *Response) GetDocArrayResult() []*querypb.Document
- func (m *Response) GetError() errorpb.Error
- func (m *Response) GetErrorResult() []byte
- func (m *Response) GetErrorResults() [][]byte
- func (m *Response) GetFvPairArrayResult() []*FVPair
- func (m *Response) GetHasEmptyBulkResult() bool
- func (m *Response) GetHasEmptyDocArrayResult() bool
- func (m *Response) GetHasEmptyFVPairArrayResult() bool
- func (m *Response) GetHasEmptyScorePairArrayResult() bool
- func (m *Response) GetHasEmptySliceArrayResult() bool
- func (m *Response) GetIntegerResult() int64
- func (m *Response) GetOriginRequest() *Request
- func (m *Response) GetScorePairArrayResult() []*ScorePair
- func (m *Response) GetSessionID() int64
- func (m *Response) GetSliceArrayResult() [][]byte
- func (m *Response) GetStatusResult() []byte
- func (m *Response) GetType() CMDType
- func (m *Response) GetUUID() []byte
- func (m *Response) GetWithscores() bool
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- type ScorePair
- func (*ScorePair) Descriptor() ([]byte, []int)
- func (m *ScorePair) GetMember() []byte
- func (m *ScorePair) GetScore() float64
- func (m *ScorePair) Marshal() (dAtA []byte, err error)
- func (m *ScorePair) MarshalTo(dAtA []byte) (int, error)
- func (*ScorePair) ProtoMessage()
- func (m *ScorePair) Reset()
- func (m *ScorePair) Size() (n int)
- func (m *ScorePair) String() string
- func (m *ScorePair) Unmarshal(dAtA []byte) error
- type SplitRequest
- func (*SplitRequest) Descriptor() ([]byte, []int)
- func (m *SplitRequest) GetNewCellID() uint64
- func (m *SplitRequest) GetNewPeerIDs() []uint64
- func (m *SplitRequest) GetRightDerive() bool
- func (m *SplitRequest) GetSplitKey() []byte
- func (m *SplitRequest) Marshal() (dAtA []byte, err error)
- func (m *SplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SplitRequest) ProtoMessage()
- func (m *SplitRequest) Reset()
- func (m *SplitRequest) Size() (n int)
- func (m *SplitRequest) String() string
- func (m *SplitRequest) Unmarshal(dAtA []byte) error
- type SplitResponse
- func (*SplitResponse) Descriptor() ([]byte, []int)
- func (m *SplitResponse) GetLeft() metapb.Cell
- func (m *SplitResponse) GetRight() metapb.Cell
- func (m *SplitResponse) Marshal() (dAtA []byte, err error)
- func (m *SplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SplitResponse) ProtoMessage()
- func (m *SplitResponse) Reset()
- func (m *SplitResponse) Size() (n int)
- func (m *SplitResponse) String() string
- func (m *SplitResponse) Unmarshal(dAtA []byte) error
- type TransferLeaderRequest
- func (*TransferLeaderRequest) Descriptor() ([]byte, []int)
- func (m *TransferLeaderRequest) GetPeer() metapb.Peer
- func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error)
- func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TransferLeaderRequest) ProtoMessage()
- func (m *TransferLeaderRequest) Reset()
- func (m *TransferLeaderRequest) Size() (n int)
- func (m *TransferLeaderRequest) String() string
- func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error
- type TransferLeaderResponse
- func (*TransferLeaderResponse) Descriptor() ([]byte, []int)
- func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error)
- func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TransferLeaderResponse) ProtoMessage()
- func (m *TransferLeaderResponse) Reset()
- func (m *TransferLeaderResponse) Size() (n int)
- func (m *TransferLeaderResponse) String() string
- func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthRaftcmdpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRaftcmdpb = fmt.Errorf("proto: integer overflow") )
View Source
var AdminCmdType_name = map[int32]string{
0: "InvalidAdmin",
1: "ChangePeer",
2: "Split",
3: "RaftLogGC",
4: "TransferLeader",
5: "ComputeHash",
6: "VerifyHash",
}
View Source
var AdminCmdType_value = map[string]int32{
"InvalidAdmin": 0,
"ChangePeer": 1,
"Split": 2,
"RaftLogGC": 3,
"TransferLeader": 4,
"ComputeHash": 5,
"VerifyHash": 6,
}
View Source
var CMDType_name = map[int32]string{
0: "Invalid",
1: "RaftError",
2: "Snap",
100: "Ping",
101: "Del",
200: "Set",
201: "Get",
202: "MSet",
203: "MGet",
204: "Incrby",
205: "Decrby",
206: "GetSet",
207: "Append",
208: "Setnx",
209: "StrLen",
210: "Incr",
211: "Decr",
212: "SetRange",
213: "MSetNX",
300: "HSet",
301: "HGet",
302: "HDel",
303: "HExists",
304: "HKeys",
305: "HVals",
306: "HGetAll",
307: "HLen",
308: "HMGet",
309: "HMSet",
310: "HSetNX",
311: "HStrLen",
312: "HIncrBy",
400: "LIndex",
401: "LInsert",
402: "LLEN",
403: "LPop",
404: "LPush",
405: "LPushX",
406: "LRange",
407: "LRem",
408: "LSet",
409: "LTrim",
410: "RPop",
411: "RPopLPush",
412: "RPush",
413: "RPushX",
500: "SAdd",
501: "SCard",
502: "SRem",
503: "SMembers",
504: "SIsMember",
505: "SPop",
600: "ZAdd",
601: "ZCard",
602: "ZCount",
603: "ZIncrBy",
604: "ZLexCount",
605: "ZRange",
606: "ZRangeByLex",
607: "ZRangeByScore",
608: "ZRank",
609: "ZRem",
611: "ZRemRangeByLex",
612: "ZRemRangeByRank",
613: "ZRemRangeByScore",
614: "ZScore",
}
View Source
var CMDType_value = map[string]int32{
"Invalid": 0,
"RaftError": 1,
"Snap": 2,
"Ping": 100,
"Del": 101,
"Set": 200,
"Get": 201,
"MSet": 202,
"MGet": 203,
"Incrby": 204,
"Decrby": 205,
"GetSet": 206,
"Append": 207,
"Setnx": 208,
"StrLen": 209,
"Incr": 210,
"Decr": 211,
"SetRange": 212,
"MSetNX": 213,
"HSet": 300,
"HGet": 301,
"HDel": 302,
"HExists": 303,
"HKeys": 304,
"HVals": 305,
"HGetAll": 306,
"HLen": 307,
"HMGet": 308,
"HMSet": 309,
"HSetNX": 310,
"HStrLen": 311,
"HIncrBy": 312,
"LIndex": 400,
"LInsert": 401,
"LLEN": 402,
"LPop": 403,
"LPush": 404,
"LPushX": 405,
"LRange": 406,
"LRem": 407,
"LSet": 408,
"LTrim": 409,
"RPop": 410,
"RPopLPush": 411,
"RPush": 412,
"RPushX": 413,
"SAdd": 500,
"SCard": 501,
"SRem": 502,
"SMembers": 503,
"SIsMember": 504,
"SPop": 505,
"ZAdd": 600,
"ZCard": 601,
"ZCount": 602,
"ZIncrBy": 603,
"ZLexCount": 604,
"ZRange": 605,
"ZRangeByLex": 606,
"ZRangeByScore": 607,
"ZRank": 608,
"ZRem": 609,
"ZRemRangeByLex": 611,
"ZRemRangeByRank": 612,
"ZRemRangeByScore": 613,
"ZScore": 614,
}
Functions ¶
This section is empty.
Types ¶
type AdminCmdType ¶
type AdminCmdType int32
const ( InvalidAdmin AdminCmdType = 0 ChangePeer AdminCmdType = 1 Split AdminCmdType = 2 RaftLogGC AdminCmdType = 3 TransferLeader AdminCmdType = 4 ComputeHash AdminCmdType = 5 VerifyHash AdminCmdType = 6 )
func (AdminCmdType) Enum ¶
func (x AdminCmdType) Enum() *AdminCmdType
func (AdminCmdType) EnumDescriptor ¶
func (AdminCmdType) EnumDescriptor() ([]byte, []int)
func (AdminCmdType) String ¶
func (x AdminCmdType) String() string
func (*AdminCmdType) UnmarshalJSON ¶
func (x *AdminCmdType) UnmarshalJSON(data []byte) error
type AdminRequest ¶
type AdminRequest struct { Type AdminCmdType `protobuf:"varint,1,opt,name=type,enum=raftcmdpb.AdminCmdType" json:"type"` Body []byte `protobuf:"bytes,2,opt,name=body" json:"body,omitempty"` XXX_unrecognized []byte `json:"-"` }
admin request
func (*AdminRequest) Descriptor ¶
func (*AdminRequest) Descriptor() ([]byte, []int)
func (*AdminRequest) GetBody ¶
func (m *AdminRequest) GetBody() []byte
func (*AdminRequest) GetType ¶
func (m *AdminRequest) GetType() AdminCmdType
func (*AdminRequest) Marshal ¶
func (m *AdminRequest) Marshal() (dAtA []byte, err error)
func (*AdminRequest) ProtoMessage ¶
func (*AdminRequest) ProtoMessage()
func (*AdminRequest) Reset ¶
func (m *AdminRequest) Reset()
func (*AdminRequest) Size ¶
func (m *AdminRequest) Size() (n int)
func (*AdminRequest) String ¶
func (m *AdminRequest) String() string
func (*AdminRequest) Unmarshal ¶
func (m *AdminRequest) Unmarshal(dAtA []byte) error
type AdminResponse ¶
type AdminResponse struct { Type AdminCmdType `protobuf:"varint,1,opt,name=type,enum=raftcmdpb.AdminCmdType" json:"type"` Body []byte `protobuf:"bytes,2,opt,name=body" json:"body,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AdminResponse) Descriptor ¶
func (*AdminResponse) Descriptor() ([]byte, []int)
func (*AdminResponse) GetBody ¶
func (m *AdminResponse) GetBody() []byte
func (*AdminResponse) GetType ¶
func (m *AdminResponse) GetType() AdminCmdType
func (*AdminResponse) Marshal ¶
func (m *AdminResponse) Marshal() (dAtA []byte, err error)
func (*AdminResponse) ProtoMessage ¶
func (*AdminResponse) ProtoMessage()
func (*AdminResponse) Reset ¶
func (m *AdminResponse) Reset()
func (*AdminResponse) Size ¶
func (m *AdminResponse) Size() (n int)
func (*AdminResponse) String ¶
func (m *AdminResponse) String() string
func (*AdminResponse) Unmarshal ¶
func (m *AdminResponse) Unmarshal(dAtA []byte) error
type CMDType ¶
type CMDType int32
const ( Invalid CMDType = 0 RaftError CMDType = 1 Snap CMDType = 2 // common Ping CMDType = 100 Del CMDType = 101 // kv Set CMDType = 200 Get CMDType = 201 MSet CMDType = 202 MGet CMDType = 203 Incrby CMDType = 204 Decrby CMDType = 205 GetSet CMDType = 206 Append CMDType = 207 Setnx CMDType = 208 StrLen CMDType = 209 Incr CMDType = 210 Decr CMDType = 211 SetRange CMDType = 212 MSetNX CMDType = 213 // Hash HSet CMDType = 300 HGet CMDType = 301 HDel CMDType = 302 HExists CMDType = 303 HKeys CMDType = 304 HVals CMDType = 305 HGetAll CMDType = 306 HLen CMDType = 307 HMGet CMDType = 308 HMSet CMDType = 309 HSetNX CMDType = 310 HStrLen CMDType = 311 HIncrBy CMDType = 312 // lists LIndex CMDType = 400 LInsert CMDType = 401 LLEN CMDType = 402 LPop CMDType = 403 LPush CMDType = 404 LPushX CMDType = 405 LRange CMDType = 406 LRem CMDType = 407 LSet CMDType = 408 LTrim CMDType = 409 RPop CMDType = 410 RPopLPush CMDType = 411 RPush CMDType = 412 RPushX CMDType = 413 // sets SAdd CMDType = 500 SCard CMDType = 501 SRem CMDType = 502 SMembers CMDType = 503 SIsMember CMDType = 504 SPop CMDType = 505 // zsets ZAdd CMDType = 600 ZCard CMDType = 601 ZCount CMDType = 602 ZIncrBy CMDType = 603 ZLexCount CMDType = 604 ZRange CMDType = 605 ZRangeByLex CMDType = 606 ZRangeByScore CMDType = 607 ZRank CMDType = 608 ZRem CMDType = 609 ZRemRangeByLex CMDType = 611 ZRemRangeByRank CMDType = 612 ZRemRangeByScore CMDType = 613 ZScore CMDType = 614 )
func (CMDType) EnumDescriptor ¶
func (*CMDType) UnmarshalJSON ¶
type ChangePeerRequest ¶
type ChangePeerRequest struct { ChangeType pdpb.ConfChangeType `protobuf:"varint,1,opt,name=changeType,enum=pdpb.ConfChangeType" json:"changeType"` Peer metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer"` XXX_unrecognized []byte `json:"-"` }
func (*ChangePeerRequest) Descriptor ¶
func (*ChangePeerRequest) Descriptor() ([]byte, []int)
func (*ChangePeerRequest) GetChangeType ¶
func (m *ChangePeerRequest) GetChangeType() pdpb.ConfChangeType
func (*ChangePeerRequest) GetPeer ¶
func (m *ChangePeerRequest) GetPeer() metapb.Peer
func (*ChangePeerRequest) Marshal ¶
func (m *ChangePeerRequest) Marshal() (dAtA []byte, err error)
func (*ChangePeerRequest) MarshalTo ¶
func (m *ChangePeerRequest) MarshalTo(dAtA []byte) (int, error)
func (*ChangePeerRequest) ProtoMessage ¶
func (*ChangePeerRequest) ProtoMessage()
func (*ChangePeerRequest) Reset ¶
func (m *ChangePeerRequest) Reset()
func (*ChangePeerRequest) Size ¶
func (m *ChangePeerRequest) Size() (n int)
func (*ChangePeerRequest) String ¶
func (m *ChangePeerRequest) String() string
func (*ChangePeerRequest) Unmarshal ¶
func (m *ChangePeerRequest) Unmarshal(dAtA []byte) error
type ChangePeerResponse ¶
type ChangePeerResponse struct { Cell metapb.Cell `protobuf:"bytes,1,opt,name=cell" json:"cell"` XXX_unrecognized []byte `json:"-"` }
func (*ChangePeerResponse) Descriptor ¶
func (*ChangePeerResponse) Descriptor() ([]byte, []int)
func (*ChangePeerResponse) GetCell ¶
func (m *ChangePeerResponse) GetCell() metapb.Cell
func (*ChangePeerResponse) Marshal ¶
func (m *ChangePeerResponse) Marshal() (dAtA []byte, err error)
func (*ChangePeerResponse) MarshalTo ¶
func (m *ChangePeerResponse) MarshalTo(dAtA []byte) (int, error)
func (*ChangePeerResponse) ProtoMessage ¶
func (*ChangePeerResponse) ProtoMessage()
func (*ChangePeerResponse) Reset ¶
func (m *ChangePeerResponse) Reset()
func (*ChangePeerResponse) Size ¶
func (m *ChangePeerResponse) Size() (n int)
func (*ChangePeerResponse) String ¶
func (m *ChangePeerResponse) String() string
func (*ChangePeerResponse) Unmarshal ¶
func (m *ChangePeerResponse) Unmarshal(dAtA []byte) error
type FVPair ¶
type FVPair struct { Field []byte `protobuf:"bytes,1,opt,name=field" json:"field,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*FVPair) Descriptor ¶
func (*FVPair) ProtoMessage ¶
func (*FVPair) ProtoMessage()
type RaftCMDRequest ¶
type RaftCMDRequest struct { Header *RaftRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Requests []*Request `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"` AdminRequest *AdminRequest `protobuf:"bytes,3,opt,name=adminRequest" json:"adminRequest,omitempty"` XXX_unrecognized []byte `json:"-"` }
RaftCMDRequest we can't include both normal requests and administrator request at same time.
func (*RaftCMDRequest) Descriptor ¶
func (*RaftCMDRequest) Descriptor() ([]byte, []int)
func (*RaftCMDRequest) GetAdminRequest ¶
func (m *RaftCMDRequest) GetAdminRequest() *AdminRequest
func (*RaftCMDRequest) GetHeader ¶
func (m *RaftCMDRequest) GetHeader() *RaftRequestHeader
func (*RaftCMDRequest) GetRequests ¶
func (m *RaftCMDRequest) GetRequests() []*Request
func (*RaftCMDRequest) Marshal ¶
func (m *RaftCMDRequest) Marshal() (dAtA []byte, err error)
func (*RaftCMDRequest) ProtoMessage ¶
func (*RaftCMDRequest) ProtoMessage()
func (*RaftCMDRequest) Reset ¶
func (m *RaftCMDRequest) Reset()
func (*RaftCMDRequest) Size ¶
func (m *RaftCMDRequest) Size() (n int)
func (*RaftCMDRequest) String ¶
func (m *RaftCMDRequest) String() string
func (*RaftCMDRequest) Unmarshal ¶
func (m *RaftCMDRequest) Unmarshal(dAtA []byte) error
type RaftCMDResponse ¶
type RaftCMDResponse struct { Header *RaftResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Responses []*Response `protobuf:"bytes,2,rep,name=responses" json:"responses,omitempty"` AdminResponse *AdminResponse `protobuf:"bytes,3,opt,name=adminResponse" json:"adminResponse,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftCMDResponse) Descriptor ¶
func (*RaftCMDResponse) Descriptor() ([]byte, []int)
func (*RaftCMDResponse) GetAdminResponse ¶
func (m *RaftCMDResponse) GetAdminResponse() *AdminResponse
func (*RaftCMDResponse) GetHeader ¶
func (m *RaftCMDResponse) GetHeader() *RaftResponseHeader
func (*RaftCMDResponse) GetResponses ¶
func (m *RaftCMDResponse) GetResponses() []*Response
func (*RaftCMDResponse) Marshal ¶
func (m *RaftCMDResponse) Marshal() (dAtA []byte, err error)
func (*RaftCMDResponse) ProtoMessage ¶
func (*RaftCMDResponse) ProtoMessage()
func (*RaftCMDResponse) Reset ¶
func (m *RaftCMDResponse) Reset()
func (*RaftCMDResponse) Size ¶
func (m *RaftCMDResponse) Size() (n int)
func (*RaftCMDResponse) String ¶
func (m *RaftCMDResponse) String() string
func (*RaftCMDResponse) Unmarshal ¶
func (m *RaftCMDResponse) Unmarshal(dAtA []byte) error
type RaftLogGCRequest ¶
type RaftLogGCRequest struct { CompactIndex uint64 `protobuf:"varint,1,opt,name=compactIndex" json:"compactIndex"` CompactTerm uint64 `protobuf:"varint,2,opt,name=compactTerm" json:"compactTerm"` XXX_unrecognized []byte `json:"-"` }
func (*RaftLogGCRequest) Descriptor ¶
func (*RaftLogGCRequest) Descriptor() ([]byte, []int)
func (*RaftLogGCRequest) GetCompactIndex ¶
func (m *RaftLogGCRequest) GetCompactIndex() uint64
func (*RaftLogGCRequest) GetCompactTerm ¶
func (m *RaftLogGCRequest) GetCompactTerm() uint64
func (*RaftLogGCRequest) Marshal ¶
func (m *RaftLogGCRequest) Marshal() (dAtA []byte, err error)
func (*RaftLogGCRequest) ProtoMessage ¶
func (*RaftLogGCRequest) ProtoMessage()
func (*RaftLogGCRequest) Reset ¶
func (m *RaftLogGCRequest) Reset()
func (*RaftLogGCRequest) Size ¶
func (m *RaftLogGCRequest) Size() (n int)
func (*RaftLogGCRequest) String ¶
func (m *RaftLogGCRequest) String() string
func (*RaftLogGCRequest) Unmarshal ¶
func (m *RaftLogGCRequest) Unmarshal(dAtA []byte) error
type RaftLogGCResponse ¶
type RaftLogGCResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*RaftLogGCResponse) Descriptor ¶
func (*RaftLogGCResponse) Descriptor() ([]byte, []int)
func (*RaftLogGCResponse) Marshal ¶
func (m *RaftLogGCResponse) Marshal() (dAtA []byte, err error)
func (*RaftLogGCResponse) MarshalTo ¶
func (m *RaftLogGCResponse) MarshalTo(dAtA []byte) (int, error)
func (*RaftLogGCResponse) ProtoMessage ¶
func (*RaftLogGCResponse) ProtoMessage()
func (*RaftLogGCResponse) Reset ¶
func (m *RaftLogGCResponse) Reset()
func (*RaftLogGCResponse) Size ¶
func (m *RaftLogGCResponse) Size() (n int)
func (*RaftLogGCResponse) String ¶
func (m *RaftLogGCResponse) String() string
func (*RaftLogGCResponse) Unmarshal ¶
func (m *RaftLogGCResponse) Unmarshal(dAtA []byte) error
type RaftRequestHeader ¶
type RaftRequestHeader struct { CellId uint64 `protobuf:"varint,1,opt,name=cellId" json:"cellId"` Peer metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer"` // true for read linearizati ReadQuorum bool `protobuf:"varint,3,opt,name=readQuorum" json:"readQuorum"` // 16 bytes, to distinguish request. UUID []byte `protobuf:"bytes,4,opt,name=uuid" json:"uuid,omitempty"` CellEpoch metapb.CellEpoch `protobuf:"bytes,5,opt,name=cellEpoch" json:"cellEpoch"` Term uint64 `protobuf:"varint,6,opt,name=term" json:"term"` XXX_unrecognized []byte `json:"-"` }
func (*RaftRequestHeader) Descriptor ¶
func (*RaftRequestHeader) Descriptor() ([]byte, []int)
func (*RaftRequestHeader) GetCellEpoch ¶
func (m *RaftRequestHeader) GetCellEpoch() metapb.CellEpoch
func (*RaftRequestHeader) GetCellId ¶
func (m *RaftRequestHeader) GetCellId() uint64
func (*RaftRequestHeader) GetPeer ¶
func (m *RaftRequestHeader) GetPeer() metapb.Peer
func (*RaftRequestHeader) GetReadQuorum ¶
func (m *RaftRequestHeader) GetReadQuorum() bool
func (*RaftRequestHeader) GetTerm ¶
func (m *RaftRequestHeader) GetTerm() uint64
func (*RaftRequestHeader) GetUUID ¶
func (m *RaftRequestHeader) GetUUID() []byte
func (*RaftRequestHeader) Marshal ¶
func (m *RaftRequestHeader) Marshal() (dAtA []byte, err error)
func (*RaftRequestHeader) MarshalTo ¶
func (m *RaftRequestHeader) MarshalTo(dAtA []byte) (int, error)
func (*RaftRequestHeader) ProtoMessage ¶
func (*RaftRequestHeader) ProtoMessage()
func (*RaftRequestHeader) Reset ¶
func (m *RaftRequestHeader) Reset()
func (*RaftRequestHeader) Size ¶
func (m *RaftRequestHeader) Size() (n int)
func (*RaftRequestHeader) String ¶
func (m *RaftRequestHeader) String() string
func (*RaftRequestHeader) Unmarshal ¶
func (m *RaftRequestHeader) Unmarshal(dAtA []byte) error
type RaftResponseHeader ¶
type RaftResponseHeader struct { Error errorpb.Error `protobuf:"bytes,1,opt,name=error" json:"error"` UUID []byte `protobuf:"bytes,2,opt,name=uuid" json:"uuid,omitempty"` CurrentTerm uint64 `protobuf:"varint,3,opt,name=currentTerm" json:"currentTerm"` XXX_unrecognized []byte `json:"-"` }
func (*RaftResponseHeader) Descriptor ¶
func (*RaftResponseHeader) Descriptor() ([]byte, []int)
func (*RaftResponseHeader) GetCurrentTerm ¶
func (m *RaftResponseHeader) GetCurrentTerm() uint64
func (*RaftResponseHeader) GetError ¶
func (m *RaftResponseHeader) GetError() errorpb.Error
func (*RaftResponseHeader) GetUUID ¶
func (m *RaftResponseHeader) GetUUID() []byte
func (*RaftResponseHeader) Marshal ¶
func (m *RaftResponseHeader) Marshal() (dAtA []byte, err error)
func (*RaftResponseHeader) MarshalTo ¶
func (m *RaftResponseHeader) MarshalTo(dAtA []byte) (int, error)
func (*RaftResponseHeader) ProtoMessage ¶
func (*RaftResponseHeader) ProtoMessage()
func (*RaftResponseHeader) Reset ¶
func (m *RaftResponseHeader) Reset()
func (*RaftResponseHeader) Size ¶
func (m *RaftResponseHeader) Size() (n int)
func (*RaftResponseHeader) String ¶
func (m *RaftResponseHeader) String() string
func (*RaftResponseHeader) Unmarshal ¶
func (m *RaftResponseHeader) Unmarshal(dAtA []byte) error
type Request ¶
type Request struct { UUID []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"` Type CMDType `protobuf:"varint,2,opt,name=type,enum=raftcmdpb.CMDType" json:"type"` Cmd [][]byte `protobuf:"bytes,3,rep,name=cmd" json:"cmd,omitempty"` Epoch uint64 `protobuf:"varint,4,opt,name=epoch" json:"epoch"` StartAt int64 `protobuf:"varint,5,opt,name=startAt" json:"startAt"` LastStageAt int64 `protobuf:"varint,6,opt,name=lastStageAt" json:"lastStageAt"` SessionID int64 `protobuf:"varint,7,opt,name=sessionID" json:"sessionID"` XXX_unrecognized []byte `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetLastStageAt ¶
func (*Request) GetSessionID ¶
func (*Request) GetStartAt ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type Response ¶
type Response struct { UUID []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"` Type CMDType `protobuf:"varint,2,opt,name=type,enum=raftcmdpb.CMDType" json:"type"` ErrorResult []byte `protobuf:"bytes,3,opt,name=errorResult" json:"errorResult,omitempty"` ErrorResults [][]byte `protobuf:"bytes,4,rep,name=errorResults" json:"errorResults,omitempty"` StatusResult []byte `protobuf:"bytes,5,opt,name=statusResult" json:"statusResult,omitempty"` IntegerResult *int64 `protobuf:"varint,6,opt,name=integerResult" json:"integerResult,omitempty"` BulkResult []byte `protobuf:"bytes,7,opt,name=bulkResult" json:"bulkResult,omitempty"` HasEmptyBulkResult *bool `protobuf:"varint,8,opt,name=hasEmptyBulkResult" json:"hasEmptyBulkResult,omitempty"` SliceArrayResult [][]byte `protobuf:"bytes,9,rep,name=sliceArrayResult" json:"sliceArrayResult,omitempty"` HasEmptySliceArrayResult *bool `protobuf:"varint,10,opt,name=hasEmptySliceArrayResult" json:"hasEmptySliceArrayResult,omitempty"` FvPairArrayResult []*FVPair `protobuf:"bytes,11,rep,name=fvPairArrayResult" json:"fvPairArrayResult,omitempty"` HasEmptyFVPairArrayResult *bool `protobuf:"varint,12,opt,name=hasEmptyFVPairArrayResult" json:"hasEmptyFVPairArrayResult,omitempty"` ScorePairArrayResult []*ScorePair `protobuf:"bytes,13,rep,name=scorePairArrayResult" json:"scorePairArrayResult,omitempty"` HasEmptyScorePairArrayResult *bool `protobuf:"varint,14,opt,name=hasEmptyScorePairArrayResult" json:"hasEmptyScorePairArrayResult,omitempty"` Withscores *bool `protobuf:"varint,15,opt,name=withscores" json:"withscores,omitempty"` OriginRequest *Request `protobuf:"bytes,16,opt,name=originRequest" json:"originRequest,omitempty"` SessionID int64 `protobuf:"varint,17,opt,name=sessionID" json:"sessionID"` DocArrayResult []*querypb.Document `protobuf:"bytes,18,rep,name=docArrayResult" json:"docArrayResult,omitempty"` HasEmptyDocArrayResult *bool `protobuf:"varint,19,opt,name=hasEmptyDocArrayResult" json:"hasEmptyDocArrayResult,omitempty"` Error errorpb.Error `protobuf:"bytes,20,opt,name=error" json:"error"` XXX_unrecognized []byte `json:"-"` }
func (*Response) Descriptor ¶
func (*Response) GetBulkResult ¶
func (*Response) GetDocArrayResult ¶
func (*Response) GetErrorResult ¶
func (*Response) GetErrorResults ¶
func (*Response) GetFvPairArrayResult ¶
func (*Response) GetHasEmptyBulkResult ¶
func (*Response) GetHasEmptyDocArrayResult ¶
func (*Response) GetHasEmptyFVPairArrayResult ¶
func (*Response) GetHasEmptyScorePairArrayResult ¶
func (*Response) GetHasEmptySliceArrayResult ¶
func (*Response) GetIntegerResult ¶
func (*Response) GetOriginRequest ¶
func (*Response) GetScorePairArrayResult ¶
func (*Response) GetSessionID ¶
func (*Response) GetSliceArrayResult ¶
func (*Response) GetStatusResult ¶
func (*Response) GetWithscores ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
type ScorePair ¶
type ScorePair struct { Score float64 `protobuf:"fixed64,1,opt,name=score" json:"score"` Member []byte `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ScorePair) Descriptor ¶
func (*ScorePair) ProtoMessage ¶
func (*ScorePair) ProtoMessage()
type SplitRequest ¶
type SplitRequest struct { // This can be only called in internal RaftStore now. // The splitKey must be in the been splitting cell. SplitKey []byte `protobuf:"bytes,1,opt,name=splitKey" json:"splitKey,omitempty"` // We split the cell into two, first uses the origin // parent cell id, and the second uses the new_cell_id. // We must guarantee that the new_cell_id is global unique. NewCellID uint64 `protobuf:"varint,2,opt,name=newCellID" json:"newCellID"` // The peer ids for the new split cell. NewPeerIDs []uint64 `protobuf:"varint,3,rep,name=newPeerIDs" json:"newPeerIDs,omitempty"` // If true, right cell derive the origin cell_id, // left cell use new_cell_id. RightDerive bool `protobuf:"varint,4,opt,name=rightDerive" json:"rightDerive"` XXX_unrecognized []byte `json:"-"` }
func (*SplitRequest) Descriptor ¶
func (*SplitRequest) Descriptor() ([]byte, []int)
func (*SplitRequest) GetNewCellID ¶
func (m *SplitRequest) GetNewCellID() uint64
func (*SplitRequest) GetNewPeerIDs ¶
func (m *SplitRequest) GetNewPeerIDs() []uint64
func (*SplitRequest) GetRightDerive ¶
func (m *SplitRequest) GetRightDerive() bool
func (*SplitRequest) GetSplitKey ¶
func (m *SplitRequest) GetSplitKey() []byte
func (*SplitRequest) Marshal ¶
func (m *SplitRequest) Marshal() (dAtA []byte, err error)
func (*SplitRequest) ProtoMessage ¶
func (*SplitRequest) ProtoMessage()
func (*SplitRequest) Reset ¶
func (m *SplitRequest) Reset()
func (*SplitRequest) Size ¶
func (m *SplitRequest) Size() (n int)
func (*SplitRequest) String ¶
func (m *SplitRequest) String() string
func (*SplitRequest) Unmarshal ¶
func (m *SplitRequest) Unmarshal(dAtA []byte) error
type SplitResponse ¶
type SplitResponse struct { Left metapb.Cell `protobuf:"bytes,1,opt,name=left" json:"left"` Right metapb.Cell `protobuf:"bytes,2,opt,name=right" json:"right"` XXX_unrecognized []byte `json:"-"` }
func (*SplitResponse) Descriptor ¶
func (*SplitResponse) Descriptor() ([]byte, []int)
func (*SplitResponse) GetLeft ¶
func (m *SplitResponse) GetLeft() metapb.Cell
func (*SplitResponse) GetRight ¶
func (m *SplitResponse) GetRight() metapb.Cell
func (*SplitResponse) Marshal ¶
func (m *SplitResponse) Marshal() (dAtA []byte, err error)
func (*SplitResponse) ProtoMessage ¶
func (*SplitResponse) ProtoMessage()
func (*SplitResponse) Reset ¶
func (m *SplitResponse) Reset()
func (*SplitResponse) Size ¶
func (m *SplitResponse) Size() (n int)
func (*SplitResponse) String ¶
func (m *SplitResponse) String() string
func (*SplitResponse) Unmarshal ¶
func (m *SplitResponse) Unmarshal(dAtA []byte) error
type TransferLeaderRequest ¶
type TransferLeaderRequest struct { Peer metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer"` XXX_unrecognized []byte `json:"-"` }
func (*TransferLeaderRequest) Descriptor ¶
func (*TransferLeaderRequest) Descriptor() ([]byte, []int)
func (*TransferLeaderRequest) GetPeer ¶
func (m *TransferLeaderRequest) GetPeer() metapb.Peer
func (*TransferLeaderRequest) Marshal ¶
func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error)
func (*TransferLeaderRequest) MarshalTo ¶
func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error)
func (*TransferLeaderRequest) ProtoMessage ¶
func (*TransferLeaderRequest) ProtoMessage()
func (*TransferLeaderRequest) Reset ¶
func (m *TransferLeaderRequest) Reset()
func (*TransferLeaderRequest) Size ¶
func (m *TransferLeaderRequest) Size() (n int)
func (*TransferLeaderRequest) String ¶
func (m *TransferLeaderRequest) String() string
func (*TransferLeaderRequest) Unmarshal ¶
func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error
type TransferLeaderResponse ¶
type TransferLeaderResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*TransferLeaderResponse) Descriptor ¶
func (*TransferLeaderResponse) Descriptor() ([]byte, []int)
func (*TransferLeaderResponse) Marshal ¶
func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error)
func (*TransferLeaderResponse) MarshalTo ¶
func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error)
func (*TransferLeaderResponse) ProtoMessage ¶
func (*TransferLeaderResponse) ProtoMessage()
func (*TransferLeaderResponse) Reset ¶
func (m *TransferLeaderResponse) Reset()
func (*TransferLeaderResponse) Size ¶
func (m *TransferLeaderResponse) Size() (n int)
func (*TransferLeaderResponse) String ¶
func (m *TransferLeaderResponse) String() string
func (*TransferLeaderResponse) Unmarshal ¶
func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.