| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193 |
- // Code generated by protoc-gen-gogo.
- // source: raft.proto
- // DO NOT EDIT!
- /*
- Package raftpb is a generated protocol buffer package.
- It is generated from these files:
- raft.proto
- It has these top-level messages:
- Info
- Entry
- Snapshot
- Message
- HardState
- ConfChange
- */
- package raftpb
- import proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
- import json "encoding/json"
- import math "math"
- // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
- import io "io"
- import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
- // Reference proto, json, and math imports to suppress error if they are not otherwise used.
- var _ = proto.Marshal
- var _ = &json.SyntaxError{}
- var _ = math.Inf
- type EntryType int32
- const (
- EntryNormal EntryType = 0
- EntryConfChange EntryType = 1
- )
- var EntryType_name = map[int32]string{
- 0: "EntryNormal",
- 1: "EntryConfChange",
- }
- var EntryType_value = map[string]int32{
- "EntryNormal": 0,
- "EntryConfChange": 1,
- }
- func (x EntryType) Enum() *EntryType {
- p := new(EntryType)
- *p = x
- return p
- }
- func (x EntryType) String() string {
- return proto.EnumName(EntryType_name, int32(x))
- }
- func (x *EntryType) UnmarshalJSON(data []byte) error {
- value, err := proto.UnmarshalJSONEnum(EntryType_value, data, "EntryType")
- if err != nil {
- return err
- }
- *x = EntryType(value)
- return nil
- }
- type ConfChangeType int32
- const (
- ConfChangeAddNode ConfChangeType = 0
- ConfChangeRemoveNode ConfChangeType = 1
- )
- var ConfChangeType_name = map[int32]string{
- 0: "ConfChangeAddNode",
- 1: "ConfChangeRemoveNode",
- }
- var ConfChangeType_value = map[string]int32{
- "ConfChangeAddNode": 0,
- "ConfChangeRemoveNode": 1,
- }
- func (x ConfChangeType) Enum() *ConfChangeType {
- p := new(ConfChangeType)
- *p = x
- return p
- }
- func (x ConfChangeType) String() string {
- return proto.EnumName(ConfChangeType_name, int32(x))
- }
- func (x *ConfChangeType) UnmarshalJSON(data []byte) error {
- value, err := proto.UnmarshalJSONEnum(ConfChangeType_value, data, "ConfChangeType")
- if err != nil {
- return err
- }
- *x = ConfChangeType(value)
- return nil
- }
- type Info struct {
- Id int64 `protobuf:"varint,1,req,name=id" json:"id"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *Info) Reset() { *m = Info{} }
- func (m *Info) String() string { return proto.CompactTextString(m) }
- func (*Info) ProtoMessage() {}
- type Entry struct {
- Type EntryType `protobuf:"varint,1,req,enum=raftpb.EntryType" json:"Type"`
- Term int64 `protobuf:"varint,2,req" json:"Term"`
- Index int64 `protobuf:"varint,3,req" json:"Index"`
- Data []byte `protobuf:"bytes,4,opt" json:"Data"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *Entry) Reset() { *m = Entry{} }
- func (m *Entry) String() string { return proto.CompactTextString(m) }
- func (*Entry) ProtoMessage() {}
- type Snapshot struct {
- Data []byte `protobuf:"bytes,1,req,name=data" json:"data"`
- Nodes []int64 `protobuf:"varint,2,rep,name=nodes" json:"nodes"`
- Index int64 `protobuf:"varint,3,req,name=index" json:"index"`
- Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *Snapshot) Reset() { *m = Snapshot{} }
- func (m *Snapshot) String() string { return proto.CompactTextString(m) }
- func (*Snapshot) ProtoMessage() {}
- type Message struct {
- Type int64 `protobuf:"varint,1,req,name=type" json:"type"`
- To int64 `protobuf:"varint,2,req,name=to" json:"to"`
- From int64 `protobuf:"varint,3,req,name=from" json:"from"`
- Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
- LogTerm int64 `protobuf:"varint,5,req,name=logTerm" json:"logTerm"`
- Index int64 `protobuf:"varint,6,req,name=index" json:"index"`
- Entries []Entry `protobuf:"bytes,7,rep,name=entries" json:"entries"`
- Commit int64 `protobuf:"varint,8,req,name=commit" json:"commit"`
- Snapshot Snapshot `protobuf:"bytes,9,req,name=snapshot" json:"snapshot"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *Message) Reset() { *m = Message{} }
- func (m *Message) String() string { return proto.CompactTextString(m) }
- func (*Message) ProtoMessage() {}
- type HardState struct {
- Term int64 `protobuf:"varint,1,req,name=term" json:"term"`
- Vote int64 `protobuf:"varint,2,req,name=vote" json:"vote"`
- Commit int64 `protobuf:"varint,3,req,name=commit" json:"commit"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *HardState) Reset() { *m = HardState{} }
- func (m *HardState) String() string { return proto.CompactTextString(m) }
- func (*HardState) ProtoMessage() {}
- type ConfChange struct {
- ID int64 `protobuf:"varint,1,req" json:"ID"`
- Type ConfChangeType `protobuf:"varint,2,req,enum=raftpb.ConfChangeType" json:"Type"`
- NodeID int64 `protobuf:"varint,3,req" json:"NodeID"`
- Context []byte `protobuf:"bytes,4,opt" json:"Context"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *ConfChange) Reset() { *m = ConfChange{} }
- func (m *ConfChange) String() string { return proto.CompactTextString(m) }
- func (*ConfChange) ProtoMessage() {}
- func init() {
- proto.RegisterEnum("raftpb.EntryType", EntryType_name, EntryType_value)
- proto.RegisterEnum("raftpb.ConfChangeType", ConfChangeType_name, ConfChangeType_value)
- }
- func (m *Info) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Id |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *Entry) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Type |= (EntryType(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Term |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 3:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Index |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 4:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var byteLen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- byteLen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + byteLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Data = append(m.Data, data[index:postIndex]...)
- index = postIndex
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *Snapshot) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var byteLen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- byteLen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + byteLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Data = append(m.Data, data[index:postIndex]...)
- index = postIndex
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var v int64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- v |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- m.Nodes = append(m.Nodes, v)
- case 3:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Index |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 4:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Term |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *Message) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Type |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.To |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 3:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.From |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 4:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Term |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 5:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.LogTerm |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 6:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Index |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 7:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Entries = append(m.Entries, Entry{})
- m.Entries[len(m.Entries)-1].Unmarshal(data[index:postIndex])
- index = postIndex
- case 8:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Commit |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 9:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if err := m.Snapshot.Unmarshal(data[index:postIndex]); err != nil {
- return err
- }
- index = postIndex
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *HardState) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Term |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Vote |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 3:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Commit |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *ConfChange) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.ID |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.Type |= (ConfChangeType(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 3:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- m.NodeID |= (int64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 4:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var byteLen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- byteLen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + byteLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Context = append(m.Context, data[index:postIndex]...)
- index = postIndex
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (m *Info) Size() (n int) {
- var l int
- _ = l
- n += 1 + sovRaft(uint64(m.Id))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func (m *Entry) Size() (n int) {
- var l int
- _ = l
- n += 1 + sovRaft(uint64(m.Type))
- n += 1 + sovRaft(uint64(m.Term))
- n += 1 + sovRaft(uint64(m.Index))
- l = len(m.Data)
- n += 1 + l + sovRaft(uint64(l))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func (m *Snapshot) Size() (n int) {
- var l int
- _ = l
- l = len(m.Data)
- n += 1 + l + sovRaft(uint64(l))
- if len(m.Nodes) > 0 {
- for _, e := range m.Nodes {
- n += 1 + sovRaft(uint64(e))
- }
- }
- n += 1 + sovRaft(uint64(m.Index))
- n += 1 + sovRaft(uint64(m.Term))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func (m *Message) Size() (n int) {
- var l int
- _ = l
- n += 1 + sovRaft(uint64(m.Type))
- n += 1 + sovRaft(uint64(m.To))
- n += 1 + sovRaft(uint64(m.From))
- n += 1 + sovRaft(uint64(m.Term))
- n += 1 + sovRaft(uint64(m.LogTerm))
- n += 1 + sovRaft(uint64(m.Index))
- if len(m.Entries) > 0 {
- for _, e := range m.Entries {
- l = e.Size()
- n += 1 + l + sovRaft(uint64(l))
- }
- }
- n += 1 + sovRaft(uint64(m.Commit))
- l = m.Snapshot.Size()
- n += 1 + l + sovRaft(uint64(l))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func (m *HardState) Size() (n int) {
- var l int
- _ = l
- n += 1 + sovRaft(uint64(m.Term))
- n += 1 + sovRaft(uint64(m.Vote))
- n += 1 + sovRaft(uint64(m.Commit))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func (m *ConfChange) Size() (n int) {
- var l int
- _ = l
- n += 1 + sovRaft(uint64(m.ID))
- n += 1 + sovRaft(uint64(m.Type))
- n += 1 + sovRaft(uint64(m.NodeID))
- l = len(m.Context)
- n += 1 + l + sovRaft(uint64(l))
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func sovRaft(x uint64) (n int) {
- for {
- n++
- x >>= 7
- if x == 0 {
- break
- }
- }
- return n
- }
- func sozRaft(x uint64) (n int) {
- return sovRaft(uint64((x << 1) ^ uint64((int64(x) >> 63))))
- }
- func (m *Info) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *Info) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0x8
- i++
- i = encodeVarintRaft(data, i, uint64(m.Id))
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func (m *Entry) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *Entry) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0x8
- i++
- i = encodeVarintRaft(data, i, uint64(m.Type))
- data[i] = 0x10
- i++
- i = encodeVarintRaft(data, i, uint64(m.Term))
- data[i] = 0x18
- i++
- i = encodeVarintRaft(data, i, uint64(m.Index))
- data[i] = 0x22
- i++
- i = encodeVarintRaft(data, i, uint64(len(m.Data)))
- i += copy(data[i:], m.Data)
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func (m *Snapshot) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *Snapshot) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0xa
- i++
- i = encodeVarintRaft(data, i, uint64(len(m.Data)))
- i += copy(data[i:], m.Data)
- if len(m.Nodes) > 0 {
- for _, num := range m.Nodes {
- data[i] = 0x10
- i++
- for num >= 1<<7 {
- data[i] = uint8(uint64(num)&0x7f | 0x80)
- num >>= 7
- i++
- }
- data[i] = uint8(num)
- i++
- }
- }
- data[i] = 0x18
- i++
- i = encodeVarintRaft(data, i, uint64(m.Index))
- data[i] = 0x20
- i++
- i = encodeVarintRaft(data, i, uint64(m.Term))
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func (m *Message) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *Message) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0x8
- i++
- i = encodeVarintRaft(data, i, uint64(m.Type))
- data[i] = 0x10
- i++
- i = encodeVarintRaft(data, i, uint64(m.To))
- data[i] = 0x18
- i++
- i = encodeVarintRaft(data, i, uint64(m.From))
- data[i] = 0x20
- i++
- i = encodeVarintRaft(data, i, uint64(m.Term))
- data[i] = 0x28
- i++
- i = encodeVarintRaft(data, i, uint64(m.LogTerm))
- data[i] = 0x30
- i++
- i = encodeVarintRaft(data, i, uint64(m.Index))
- if len(m.Entries) > 0 {
- for _, msg := range m.Entries {
- data[i] = 0x3a
- i++
- i = encodeVarintRaft(data, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(data[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- data[i] = 0x40
- i++
- i = encodeVarintRaft(data, i, uint64(m.Commit))
- data[i] = 0x4a
- i++
- i = encodeVarintRaft(data, i, uint64(m.Snapshot.Size()))
- n1, err := m.Snapshot.MarshalTo(data[i:])
- if err != nil {
- return 0, err
- }
- i += n1
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func (m *HardState) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *HardState) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0x8
- i++
- i = encodeVarintRaft(data, i, uint64(m.Term))
- data[i] = 0x10
- i++
- i = encodeVarintRaft(data, i, uint64(m.Vote))
- data[i] = 0x18
- i++
- i = encodeVarintRaft(data, i, uint64(m.Commit))
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func (m *ConfChange) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *ConfChange) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- data[i] = 0x8
- i++
- i = encodeVarintRaft(data, i, uint64(m.ID))
- data[i] = 0x10
- i++
- i = encodeVarintRaft(data, i, uint64(m.Type))
- data[i] = 0x18
- i++
- i = encodeVarintRaft(data, i, uint64(m.NodeID))
- data[i] = 0x22
- i++
- i = encodeVarintRaft(data, i, uint64(len(m.Context)))
- i += copy(data[i:], m.Context)
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func encodeFixed64Raft(data []byte, offset int, v uint64) int {
- data[offset] = uint8(v)
- data[offset+1] = uint8(v >> 8)
- data[offset+2] = uint8(v >> 16)
- data[offset+3] = uint8(v >> 24)
- data[offset+4] = uint8(v >> 32)
- data[offset+5] = uint8(v >> 40)
- data[offset+6] = uint8(v >> 48)
- data[offset+7] = uint8(v >> 56)
- return offset + 8
- }
- func encodeFixed32Raft(data []byte, offset int, v uint32) int {
- data[offset] = uint8(v)
- data[offset+1] = uint8(v >> 8)
- data[offset+2] = uint8(v >> 16)
- data[offset+3] = uint8(v >> 24)
- return offset + 4
- }
- func encodeVarintRaft(data []byte, offset int, v uint64) int {
- for v >= 1<<7 {
- data[offset] = uint8(v&0x7f | 0x80)
- v >>= 7
- offset++
- }
- data[offset] = uint8(v)
- return offset + 1
- }
|