raft.pb.go 26 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193
  1. // Code generated by protoc-gen-gogo.
  2. // source: raft.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package raftpb is a generated protocol buffer package.
  6. It is generated from these files:
  7. raft.proto
  8. It has these top-level messages:
  9. Info
  10. Entry
  11. Snapshot
  12. Message
  13. HardState
  14. ConfChange
  15. */
  16. package raftpb
  17. import proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  18. import json "encoding/json"
  19. import math "math"
  20. // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
  21. import io "io"
  22. import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  23. // Reference proto, json, and math imports to suppress error if they are not otherwise used.
  24. var _ = proto.Marshal
  25. var _ = &json.SyntaxError{}
  26. var _ = math.Inf
  27. type EntryType int32
  28. const (
  29. EntryNormal EntryType = 0
  30. EntryConfChange EntryType = 1
  31. )
  32. var EntryType_name = map[int32]string{
  33. 0: "EntryNormal",
  34. 1: "EntryConfChange",
  35. }
  36. var EntryType_value = map[string]int32{
  37. "EntryNormal": 0,
  38. "EntryConfChange": 1,
  39. }
  40. func (x EntryType) Enum() *EntryType {
  41. p := new(EntryType)
  42. *p = x
  43. return p
  44. }
  45. func (x EntryType) String() string {
  46. return proto.EnumName(EntryType_name, int32(x))
  47. }
  48. func (x *EntryType) UnmarshalJSON(data []byte) error {
  49. value, err := proto.UnmarshalJSONEnum(EntryType_value, data, "EntryType")
  50. if err != nil {
  51. return err
  52. }
  53. *x = EntryType(value)
  54. return nil
  55. }
  56. type ConfChangeType int32
  57. const (
  58. ConfChangeAddNode ConfChangeType = 0
  59. ConfChangeRemoveNode ConfChangeType = 1
  60. )
  61. var ConfChangeType_name = map[int32]string{
  62. 0: "ConfChangeAddNode",
  63. 1: "ConfChangeRemoveNode",
  64. }
  65. var ConfChangeType_value = map[string]int32{
  66. "ConfChangeAddNode": 0,
  67. "ConfChangeRemoveNode": 1,
  68. }
  69. func (x ConfChangeType) Enum() *ConfChangeType {
  70. p := new(ConfChangeType)
  71. *p = x
  72. return p
  73. }
  74. func (x ConfChangeType) String() string {
  75. return proto.EnumName(ConfChangeType_name, int32(x))
  76. }
  77. func (x *ConfChangeType) UnmarshalJSON(data []byte) error {
  78. value, err := proto.UnmarshalJSONEnum(ConfChangeType_value, data, "ConfChangeType")
  79. if err != nil {
  80. return err
  81. }
  82. *x = ConfChangeType(value)
  83. return nil
  84. }
  85. type Info struct {
  86. Id int64 `protobuf:"varint,1,req,name=id" json:"id"`
  87. XXX_unrecognized []byte `json:"-"`
  88. }
  89. func (m *Info) Reset() { *m = Info{} }
  90. func (m *Info) String() string { return proto.CompactTextString(m) }
  91. func (*Info) ProtoMessage() {}
  92. type Entry struct {
  93. Type EntryType `protobuf:"varint,1,req,enum=raftpb.EntryType" json:"Type"`
  94. Term int64 `protobuf:"varint,2,req" json:"Term"`
  95. Index int64 `protobuf:"varint,3,req" json:"Index"`
  96. Data []byte `protobuf:"bytes,4,opt" json:"Data"`
  97. XXX_unrecognized []byte `json:"-"`
  98. }
  99. func (m *Entry) Reset() { *m = Entry{} }
  100. func (m *Entry) String() string { return proto.CompactTextString(m) }
  101. func (*Entry) ProtoMessage() {}
  102. type Snapshot struct {
  103. Data []byte `protobuf:"bytes,1,req,name=data" json:"data"`
  104. Nodes []int64 `protobuf:"varint,2,rep,name=nodes" json:"nodes"`
  105. Index int64 `protobuf:"varint,3,req,name=index" json:"index"`
  106. Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
  107. XXX_unrecognized []byte `json:"-"`
  108. }
  109. func (m *Snapshot) Reset() { *m = Snapshot{} }
  110. func (m *Snapshot) String() string { return proto.CompactTextString(m) }
  111. func (*Snapshot) ProtoMessage() {}
  112. type Message struct {
  113. Type int64 `protobuf:"varint,1,req,name=type" json:"type"`
  114. To int64 `protobuf:"varint,2,req,name=to" json:"to"`
  115. From int64 `protobuf:"varint,3,req,name=from" json:"from"`
  116. Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
  117. LogTerm int64 `protobuf:"varint,5,req,name=logTerm" json:"logTerm"`
  118. Index int64 `protobuf:"varint,6,req,name=index" json:"index"`
  119. Entries []Entry `protobuf:"bytes,7,rep,name=entries" json:"entries"`
  120. Commit int64 `protobuf:"varint,8,req,name=commit" json:"commit"`
  121. Snapshot Snapshot `protobuf:"bytes,9,req,name=snapshot" json:"snapshot"`
  122. XXX_unrecognized []byte `json:"-"`
  123. }
  124. func (m *Message) Reset() { *m = Message{} }
  125. func (m *Message) String() string { return proto.CompactTextString(m) }
  126. func (*Message) ProtoMessage() {}
  127. type HardState struct {
  128. Term int64 `protobuf:"varint,1,req,name=term" json:"term"`
  129. Vote int64 `protobuf:"varint,2,req,name=vote" json:"vote"`
  130. Commit int64 `protobuf:"varint,3,req,name=commit" json:"commit"`
  131. XXX_unrecognized []byte `json:"-"`
  132. }
  133. func (m *HardState) Reset() { *m = HardState{} }
  134. func (m *HardState) String() string { return proto.CompactTextString(m) }
  135. func (*HardState) ProtoMessage() {}
  136. type ConfChange struct {
  137. ID int64 `protobuf:"varint,1,req" json:"ID"`
  138. Type ConfChangeType `protobuf:"varint,2,req,enum=raftpb.ConfChangeType" json:"Type"`
  139. NodeID int64 `protobuf:"varint,3,req" json:"NodeID"`
  140. Context []byte `protobuf:"bytes,4,opt" json:"Context"`
  141. XXX_unrecognized []byte `json:"-"`
  142. }
  143. func (m *ConfChange) Reset() { *m = ConfChange{} }
  144. func (m *ConfChange) String() string { return proto.CompactTextString(m) }
  145. func (*ConfChange) ProtoMessage() {}
  146. func init() {
  147. proto.RegisterEnum("raftpb.EntryType", EntryType_name, EntryType_value)
  148. proto.RegisterEnum("raftpb.ConfChangeType", ConfChangeType_name, ConfChangeType_value)
  149. }
  150. func (m *Info) Unmarshal(data []byte) error {
  151. l := len(data)
  152. index := 0
  153. for index < l {
  154. var wire uint64
  155. for shift := uint(0); ; shift += 7 {
  156. if index >= l {
  157. return io.ErrUnexpectedEOF
  158. }
  159. b := data[index]
  160. index++
  161. wire |= (uint64(b) & 0x7F) << shift
  162. if b < 0x80 {
  163. break
  164. }
  165. }
  166. fieldNum := int32(wire >> 3)
  167. wireType := int(wire & 0x7)
  168. switch fieldNum {
  169. case 1:
  170. if wireType != 0 {
  171. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  172. }
  173. for shift := uint(0); ; shift += 7 {
  174. if index >= l {
  175. return io.ErrUnexpectedEOF
  176. }
  177. b := data[index]
  178. index++
  179. m.Id |= (int64(b) & 0x7F) << shift
  180. if b < 0x80 {
  181. break
  182. }
  183. }
  184. default:
  185. var sizeOfWire int
  186. for {
  187. sizeOfWire++
  188. wire >>= 7
  189. if wire == 0 {
  190. break
  191. }
  192. }
  193. index -= sizeOfWire
  194. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  195. if err != nil {
  196. return err
  197. }
  198. if (index + skippy) > l {
  199. return io.ErrUnexpectedEOF
  200. }
  201. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  202. index += skippy
  203. }
  204. }
  205. return nil
  206. }
  207. func (m *Entry) Unmarshal(data []byte) error {
  208. l := len(data)
  209. index := 0
  210. for index < l {
  211. var wire uint64
  212. for shift := uint(0); ; shift += 7 {
  213. if index >= l {
  214. return io.ErrUnexpectedEOF
  215. }
  216. b := data[index]
  217. index++
  218. wire |= (uint64(b) & 0x7F) << shift
  219. if b < 0x80 {
  220. break
  221. }
  222. }
  223. fieldNum := int32(wire >> 3)
  224. wireType := int(wire & 0x7)
  225. switch fieldNum {
  226. case 1:
  227. if wireType != 0 {
  228. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  229. }
  230. for shift := uint(0); ; shift += 7 {
  231. if index >= l {
  232. return io.ErrUnexpectedEOF
  233. }
  234. b := data[index]
  235. index++
  236. m.Type |= (EntryType(b) & 0x7F) << shift
  237. if b < 0x80 {
  238. break
  239. }
  240. }
  241. case 2:
  242. if wireType != 0 {
  243. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  244. }
  245. for shift := uint(0); ; shift += 7 {
  246. if index >= l {
  247. return io.ErrUnexpectedEOF
  248. }
  249. b := data[index]
  250. index++
  251. m.Term |= (int64(b) & 0x7F) << shift
  252. if b < 0x80 {
  253. break
  254. }
  255. }
  256. case 3:
  257. if wireType != 0 {
  258. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  259. }
  260. for shift := uint(0); ; shift += 7 {
  261. if index >= l {
  262. return io.ErrUnexpectedEOF
  263. }
  264. b := data[index]
  265. index++
  266. m.Index |= (int64(b) & 0x7F) << shift
  267. if b < 0x80 {
  268. break
  269. }
  270. }
  271. case 4:
  272. if wireType != 2 {
  273. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  274. }
  275. var byteLen int
  276. for shift := uint(0); ; shift += 7 {
  277. if index >= l {
  278. return io.ErrUnexpectedEOF
  279. }
  280. b := data[index]
  281. index++
  282. byteLen |= (int(b) & 0x7F) << shift
  283. if b < 0x80 {
  284. break
  285. }
  286. }
  287. postIndex := index + byteLen
  288. if postIndex > l {
  289. return io.ErrUnexpectedEOF
  290. }
  291. m.Data = append(m.Data, data[index:postIndex]...)
  292. index = postIndex
  293. default:
  294. var sizeOfWire int
  295. for {
  296. sizeOfWire++
  297. wire >>= 7
  298. if wire == 0 {
  299. break
  300. }
  301. }
  302. index -= sizeOfWire
  303. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  304. if err != nil {
  305. return err
  306. }
  307. if (index + skippy) > l {
  308. return io.ErrUnexpectedEOF
  309. }
  310. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  311. index += skippy
  312. }
  313. }
  314. return nil
  315. }
  316. func (m *Snapshot) Unmarshal(data []byte) error {
  317. l := len(data)
  318. index := 0
  319. for index < l {
  320. var wire uint64
  321. for shift := uint(0); ; shift += 7 {
  322. if index >= l {
  323. return io.ErrUnexpectedEOF
  324. }
  325. b := data[index]
  326. index++
  327. wire |= (uint64(b) & 0x7F) << shift
  328. if b < 0x80 {
  329. break
  330. }
  331. }
  332. fieldNum := int32(wire >> 3)
  333. wireType := int(wire & 0x7)
  334. switch fieldNum {
  335. case 1:
  336. if wireType != 2 {
  337. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  338. }
  339. var byteLen int
  340. for shift := uint(0); ; shift += 7 {
  341. if index >= l {
  342. return io.ErrUnexpectedEOF
  343. }
  344. b := data[index]
  345. index++
  346. byteLen |= (int(b) & 0x7F) << shift
  347. if b < 0x80 {
  348. break
  349. }
  350. }
  351. postIndex := index + byteLen
  352. if postIndex > l {
  353. return io.ErrUnexpectedEOF
  354. }
  355. m.Data = append(m.Data, data[index:postIndex]...)
  356. index = postIndex
  357. case 2:
  358. if wireType != 0 {
  359. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  360. }
  361. var v int64
  362. for shift := uint(0); ; shift += 7 {
  363. if index >= l {
  364. return io.ErrUnexpectedEOF
  365. }
  366. b := data[index]
  367. index++
  368. v |= (int64(b) & 0x7F) << shift
  369. if b < 0x80 {
  370. break
  371. }
  372. }
  373. m.Nodes = append(m.Nodes, v)
  374. case 3:
  375. if wireType != 0 {
  376. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  377. }
  378. for shift := uint(0); ; shift += 7 {
  379. if index >= l {
  380. return io.ErrUnexpectedEOF
  381. }
  382. b := data[index]
  383. index++
  384. m.Index |= (int64(b) & 0x7F) << shift
  385. if b < 0x80 {
  386. break
  387. }
  388. }
  389. case 4:
  390. if wireType != 0 {
  391. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  392. }
  393. for shift := uint(0); ; shift += 7 {
  394. if index >= l {
  395. return io.ErrUnexpectedEOF
  396. }
  397. b := data[index]
  398. index++
  399. m.Term |= (int64(b) & 0x7F) << shift
  400. if b < 0x80 {
  401. break
  402. }
  403. }
  404. default:
  405. var sizeOfWire int
  406. for {
  407. sizeOfWire++
  408. wire >>= 7
  409. if wire == 0 {
  410. break
  411. }
  412. }
  413. index -= sizeOfWire
  414. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  415. if err != nil {
  416. return err
  417. }
  418. if (index + skippy) > l {
  419. return io.ErrUnexpectedEOF
  420. }
  421. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  422. index += skippy
  423. }
  424. }
  425. return nil
  426. }
  427. func (m *Message) Unmarshal(data []byte) error {
  428. l := len(data)
  429. index := 0
  430. for index < l {
  431. var wire uint64
  432. for shift := uint(0); ; shift += 7 {
  433. if index >= l {
  434. return io.ErrUnexpectedEOF
  435. }
  436. b := data[index]
  437. index++
  438. wire |= (uint64(b) & 0x7F) << shift
  439. if b < 0x80 {
  440. break
  441. }
  442. }
  443. fieldNum := int32(wire >> 3)
  444. wireType := int(wire & 0x7)
  445. switch fieldNum {
  446. case 1:
  447. if wireType != 0 {
  448. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  449. }
  450. for shift := uint(0); ; shift += 7 {
  451. if index >= l {
  452. return io.ErrUnexpectedEOF
  453. }
  454. b := data[index]
  455. index++
  456. m.Type |= (int64(b) & 0x7F) << shift
  457. if b < 0x80 {
  458. break
  459. }
  460. }
  461. case 2:
  462. if wireType != 0 {
  463. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  464. }
  465. for shift := uint(0); ; shift += 7 {
  466. if index >= l {
  467. return io.ErrUnexpectedEOF
  468. }
  469. b := data[index]
  470. index++
  471. m.To |= (int64(b) & 0x7F) << shift
  472. if b < 0x80 {
  473. break
  474. }
  475. }
  476. case 3:
  477. if wireType != 0 {
  478. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  479. }
  480. for shift := uint(0); ; shift += 7 {
  481. if index >= l {
  482. return io.ErrUnexpectedEOF
  483. }
  484. b := data[index]
  485. index++
  486. m.From |= (int64(b) & 0x7F) << shift
  487. if b < 0x80 {
  488. break
  489. }
  490. }
  491. case 4:
  492. if wireType != 0 {
  493. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  494. }
  495. for shift := uint(0); ; shift += 7 {
  496. if index >= l {
  497. return io.ErrUnexpectedEOF
  498. }
  499. b := data[index]
  500. index++
  501. m.Term |= (int64(b) & 0x7F) << shift
  502. if b < 0x80 {
  503. break
  504. }
  505. }
  506. case 5:
  507. if wireType != 0 {
  508. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  509. }
  510. for shift := uint(0); ; shift += 7 {
  511. if index >= l {
  512. return io.ErrUnexpectedEOF
  513. }
  514. b := data[index]
  515. index++
  516. m.LogTerm |= (int64(b) & 0x7F) << shift
  517. if b < 0x80 {
  518. break
  519. }
  520. }
  521. case 6:
  522. if wireType != 0 {
  523. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  524. }
  525. for shift := uint(0); ; shift += 7 {
  526. if index >= l {
  527. return io.ErrUnexpectedEOF
  528. }
  529. b := data[index]
  530. index++
  531. m.Index |= (int64(b) & 0x7F) << shift
  532. if b < 0x80 {
  533. break
  534. }
  535. }
  536. case 7:
  537. if wireType != 2 {
  538. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  539. }
  540. var msglen int
  541. for shift := uint(0); ; shift += 7 {
  542. if index >= l {
  543. return io.ErrUnexpectedEOF
  544. }
  545. b := data[index]
  546. index++
  547. msglen |= (int(b) & 0x7F) << shift
  548. if b < 0x80 {
  549. break
  550. }
  551. }
  552. postIndex := index + msglen
  553. if postIndex > l {
  554. return io.ErrUnexpectedEOF
  555. }
  556. m.Entries = append(m.Entries, Entry{})
  557. m.Entries[len(m.Entries)-1].Unmarshal(data[index:postIndex])
  558. index = postIndex
  559. case 8:
  560. if wireType != 0 {
  561. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  562. }
  563. for shift := uint(0); ; shift += 7 {
  564. if index >= l {
  565. return io.ErrUnexpectedEOF
  566. }
  567. b := data[index]
  568. index++
  569. m.Commit |= (int64(b) & 0x7F) << shift
  570. if b < 0x80 {
  571. break
  572. }
  573. }
  574. case 9:
  575. if wireType != 2 {
  576. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  577. }
  578. var msglen int
  579. for shift := uint(0); ; shift += 7 {
  580. if index >= l {
  581. return io.ErrUnexpectedEOF
  582. }
  583. b := data[index]
  584. index++
  585. msglen |= (int(b) & 0x7F) << shift
  586. if b < 0x80 {
  587. break
  588. }
  589. }
  590. postIndex := index + msglen
  591. if postIndex > l {
  592. return io.ErrUnexpectedEOF
  593. }
  594. if err := m.Snapshot.Unmarshal(data[index:postIndex]); err != nil {
  595. return err
  596. }
  597. index = postIndex
  598. default:
  599. var sizeOfWire int
  600. for {
  601. sizeOfWire++
  602. wire >>= 7
  603. if wire == 0 {
  604. break
  605. }
  606. }
  607. index -= sizeOfWire
  608. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  609. if err != nil {
  610. return err
  611. }
  612. if (index + skippy) > l {
  613. return io.ErrUnexpectedEOF
  614. }
  615. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  616. index += skippy
  617. }
  618. }
  619. return nil
  620. }
  621. func (m *HardState) Unmarshal(data []byte) error {
  622. l := len(data)
  623. index := 0
  624. for index < l {
  625. var wire uint64
  626. for shift := uint(0); ; shift += 7 {
  627. if index >= l {
  628. return io.ErrUnexpectedEOF
  629. }
  630. b := data[index]
  631. index++
  632. wire |= (uint64(b) & 0x7F) << shift
  633. if b < 0x80 {
  634. break
  635. }
  636. }
  637. fieldNum := int32(wire >> 3)
  638. wireType := int(wire & 0x7)
  639. switch fieldNum {
  640. case 1:
  641. if wireType != 0 {
  642. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  643. }
  644. for shift := uint(0); ; shift += 7 {
  645. if index >= l {
  646. return io.ErrUnexpectedEOF
  647. }
  648. b := data[index]
  649. index++
  650. m.Term |= (int64(b) & 0x7F) << shift
  651. if b < 0x80 {
  652. break
  653. }
  654. }
  655. case 2:
  656. if wireType != 0 {
  657. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  658. }
  659. for shift := uint(0); ; shift += 7 {
  660. if index >= l {
  661. return io.ErrUnexpectedEOF
  662. }
  663. b := data[index]
  664. index++
  665. m.Vote |= (int64(b) & 0x7F) << shift
  666. if b < 0x80 {
  667. break
  668. }
  669. }
  670. case 3:
  671. if wireType != 0 {
  672. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  673. }
  674. for shift := uint(0); ; shift += 7 {
  675. if index >= l {
  676. return io.ErrUnexpectedEOF
  677. }
  678. b := data[index]
  679. index++
  680. m.Commit |= (int64(b) & 0x7F) << shift
  681. if b < 0x80 {
  682. break
  683. }
  684. }
  685. default:
  686. var sizeOfWire int
  687. for {
  688. sizeOfWire++
  689. wire >>= 7
  690. if wire == 0 {
  691. break
  692. }
  693. }
  694. index -= sizeOfWire
  695. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  696. if err != nil {
  697. return err
  698. }
  699. if (index + skippy) > l {
  700. return io.ErrUnexpectedEOF
  701. }
  702. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  703. index += skippy
  704. }
  705. }
  706. return nil
  707. }
  708. func (m *ConfChange) Unmarshal(data []byte) error {
  709. l := len(data)
  710. index := 0
  711. for index < l {
  712. var wire uint64
  713. for shift := uint(0); ; shift += 7 {
  714. if index >= l {
  715. return io.ErrUnexpectedEOF
  716. }
  717. b := data[index]
  718. index++
  719. wire |= (uint64(b) & 0x7F) << shift
  720. if b < 0x80 {
  721. break
  722. }
  723. }
  724. fieldNum := int32(wire >> 3)
  725. wireType := int(wire & 0x7)
  726. switch fieldNum {
  727. case 1:
  728. if wireType != 0 {
  729. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  730. }
  731. for shift := uint(0); ; shift += 7 {
  732. if index >= l {
  733. return io.ErrUnexpectedEOF
  734. }
  735. b := data[index]
  736. index++
  737. m.ID |= (int64(b) & 0x7F) << shift
  738. if b < 0x80 {
  739. break
  740. }
  741. }
  742. case 2:
  743. if wireType != 0 {
  744. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  745. }
  746. for shift := uint(0); ; shift += 7 {
  747. if index >= l {
  748. return io.ErrUnexpectedEOF
  749. }
  750. b := data[index]
  751. index++
  752. m.Type |= (ConfChangeType(b) & 0x7F) << shift
  753. if b < 0x80 {
  754. break
  755. }
  756. }
  757. case 3:
  758. if wireType != 0 {
  759. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  760. }
  761. for shift := uint(0); ; shift += 7 {
  762. if index >= l {
  763. return io.ErrUnexpectedEOF
  764. }
  765. b := data[index]
  766. index++
  767. m.NodeID |= (int64(b) & 0x7F) << shift
  768. if b < 0x80 {
  769. break
  770. }
  771. }
  772. case 4:
  773. if wireType != 2 {
  774. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  775. }
  776. var byteLen int
  777. for shift := uint(0); ; shift += 7 {
  778. if index >= l {
  779. return io.ErrUnexpectedEOF
  780. }
  781. b := data[index]
  782. index++
  783. byteLen |= (int(b) & 0x7F) << shift
  784. if b < 0x80 {
  785. break
  786. }
  787. }
  788. postIndex := index + byteLen
  789. if postIndex > l {
  790. return io.ErrUnexpectedEOF
  791. }
  792. m.Context = append(m.Context, data[index:postIndex]...)
  793. index = postIndex
  794. default:
  795. var sizeOfWire int
  796. for {
  797. sizeOfWire++
  798. wire >>= 7
  799. if wire == 0 {
  800. break
  801. }
  802. }
  803. index -= sizeOfWire
  804. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  805. if err != nil {
  806. return err
  807. }
  808. if (index + skippy) > l {
  809. return io.ErrUnexpectedEOF
  810. }
  811. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  812. index += skippy
  813. }
  814. }
  815. return nil
  816. }
  817. func (m *Info) Size() (n int) {
  818. var l int
  819. _ = l
  820. n += 1 + sovRaft(uint64(m.Id))
  821. if m.XXX_unrecognized != nil {
  822. n += len(m.XXX_unrecognized)
  823. }
  824. return n
  825. }
  826. func (m *Entry) Size() (n int) {
  827. var l int
  828. _ = l
  829. n += 1 + sovRaft(uint64(m.Type))
  830. n += 1 + sovRaft(uint64(m.Term))
  831. n += 1 + sovRaft(uint64(m.Index))
  832. l = len(m.Data)
  833. n += 1 + l + sovRaft(uint64(l))
  834. if m.XXX_unrecognized != nil {
  835. n += len(m.XXX_unrecognized)
  836. }
  837. return n
  838. }
  839. func (m *Snapshot) Size() (n int) {
  840. var l int
  841. _ = l
  842. l = len(m.Data)
  843. n += 1 + l + sovRaft(uint64(l))
  844. if len(m.Nodes) > 0 {
  845. for _, e := range m.Nodes {
  846. n += 1 + sovRaft(uint64(e))
  847. }
  848. }
  849. n += 1 + sovRaft(uint64(m.Index))
  850. n += 1 + sovRaft(uint64(m.Term))
  851. if m.XXX_unrecognized != nil {
  852. n += len(m.XXX_unrecognized)
  853. }
  854. return n
  855. }
  856. func (m *Message) Size() (n int) {
  857. var l int
  858. _ = l
  859. n += 1 + sovRaft(uint64(m.Type))
  860. n += 1 + sovRaft(uint64(m.To))
  861. n += 1 + sovRaft(uint64(m.From))
  862. n += 1 + sovRaft(uint64(m.Term))
  863. n += 1 + sovRaft(uint64(m.LogTerm))
  864. n += 1 + sovRaft(uint64(m.Index))
  865. if len(m.Entries) > 0 {
  866. for _, e := range m.Entries {
  867. l = e.Size()
  868. n += 1 + l + sovRaft(uint64(l))
  869. }
  870. }
  871. n += 1 + sovRaft(uint64(m.Commit))
  872. l = m.Snapshot.Size()
  873. n += 1 + l + sovRaft(uint64(l))
  874. if m.XXX_unrecognized != nil {
  875. n += len(m.XXX_unrecognized)
  876. }
  877. return n
  878. }
  879. func (m *HardState) Size() (n int) {
  880. var l int
  881. _ = l
  882. n += 1 + sovRaft(uint64(m.Term))
  883. n += 1 + sovRaft(uint64(m.Vote))
  884. n += 1 + sovRaft(uint64(m.Commit))
  885. if m.XXX_unrecognized != nil {
  886. n += len(m.XXX_unrecognized)
  887. }
  888. return n
  889. }
  890. func (m *ConfChange) Size() (n int) {
  891. var l int
  892. _ = l
  893. n += 1 + sovRaft(uint64(m.ID))
  894. n += 1 + sovRaft(uint64(m.Type))
  895. n += 1 + sovRaft(uint64(m.NodeID))
  896. l = len(m.Context)
  897. n += 1 + l + sovRaft(uint64(l))
  898. if m.XXX_unrecognized != nil {
  899. n += len(m.XXX_unrecognized)
  900. }
  901. return n
  902. }
  903. func sovRaft(x uint64) (n int) {
  904. for {
  905. n++
  906. x >>= 7
  907. if x == 0 {
  908. break
  909. }
  910. }
  911. return n
  912. }
  913. func sozRaft(x uint64) (n int) {
  914. return sovRaft(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  915. }
  916. func (m *Info) Marshal() (data []byte, err error) {
  917. size := m.Size()
  918. data = make([]byte, size)
  919. n, err := m.MarshalTo(data)
  920. if err != nil {
  921. return nil, err
  922. }
  923. return data[:n], nil
  924. }
  925. func (m *Info) MarshalTo(data []byte) (n int, err error) {
  926. var i int
  927. _ = i
  928. var l int
  929. _ = l
  930. data[i] = 0x8
  931. i++
  932. i = encodeVarintRaft(data, i, uint64(m.Id))
  933. if m.XXX_unrecognized != nil {
  934. i += copy(data[i:], m.XXX_unrecognized)
  935. }
  936. return i, nil
  937. }
  938. func (m *Entry) Marshal() (data []byte, err error) {
  939. size := m.Size()
  940. data = make([]byte, size)
  941. n, err := m.MarshalTo(data)
  942. if err != nil {
  943. return nil, err
  944. }
  945. return data[:n], nil
  946. }
  947. func (m *Entry) MarshalTo(data []byte) (n int, err error) {
  948. var i int
  949. _ = i
  950. var l int
  951. _ = l
  952. data[i] = 0x8
  953. i++
  954. i = encodeVarintRaft(data, i, uint64(m.Type))
  955. data[i] = 0x10
  956. i++
  957. i = encodeVarintRaft(data, i, uint64(m.Term))
  958. data[i] = 0x18
  959. i++
  960. i = encodeVarintRaft(data, i, uint64(m.Index))
  961. data[i] = 0x22
  962. i++
  963. i = encodeVarintRaft(data, i, uint64(len(m.Data)))
  964. i += copy(data[i:], m.Data)
  965. if m.XXX_unrecognized != nil {
  966. i += copy(data[i:], m.XXX_unrecognized)
  967. }
  968. return i, nil
  969. }
  970. func (m *Snapshot) Marshal() (data []byte, err error) {
  971. size := m.Size()
  972. data = make([]byte, size)
  973. n, err := m.MarshalTo(data)
  974. if err != nil {
  975. return nil, err
  976. }
  977. return data[:n], nil
  978. }
  979. func (m *Snapshot) MarshalTo(data []byte) (n int, err error) {
  980. var i int
  981. _ = i
  982. var l int
  983. _ = l
  984. data[i] = 0xa
  985. i++
  986. i = encodeVarintRaft(data, i, uint64(len(m.Data)))
  987. i += copy(data[i:], m.Data)
  988. if len(m.Nodes) > 0 {
  989. for _, num := range m.Nodes {
  990. data[i] = 0x10
  991. i++
  992. for num >= 1<<7 {
  993. data[i] = uint8(uint64(num)&0x7f | 0x80)
  994. num >>= 7
  995. i++
  996. }
  997. data[i] = uint8(num)
  998. i++
  999. }
  1000. }
  1001. data[i] = 0x18
  1002. i++
  1003. i = encodeVarintRaft(data, i, uint64(m.Index))
  1004. data[i] = 0x20
  1005. i++
  1006. i = encodeVarintRaft(data, i, uint64(m.Term))
  1007. if m.XXX_unrecognized != nil {
  1008. i += copy(data[i:], m.XXX_unrecognized)
  1009. }
  1010. return i, nil
  1011. }
  1012. func (m *Message) Marshal() (data []byte, err error) {
  1013. size := m.Size()
  1014. data = make([]byte, size)
  1015. n, err := m.MarshalTo(data)
  1016. if err != nil {
  1017. return nil, err
  1018. }
  1019. return data[:n], nil
  1020. }
  1021. func (m *Message) MarshalTo(data []byte) (n int, err error) {
  1022. var i int
  1023. _ = i
  1024. var l int
  1025. _ = l
  1026. data[i] = 0x8
  1027. i++
  1028. i = encodeVarintRaft(data, i, uint64(m.Type))
  1029. data[i] = 0x10
  1030. i++
  1031. i = encodeVarintRaft(data, i, uint64(m.To))
  1032. data[i] = 0x18
  1033. i++
  1034. i = encodeVarintRaft(data, i, uint64(m.From))
  1035. data[i] = 0x20
  1036. i++
  1037. i = encodeVarintRaft(data, i, uint64(m.Term))
  1038. data[i] = 0x28
  1039. i++
  1040. i = encodeVarintRaft(data, i, uint64(m.LogTerm))
  1041. data[i] = 0x30
  1042. i++
  1043. i = encodeVarintRaft(data, i, uint64(m.Index))
  1044. if len(m.Entries) > 0 {
  1045. for _, msg := range m.Entries {
  1046. data[i] = 0x3a
  1047. i++
  1048. i = encodeVarintRaft(data, i, uint64(msg.Size()))
  1049. n, err := msg.MarshalTo(data[i:])
  1050. if err != nil {
  1051. return 0, err
  1052. }
  1053. i += n
  1054. }
  1055. }
  1056. data[i] = 0x40
  1057. i++
  1058. i = encodeVarintRaft(data, i, uint64(m.Commit))
  1059. data[i] = 0x4a
  1060. i++
  1061. i = encodeVarintRaft(data, i, uint64(m.Snapshot.Size()))
  1062. n1, err := m.Snapshot.MarshalTo(data[i:])
  1063. if err != nil {
  1064. return 0, err
  1065. }
  1066. i += n1
  1067. if m.XXX_unrecognized != nil {
  1068. i += copy(data[i:], m.XXX_unrecognized)
  1069. }
  1070. return i, nil
  1071. }
  1072. func (m *HardState) Marshal() (data []byte, err error) {
  1073. size := m.Size()
  1074. data = make([]byte, size)
  1075. n, err := m.MarshalTo(data)
  1076. if err != nil {
  1077. return nil, err
  1078. }
  1079. return data[:n], nil
  1080. }
  1081. func (m *HardState) MarshalTo(data []byte) (n int, err error) {
  1082. var i int
  1083. _ = i
  1084. var l int
  1085. _ = l
  1086. data[i] = 0x8
  1087. i++
  1088. i = encodeVarintRaft(data, i, uint64(m.Term))
  1089. data[i] = 0x10
  1090. i++
  1091. i = encodeVarintRaft(data, i, uint64(m.Vote))
  1092. data[i] = 0x18
  1093. i++
  1094. i = encodeVarintRaft(data, i, uint64(m.Commit))
  1095. if m.XXX_unrecognized != nil {
  1096. i += copy(data[i:], m.XXX_unrecognized)
  1097. }
  1098. return i, nil
  1099. }
  1100. func (m *ConfChange) Marshal() (data []byte, err error) {
  1101. size := m.Size()
  1102. data = make([]byte, size)
  1103. n, err := m.MarshalTo(data)
  1104. if err != nil {
  1105. return nil, err
  1106. }
  1107. return data[:n], nil
  1108. }
  1109. func (m *ConfChange) MarshalTo(data []byte) (n int, err error) {
  1110. var i int
  1111. _ = i
  1112. var l int
  1113. _ = l
  1114. data[i] = 0x8
  1115. i++
  1116. i = encodeVarintRaft(data, i, uint64(m.ID))
  1117. data[i] = 0x10
  1118. i++
  1119. i = encodeVarintRaft(data, i, uint64(m.Type))
  1120. data[i] = 0x18
  1121. i++
  1122. i = encodeVarintRaft(data, i, uint64(m.NodeID))
  1123. data[i] = 0x22
  1124. i++
  1125. i = encodeVarintRaft(data, i, uint64(len(m.Context)))
  1126. i += copy(data[i:], m.Context)
  1127. if m.XXX_unrecognized != nil {
  1128. i += copy(data[i:], m.XXX_unrecognized)
  1129. }
  1130. return i, nil
  1131. }
  1132. func encodeFixed64Raft(data []byte, offset int, v uint64) int {
  1133. data[offset] = uint8(v)
  1134. data[offset+1] = uint8(v >> 8)
  1135. data[offset+2] = uint8(v >> 16)
  1136. data[offset+3] = uint8(v >> 24)
  1137. data[offset+4] = uint8(v >> 32)
  1138. data[offset+5] = uint8(v >> 40)
  1139. data[offset+6] = uint8(v >> 48)
  1140. data[offset+7] = uint8(v >> 56)
  1141. return offset + 8
  1142. }
  1143. func encodeFixed32Raft(data []byte, offset int, v uint32) int {
  1144. data[offset] = uint8(v)
  1145. data[offset+1] = uint8(v >> 8)
  1146. data[offset+2] = uint8(v >> 16)
  1147. data[offset+3] = uint8(v >> 24)
  1148. return offset + 4
  1149. }
  1150. func encodeVarintRaft(data []byte, offset int, v uint64) int {
  1151. for v >= 1<<7 {
  1152. data[offset] = uint8(v&0x7f | 0x80)
  1153. v >>= 7
  1154. offset++
  1155. }
  1156. data[offset] = uint8(v)
  1157. return offset + 1
  1158. }