raftcmdpb

package
v0.0.0-...-3b800f5 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

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

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

func (m *AdminRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *AdminResponse) MarshalTo(dAtA []byte) (int, 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) Enum

func (x CMDType) Enum() *CMDType

func (CMDType) EnumDescriptor

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

func (CMDType) String

func (x CMDType) String() string

func (*CMDType) UnmarshalJSON

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

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) Descriptor() ([]byte, []int)

func (*FVPair) GetField

func (m *FVPair) GetField() []byte

func (*FVPair) GetValue

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

func (*FVPair) Marshal

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

func (*FVPair) MarshalTo

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

func (*FVPair) ProtoMessage

func (*FVPair) ProtoMessage()

func (*FVPair) Reset

func (m *FVPair) Reset()

func (*FVPair) Size

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

func (*FVPair) String

func (m *FVPair) String() string

func (*FVPair) Unmarshal

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

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

func (m *RaftCMDRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RaftCMDResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RaftLogGCRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Request) GetCmd

func (m *Request) GetCmd() [][]byte

func (*Request) GetEpoch

func (m *Request) GetEpoch() uint64

func (*Request) GetLastStageAt

func (m *Request) GetLastStageAt() int64

func (*Request) GetSessionID

func (m *Request) GetSessionID() int64

func (*Request) GetStartAt

func (m *Request) GetStartAt() int64

func (*Request) GetType

func (m *Request) GetType() CMDType

func (*Request) GetUUID

func (m *Request) GetUUID() []byte

func (*Request) Marshal

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

func (*Request) MarshalTo

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

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

type Response

type Response struct {
	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) Descriptor() ([]byte, []int)

func (*Response) GetBulkResult

func (m *Response) GetBulkResult() []byte

func (*Response) GetDocArrayResult

func (m *Response) GetDocArrayResult() []*querypb.Document

func (*Response) GetError

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

func (*Response) GetErrorResult

func (m *Response) GetErrorResult() []byte

func (*Response) GetErrorResults

func (m *Response) GetErrorResults() [][]byte

func (*Response) GetFvPairArrayResult

func (m *Response) GetFvPairArrayResult() []*FVPair

func (*Response) GetHasEmptyBulkResult

func (m *Response) GetHasEmptyBulkResult() bool

func (*Response) GetHasEmptyDocArrayResult

func (m *Response) GetHasEmptyDocArrayResult() bool

func (*Response) GetHasEmptyFVPairArrayResult

func (m *Response) GetHasEmptyFVPairArrayResult() bool

func (*Response) GetHasEmptyScorePairArrayResult

func (m *Response) GetHasEmptyScorePairArrayResult() bool

func (*Response) GetHasEmptySliceArrayResult

func (m *Response) GetHasEmptySliceArrayResult() bool

func (*Response) GetIntegerResult

func (m *Response) GetIntegerResult() int64

func (*Response) GetOriginRequest

func (m *Response) GetOriginRequest() *Request

func (*Response) GetScorePairArrayResult

func (m *Response) GetScorePairArrayResult() []*ScorePair

func (*Response) GetSessionID

func (m *Response) GetSessionID() int64

func (*Response) GetSliceArrayResult

func (m *Response) GetSliceArrayResult() [][]byte

func (*Response) GetStatusResult

func (m *Response) GetStatusResult() []byte

func (*Response) GetType

func (m *Response) GetType() CMDType

func (*Response) GetUUID

func (m *Response) GetUUID() []byte

func (*Response) GetWithscores

func (m *Response) GetWithscores() bool

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*ScorePair) GetMember

func (m *ScorePair) GetMember() []byte

func (*ScorePair) GetScore

func (m *ScorePair) GetScore() float64

func (*ScorePair) Marshal

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

func (*ScorePair) MarshalTo

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

func (*ScorePair) ProtoMessage

func (*ScorePair) ProtoMessage()

func (*ScorePair) Reset

func (m *ScorePair) Reset()

func (*ScorePair) Size

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

func (*ScorePair) String

func (m *ScorePair) String() string

func (*ScorePair) Unmarshal

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

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

func (m *SplitRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *SplitResponse) MarshalTo(dAtA []byte) (int, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL