raftcmdpb

package
v0.0.0-...-f0aa2c5 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

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",
	313: "HScanGet",
	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",
	700: "Lock",
	701: "Unlock",
	702: "Lockable",
	800: "BMCreate",
	801: "BMAdd",
	802: "BMRemove",
	803: "BMClear",
	804: "BMContains",
	805: "BMDel",
	806: "BMCount",
	807: "BMRange",
}
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,
	"HScanGet":         313,
	"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,
	"Lock":             700,
	"Unlock":           701,
	"Lockable":         702,
	"BMCreate":         800,
	"BMAdd":            801,
	"BMRemove":         802,
	"BMClear":          803,
	"BMContains":       804,
	"BMDel":            805,
	"BMCount":          806,
	"BMRange":          807,
}

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

func (m *AdminRequest) MarshalToSizedBuffer(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

func (*AdminRequest) XXX_DiscardUnknown 

func (m *AdminRequest) XXX_DiscardUnknown()

func (*AdminRequest) XXX_Marshal 

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

func (*AdminRequest) XXX_Merge 

func (m *AdminRequest) XXX_Merge(src proto.Message)

func (*AdminRequest) XXX_Size 

func (m *AdminRequest) XXX_Size() int

func (*AdminRequest) XXX_Unmarshal 

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

func (m *AdminResponse) MarshalToSizedBuffer(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

func (*AdminResponse) XXX_DiscardUnknown 

func (m *AdminResponse) XXX_DiscardUnknown()

func (*AdminResponse) XXX_Marshal 

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

func (*AdminResponse) XXX_Merge 

func (m *AdminResponse) XXX_Merge(src proto.Message)

func (*AdminResponse) XXX_Size 

func (m *AdminResponse) XXX_Size() int

func (*AdminResponse) XXX_Unmarshal 

func (m *AdminResponse) XXX_Unmarshal(b []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
	HScanGet CMDType = 313
	// 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
	// lock
	Lock     CMDType = 700
	Unlock   CMDType = 701
	Lockable CMDType = 702
	// bitmap
	BMCreate   CMDType = 800
	BMAdd      CMDType = 801
	BMRemove   CMDType = 802
	BMClear    CMDType = 803
	BMContains CMDType = 804
	BMDel      CMDType = 805
	BMCount    CMDType = 806
	BMRange    CMDType = 807
)

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

func (m *ChangePeerRequest) MarshalToSizedBuffer(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

func (*ChangePeerRequest) XXX_DiscardUnknown 

func (m *ChangePeerRequest) XXX_DiscardUnknown()

func (*ChangePeerRequest) XXX_Marshal 

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

func (*ChangePeerRequest) XXX_Merge 

func (m *ChangePeerRequest) XXX_Merge(src proto.Message)

func (*ChangePeerRequest) XXX_Size 

func (m *ChangePeerRequest) XXX_Size() int

func (*ChangePeerRequest) XXX_Unmarshal 

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

type ChangePeerResponse 

type ChangePeerResponse struct {
	Cell                 metapb.Cell `protobuf:"bytes,1,opt,name=cell" json:"cell"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `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) MarshalToSizedBuffer 

func (m *ChangePeerResponse) MarshalToSizedBuffer(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

func (*ChangePeerResponse) XXX_DiscardUnknown 

func (m *ChangePeerResponse) XXX_DiscardUnknown()

func (*ChangePeerResponse) XXX_Marshal 

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

func (*ChangePeerResponse) XXX_Merge 

func (m *ChangePeerResponse) XXX_Merge(src proto.Message)

func (*ChangePeerResponse) XXX_Size 

func (m *ChangePeerResponse) XXX_Size() int

func (*ChangePeerResponse) XXX_Unmarshal 

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

func (m *FVPair) MarshalToSizedBuffer(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

func (*FVPair) XXX_DiscardUnknown 

func (m *FVPair) XXX_DiscardUnknown()

func (*FVPair) XXX_Marshal 

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

func (*FVPair) XXX_Merge 

func (m *FVPair) XXX_Merge(src proto.Message)

func (*FVPair) XXX_Size 

func (m *FVPair) XXX_Size() int

func (*FVPair) XXX_Unmarshal 

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

func (m *RaftCMDRequest) MarshalToSizedBuffer(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

func (*RaftCMDRequest) XXX_DiscardUnknown 

func (m *RaftCMDRequest) XXX_DiscardUnknown()

func (*RaftCMDRequest) XXX_Marshal 

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

func (*RaftCMDRequest) XXX_Merge 

func (m *RaftCMDRequest) XXX_Merge(src proto.Message)

func (*RaftCMDRequest) XXX_Size 

func (m *RaftCMDRequest) XXX_Size() int

func (*RaftCMDRequest) XXX_Unmarshal 

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

func (m *RaftCMDResponse) MarshalToSizedBuffer(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

func (*RaftCMDResponse) XXX_DiscardUnknown 

func (m *RaftCMDResponse) XXX_DiscardUnknown()

func (*RaftCMDResponse) XXX_Marshal 

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

func (*RaftCMDResponse) XXX_Merge 

func (m *RaftCMDResponse) XXX_Merge(src proto.Message)

func (*RaftCMDResponse) XXX_Size 

func (m *RaftCMDResponse) XXX_Size() int

func (*RaftCMDResponse) XXX_Unmarshal 

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

func (m *RaftLogGCRequest) MarshalToSizedBuffer(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

func (*RaftLogGCRequest) XXX_DiscardUnknown 

func (m *RaftLogGCRequest) XXX_DiscardUnknown()

func (*RaftLogGCRequest) XXX_Marshal 

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

func (*RaftLogGCRequest) XXX_Merge 

func (m *RaftLogGCRequest) XXX_Merge(src proto.Message)

func (*RaftLogGCRequest) XXX_Size 

func (m *RaftLogGCRequest) XXX_Size() int

func (*RaftLogGCRequest) XXX_Unmarshal 

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

type RaftLogGCResponse 

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

func (m *RaftLogGCResponse) MarshalToSizedBuffer(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

func (*RaftLogGCResponse) XXX_DiscardUnknown 

func (m *RaftLogGCResponse) XXX_DiscardUnknown()

func (*RaftLogGCResponse) XXX_Marshal 

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

func (*RaftLogGCResponse) XXX_Merge 

func (m *RaftLogGCResponse) XXX_Merge(src proto.Message)

func (*RaftLogGCResponse) XXX_Size 

func (m *RaftLogGCResponse) XXX_Size() int

func (*RaftLogGCResponse) XXX_Unmarshal 

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

func (m *RaftRequestHeader) MarshalToSizedBuffer(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

func (*RaftRequestHeader) XXX_DiscardUnknown 

func (m *RaftRequestHeader) XXX_DiscardUnknown()

func (*RaftRequestHeader) XXX_Marshal 

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

func (*RaftRequestHeader) XXX_Merge 

func (m *RaftRequestHeader) XXX_Merge(src proto.Message)

func (*RaftRequestHeader) XXX_Size 

func (m *RaftRequestHeader) XXX_Size() int

func (*RaftRequestHeader) XXX_Unmarshal 

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

func (m *RaftResponseHeader) MarshalToSizedBuffer(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

func (*RaftResponseHeader) XXX_DiscardUnknown 

func (m *RaftResponseHeader) XXX_DiscardUnknown()

func (*RaftResponseHeader) XXX_Marshal 

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

func (*RaftResponseHeader) XXX_Merge 

func (m *RaftResponseHeader) XXX_Merge(src proto.Message)

func (*RaftResponseHeader) XXX_Size 

func (m *RaftResponseHeader) XXX_Size() int

func (*RaftResponseHeader) XXX_Unmarshal 

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

func (m *Request) MarshalToSizedBuffer(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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []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"`
	SliceArrayResult             [][]byte      `protobuf:"bytes,9,rep,name=sliceArrayResult" json:"sliceArrayResult,omitempty"`
	HasEmptySliceArrayResult     bool          `protobuf:"varint,10,opt,name=hasEmptySliceArrayResult" json:"hasEmptySliceArrayResult"`
	FvPairArrayResult            []*FVPair     `protobuf:"bytes,11,rep,name=fvPairArrayResult" json:"fvPairArrayResult,omitempty"`
	HasEmptyFVPairArrayResult    bool          `protobuf:"varint,12,opt,name=hasEmptyFVPairArrayResult" json:"hasEmptyFVPairArrayResult"`
	ScorePairArrayResult         []*ScorePair  `protobuf:"bytes,13,rep,name=scorePairArrayResult" json:"scorePairArrayResult,omitempty"`
	HasEmptyScorePairArrayResult bool          `protobuf:"varint,14,opt,name=hasEmptyScorePairArrayResult" json:"hasEmptyScorePairArrayResult"`
	Withscores                   bool          `protobuf:"varint,15,opt,name=withscores" json:"withscores"`
	OriginRequest                *Request      `protobuf:"bytes,16,opt,name=originRequest" json:"originRequest,omitempty"`
	SessionID                    int64         `protobuf:"varint,17,opt,name=sessionID" json:"sessionID"`
	HasEmptyDocArrayResult       bool          `protobuf:"varint,18,opt,name=hasEmptyDocArrayResult" json:"hasEmptyDocArrayResult"`
	Error                        errorpb.Error `protobuf:"bytes,19,opt,name=error" json:"error"`
	XXX_NoUnkeyedLiteral         struct{}      `json:"-"`
	XXX_unrecognized             []byte        `json:"-"`
	XXX_sizecache                int32         `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetBulkResult 

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

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

func (m *Response) MarshalToSizedBuffer(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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

func (m *ScorePair) MarshalToSizedBuffer(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

func (*ScorePair) XXX_DiscardUnknown 

func (m *ScorePair) XXX_DiscardUnknown()

func (*ScorePair) XXX_Marshal 

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

func (*ScorePair) XXX_Merge 

func (m *ScorePair) XXX_Merge(src proto.Message)

func (*ScorePair) XXX_Size 

func (m *ScorePair) XXX_Size() int

func (*ScorePair) XXX_Unmarshal 

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

func (m *SplitRequest) MarshalToSizedBuffer(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

func (*SplitRequest) XXX_DiscardUnknown 

func (m *SplitRequest) XXX_DiscardUnknown()

func (*SplitRequest) XXX_Marshal 

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

func (*SplitRequest) XXX_Merge 

func (m *SplitRequest) XXX_Merge(src proto.Message)

func (*SplitRequest) XXX_Size 

func (m *SplitRequest) XXX_Size() int

func (*SplitRequest) XXX_Unmarshal 

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

func (m *SplitResponse) MarshalToSizedBuffer(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

func (*SplitResponse) XXX_DiscardUnknown 

func (m *SplitResponse) XXX_DiscardUnknown()

func (*SplitResponse) XXX_Marshal 

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

func (*SplitResponse) XXX_Merge 

func (m *SplitResponse) XXX_Merge(src proto.Message)

func (*SplitResponse) XXX_Size 

func (m *SplitResponse) XXX_Size() int

func (*SplitResponse) XXX_Unmarshal 

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

type TransferLeaderRequest 

type TransferLeaderRequest struct {
	Peer                 metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `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) MarshalToSizedBuffer 

func (m *TransferLeaderRequest) MarshalToSizedBuffer(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

func (*TransferLeaderRequest) XXX_DiscardUnknown 

func (m *TransferLeaderRequest) XXX_DiscardUnknown()

func (*TransferLeaderRequest) XXX_Marshal 

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

func (*TransferLeaderRequest) XXX_Merge 

func (m *TransferLeaderRequest) XXX_Merge(src proto.Message)

func (*TransferLeaderRequest) XXX_Size 

func (m *TransferLeaderRequest) XXX_Size() int

func (*TransferLeaderRequest) XXX_Unmarshal 

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

type TransferLeaderResponse 

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

func (m *TransferLeaderResponse) MarshalToSizedBuffer(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

func (*TransferLeaderResponse) XXX_DiscardUnknown 

func (m *TransferLeaderResponse) XXX_DiscardUnknown()

func (*TransferLeaderResponse) XXX_Marshal 

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

func (*TransferLeaderResponse) XXX_Merge 

func (m *TransferLeaderResponse) XXX_Merge(src proto.Message)

func (*TransferLeaderResponse) XXX_Size 

func (m *TransferLeaderResponse) XXX_Size() int

func (*TransferLeaderResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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