raft.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951
  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. State
  14. */
  15. package raftpb
  16. import proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  17. import json "encoding/json"
  18. import math "math"
  19. // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
  20. import io "io"
  21. import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  22. // Reference proto, json, and math imports to suppress error if they are not otherwise used.
  23. var _ = proto.Marshal
  24. var _ = &json.SyntaxError{}
  25. var _ = math.Inf
  26. type Info struct {
  27. Id int64 `protobuf:"varint,1,req,name=id" json:"id"`
  28. XXX_unrecognized []byte `json:"-"`
  29. }
  30. func (m *Info) Reset() { *m = Info{} }
  31. func (m *Info) String() string { return proto.CompactTextString(m) }
  32. func (*Info) ProtoMessage() {}
  33. type Entry struct {
  34. Term int64 `protobuf:"varint,2,req,name=term" json:"term"`
  35. Index int64 `protobuf:"varint,3,req,name=index" json:"index"`
  36. Data []byte `protobuf:"bytes,4,opt,name=data" json:"data"`
  37. XXX_unrecognized []byte `json:"-"`
  38. }
  39. func (m *Entry) Reset() { *m = Entry{} }
  40. func (m *Entry) String() string { return proto.CompactTextString(m) }
  41. func (*Entry) ProtoMessage() {}
  42. type Snapshot struct {
  43. Data []byte `protobuf:"bytes,1,req,name=data" json:"data"`
  44. Nodes []int64 `protobuf:"varint,2,rep,name=nodes" json:"nodes"`
  45. Index int64 `protobuf:"varint,3,req,name=index" json:"index"`
  46. Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
  47. XXX_unrecognized []byte `json:"-"`
  48. }
  49. func (m *Snapshot) Reset() { *m = Snapshot{} }
  50. func (m *Snapshot) String() string { return proto.CompactTextString(m) }
  51. func (*Snapshot) ProtoMessage() {}
  52. type Message struct {
  53. Type int64 `protobuf:"varint,1,req,name=type" json:"type"`
  54. To int64 `protobuf:"varint,2,req,name=to" json:"to"`
  55. From int64 `protobuf:"varint,3,req,name=from" json:"from"`
  56. Term int64 `protobuf:"varint,4,req,name=term" json:"term"`
  57. LogTerm int64 `protobuf:"varint,5,req,name=logTerm" json:"logTerm"`
  58. Index int64 `protobuf:"varint,6,req,name=index" json:"index"`
  59. Entries []Entry `protobuf:"bytes,7,rep,name=entries" json:"entries"`
  60. Commit int64 `protobuf:"varint,8,req,name=commit" json:"commit"`
  61. Snapshot Snapshot `protobuf:"bytes,9,req,name=snapshot" json:"snapshot"`
  62. XXX_unrecognized []byte `json:"-"`
  63. }
  64. func (m *Message) Reset() { *m = Message{} }
  65. func (m *Message) String() string { return proto.CompactTextString(m) }
  66. func (*Message) ProtoMessage() {}
  67. type State struct {
  68. Term int64 `protobuf:"varint,1,req,name=term" json:"term"`
  69. Vote int64 `protobuf:"varint,2,req,name=vote" json:"vote"`
  70. Commit int64 `protobuf:"varint,3,req,name=commit" json:"commit"`
  71. LastIndex int64 `protobuf:"varint,4,req,name=lastIndex" json:"lastIndex"`
  72. XXX_unrecognized []byte `json:"-"`
  73. }
  74. func (m *State) Reset() { *m = State{} }
  75. func (m *State) String() string { return proto.CompactTextString(m) }
  76. func (*State) ProtoMessage() {}
  77. func init() {
  78. }
  79. func (m *Info) Unmarshal(data []byte) error {
  80. l := len(data)
  81. index := 0
  82. for index < l {
  83. var wire uint64
  84. for shift := uint(0); ; shift += 7 {
  85. if index >= l {
  86. return io.ErrUnexpectedEOF
  87. }
  88. b := data[index]
  89. index++
  90. wire |= (uint64(b) & 0x7F) << shift
  91. if b < 0x80 {
  92. break
  93. }
  94. }
  95. fieldNum := int32(wire >> 3)
  96. wireType := int(wire & 0x7)
  97. switch fieldNum {
  98. case 1:
  99. if wireType != 0 {
  100. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  101. }
  102. for shift := uint(0); ; shift += 7 {
  103. if index >= l {
  104. return io.ErrUnexpectedEOF
  105. }
  106. b := data[index]
  107. index++
  108. m.Id |= (int64(b) & 0x7F) << shift
  109. if b < 0x80 {
  110. break
  111. }
  112. }
  113. default:
  114. var sizeOfWire int
  115. for {
  116. sizeOfWire++
  117. wire >>= 7
  118. if wire == 0 {
  119. break
  120. }
  121. }
  122. index -= sizeOfWire
  123. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  124. if err != nil {
  125. return err
  126. }
  127. if (index + skippy) > l {
  128. return io.ErrUnexpectedEOF
  129. }
  130. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  131. index += skippy
  132. }
  133. }
  134. return nil
  135. }
  136. func (m *Entry) Unmarshal(data []byte) error {
  137. l := len(data)
  138. index := 0
  139. for index < l {
  140. var wire uint64
  141. for shift := uint(0); ; shift += 7 {
  142. if index >= l {
  143. return io.ErrUnexpectedEOF
  144. }
  145. b := data[index]
  146. index++
  147. wire |= (uint64(b) & 0x7F) << shift
  148. if b < 0x80 {
  149. break
  150. }
  151. }
  152. fieldNum := int32(wire >> 3)
  153. wireType := int(wire & 0x7)
  154. switch fieldNum {
  155. case 2:
  156. if wireType != 0 {
  157. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  158. }
  159. for shift := uint(0); ; shift += 7 {
  160. if index >= l {
  161. return io.ErrUnexpectedEOF
  162. }
  163. b := data[index]
  164. index++
  165. m.Term |= (int64(b) & 0x7F) << shift
  166. if b < 0x80 {
  167. break
  168. }
  169. }
  170. case 3:
  171. if wireType != 0 {
  172. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  173. }
  174. for shift := uint(0); ; shift += 7 {
  175. if index >= l {
  176. return io.ErrUnexpectedEOF
  177. }
  178. b := data[index]
  179. index++
  180. m.Index |= (int64(b) & 0x7F) << shift
  181. if b < 0x80 {
  182. break
  183. }
  184. }
  185. case 4:
  186. if wireType != 2 {
  187. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  188. }
  189. var byteLen int
  190. for shift := uint(0); ; shift += 7 {
  191. if index >= l {
  192. return io.ErrUnexpectedEOF
  193. }
  194. b := data[index]
  195. index++
  196. byteLen |= (int(b) & 0x7F) << shift
  197. if b < 0x80 {
  198. break
  199. }
  200. }
  201. postIndex := index + byteLen
  202. if postIndex > l {
  203. return io.ErrUnexpectedEOF
  204. }
  205. m.Data = append(m.Data, data[index:postIndex]...)
  206. index = postIndex
  207. default:
  208. var sizeOfWire int
  209. for {
  210. sizeOfWire++
  211. wire >>= 7
  212. if wire == 0 {
  213. break
  214. }
  215. }
  216. index -= sizeOfWire
  217. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  218. if err != nil {
  219. return err
  220. }
  221. if (index + skippy) > l {
  222. return io.ErrUnexpectedEOF
  223. }
  224. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  225. index += skippy
  226. }
  227. }
  228. return nil
  229. }
  230. func (m *Snapshot) Unmarshal(data []byte) error {
  231. l := len(data)
  232. index := 0
  233. for index < l {
  234. var wire uint64
  235. for shift := uint(0); ; shift += 7 {
  236. if index >= l {
  237. return io.ErrUnexpectedEOF
  238. }
  239. b := data[index]
  240. index++
  241. wire |= (uint64(b) & 0x7F) << shift
  242. if b < 0x80 {
  243. break
  244. }
  245. }
  246. fieldNum := int32(wire >> 3)
  247. wireType := int(wire & 0x7)
  248. switch fieldNum {
  249. case 1:
  250. if wireType != 2 {
  251. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  252. }
  253. var byteLen int
  254. for shift := uint(0); ; shift += 7 {
  255. if index >= l {
  256. return io.ErrUnexpectedEOF
  257. }
  258. b := data[index]
  259. index++
  260. byteLen |= (int(b) & 0x7F) << shift
  261. if b < 0x80 {
  262. break
  263. }
  264. }
  265. postIndex := index + byteLen
  266. if postIndex > l {
  267. return io.ErrUnexpectedEOF
  268. }
  269. m.Data = append(m.Data, data[index:postIndex]...)
  270. index = postIndex
  271. case 2:
  272. if wireType != 0 {
  273. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  274. }
  275. var v int64
  276. for shift := uint(0); ; shift += 7 {
  277. if index >= l {
  278. return io.ErrUnexpectedEOF
  279. }
  280. b := data[index]
  281. index++
  282. v |= (int64(b) & 0x7F) << shift
  283. if b < 0x80 {
  284. break
  285. }
  286. }
  287. m.Nodes = append(m.Nodes, v)
  288. case 3:
  289. if wireType != 0 {
  290. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  291. }
  292. for shift := uint(0); ; shift += 7 {
  293. if index >= l {
  294. return io.ErrUnexpectedEOF
  295. }
  296. b := data[index]
  297. index++
  298. m.Index |= (int64(b) & 0x7F) << shift
  299. if b < 0x80 {
  300. break
  301. }
  302. }
  303. case 4:
  304. if wireType != 0 {
  305. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  306. }
  307. for shift := uint(0); ; shift += 7 {
  308. if index >= l {
  309. return io.ErrUnexpectedEOF
  310. }
  311. b := data[index]
  312. index++
  313. m.Term |= (int64(b) & 0x7F) << shift
  314. if b < 0x80 {
  315. break
  316. }
  317. }
  318. default:
  319. var sizeOfWire int
  320. for {
  321. sizeOfWire++
  322. wire >>= 7
  323. if wire == 0 {
  324. break
  325. }
  326. }
  327. index -= sizeOfWire
  328. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  329. if err != nil {
  330. return err
  331. }
  332. if (index + skippy) > l {
  333. return io.ErrUnexpectedEOF
  334. }
  335. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  336. index += skippy
  337. }
  338. }
  339. return nil
  340. }
  341. func (m *Message) Unmarshal(data []byte) error {
  342. l := len(data)
  343. index := 0
  344. for index < l {
  345. var wire uint64
  346. for shift := uint(0); ; shift += 7 {
  347. if index >= l {
  348. return io.ErrUnexpectedEOF
  349. }
  350. b := data[index]
  351. index++
  352. wire |= (uint64(b) & 0x7F) << shift
  353. if b < 0x80 {
  354. break
  355. }
  356. }
  357. fieldNum := int32(wire >> 3)
  358. wireType := int(wire & 0x7)
  359. switch fieldNum {
  360. case 1:
  361. if wireType != 0 {
  362. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  363. }
  364. for shift := uint(0); ; shift += 7 {
  365. if index >= l {
  366. return io.ErrUnexpectedEOF
  367. }
  368. b := data[index]
  369. index++
  370. m.Type |= (int64(b) & 0x7F) << shift
  371. if b < 0x80 {
  372. break
  373. }
  374. }
  375. case 2:
  376. if wireType != 0 {
  377. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  378. }
  379. for shift := uint(0); ; shift += 7 {
  380. if index >= l {
  381. return io.ErrUnexpectedEOF
  382. }
  383. b := data[index]
  384. index++
  385. m.To |= (int64(b) & 0x7F) << shift
  386. if b < 0x80 {
  387. break
  388. }
  389. }
  390. case 3:
  391. if wireType != 0 {
  392. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  393. }
  394. for shift := uint(0); ; shift += 7 {
  395. if index >= l {
  396. return io.ErrUnexpectedEOF
  397. }
  398. b := data[index]
  399. index++
  400. m.From |= (int64(b) & 0x7F) << shift
  401. if b < 0x80 {
  402. break
  403. }
  404. }
  405. case 4:
  406. if wireType != 0 {
  407. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  408. }
  409. for shift := uint(0); ; shift += 7 {
  410. if index >= l {
  411. return io.ErrUnexpectedEOF
  412. }
  413. b := data[index]
  414. index++
  415. m.Term |= (int64(b) & 0x7F) << shift
  416. if b < 0x80 {
  417. break
  418. }
  419. }
  420. case 5:
  421. if wireType != 0 {
  422. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  423. }
  424. for shift := uint(0); ; shift += 7 {
  425. if index >= l {
  426. return io.ErrUnexpectedEOF
  427. }
  428. b := data[index]
  429. index++
  430. m.LogTerm |= (int64(b) & 0x7F) << shift
  431. if b < 0x80 {
  432. break
  433. }
  434. }
  435. case 6:
  436. if wireType != 0 {
  437. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  438. }
  439. for shift := uint(0); ; shift += 7 {
  440. if index >= l {
  441. return io.ErrUnexpectedEOF
  442. }
  443. b := data[index]
  444. index++
  445. m.Index |= (int64(b) & 0x7F) << shift
  446. if b < 0x80 {
  447. break
  448. }
  449. }
  450. case 7:
  451. if wireType != 2 {
  452. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  453. }
  454. var msglen int
  455. for shift := uint(0); ; shift += 7 {
  456. if index >= l {
  457. return io.ErrUnexpectedEOF
  458. }
  459. b := data[index]
  460. index++
  461. msglen |= (int(b) & 0x7F) << shift
  462. if b < 0x80 {
  463. break
  464. }
  465. }
  466. postIndex := index + msglen
  467. if postIndex > l {
  468. return io.ErrUnexpectedEOF
  469. }
  470. m.Entries = append(m.Entries, Entry{})
  471. m.Entries[len(m.Entries)-1].Unmarshal(data[index:postIndex])
  472. index = postIndex
  473. case 8:
  474. if wireType != 0 {
  475. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  476. }
  477. for shift := uint(0); ; shift += 7 {
  478. if index >= l {
  479. return io.ErrUnexpectedEOF
  480. }
  481. b := data[index]
  482. index++
  483. m.Commit |= (int64(b) & 0x7F) << shift
  484. if b < 0x80 {
  485. break
  486. }
  487. }
  488. case 9:
  489. if wireType != 2 {
  490. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  491. }
  492. var msglen int
  493. for shift := uint(0); ; shift += 7 {
  494. if index >= l {
  495. return io.ErrUnexpectedEOF
  496. }
  497. b := data[index]
  498. index++
  499. msglen |= (int(b) & 0x7F) << shift
  500. if b < 0x80 {
  501. break
  502. }
  503. }
  504. postIndex := index + msglen
  505. if postIndex > l {
  506. return io.ErrUnexpectedEOF
  507. }
  508. if err := m.Snapshot.Unmarshal(data[index:postIndex]); err != nil {
  509. return err
  510. }
  511. index = postIndex
  512. default:
  513. var sizeOfWire int
  514. for {
  515. sizeOfWire++
  516. wire >>= 7
  517. if wire == 0 {
  518. break
  519. }
  520. }
  521. index -= sizeOfWire
  522. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  523. if err != nil {
  524. return err
  525. }
  526. if (index + skippy) > l {
  527. return io.ErrUnexpectedEOF
  528. }
  529. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  530. index += skippy
  531. }
  532. }
  533. return nil
  534. }
  535. func (m *State) Unmarshal(data []byte) error {
  536. l := len(data)
  537. index := 0
  538. for index < l {
  539. var wire uint64
  540. for shift := uint(0); ; shift += 7 {
  541. if index >= l {
  542. return io.ErrUnexpectedEOF
  543. }
  544. b := data[index]
  545. index++
  546. wire |= (uint64(b) & 0x7F) << shift
  547. if b < 0x80 {
  548. break
  549. }
  550. }
  551. fieldNum := int32(wire >> 3)
  552. wireType := int(wire & 0x7)
  553. switch fieldNum {
  554. case 1:
  555. if wireType != 0 {
  556. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  557. }
  558. for shift := uint(0); ; shift += 7 {
  559. if index >= l {
  560. return io.ErrUnexpectedEOF
  561. }
  562. b := data[index]
  563. index++
  564. m.Term |= (int64(b) & 0x7F) << shift
  565. if b < 0x80 {
  566. break
  567. }
  568. }
  569. case 2:
  570. if wireType != 0 {
  571. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  572. }
  573. for shift := uint(0); ; shift += 7 {
  574. if index >= l {
  575. return io.ErrUnexpectedEOF
  576. }
  577. b := data[index]
  578. index++
  579. m.Vote |= (int64(b) & 0x7F) << shift
  580. if b < 0x80 {
  581. break
  582. }
  583. }
  584. case 3:
  585. if wireType != 0 {
  586. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  587. }
  588. for shift := uint(0); ; shift += 7 {
  589. if index >= l {
  590. return io.ErrUnexpectedEOF
  591. }
  592. b := data[index]
  593. index++
  594. m.Commit |= (int64(b) & 0x7F) << shift
  595. if b < 0x80 {
  596. break
  597. }
  598. }
  599. case 4:
  600. if wireType != 0 {
  601. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  602. }
  603. for shift := uint(0); ; shift += 7 {
  604. if index >= l {
  605. return io.ErrUnexpectedEOF
  606. }
  607. b := data[index]
  608. index++
  609. m.LastIndex |= (int64(b) & 0x7F) << shift
  610. if b < 0x80 {
  611. break
  612. }
  613. }
  614. default:
  615. var sizeOfWire int
  616. for {
  617. sizeOfWire++
  618. wire >>= 7
  619. if wire == 0 {
  620. break
  621. }
  622. }
  623. index -= sizeOfWire
  624. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  625. if err != nil {
  626. return err
  627. }
  628. if (index + skippy) > l {
  629. return io.ErrUnexpectedEOF
  630. }
  631. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  632. index += skippy
  633. }
  634. }
  635. return nil
  636. }
  637. func (m *Info) Size() (n int) {
  638. var l int
  639. _ = l
  640. n += 1 + sovRaft(uint64(m.Id))
  641. if m.XXX_unrecognized != nil {
  642. n += len(m.XXX_unrecognized)
  643. }
  644. return n
  645. }
  646. func (m *Entry) Size() (n int) {
  647. var l int
  648. _ = l
  649. n += 1 + sovRaft(uint64(m.Term))
  650. n += 1 + sovRaft(uint64(m.Index))
  651. l = len(m.Data)
  652. n += 1 + l + sovRaft(uint64(l))
  653. if m.XXX_unrecognized != nil {
  654. n += len(m.XXX_unrecognized)
  655. }
  656. return n
  657. }
  658. func (m *Snapshot) Size() (n int) {
  659. var l int
  660. _ = l
  661. l = len(m.Data)
  662. n += 1 + l + sovRaft(uint64(l))
  663. if len(m.Nodes) > 0 {
  664. for _, e := range m.Nodes {
  665. n += 1 + sovRaft(uint64(e))
  666. }
  667. }
  668. n += 1 + sovRaft(uint64(m.Index))
  669. n += 1 + sovRaft(uint64(m.Term))
  670. if m.XXX_unrecognized != nil {
  671. n += len(m.XXX_unrecognized)
  672. }
  673. return n
  674. }
  675. func (m *Message) Size() (n int) {
  676. var l int
  677. _ = l
  678. n += 1 + sovRaft(uint64(m.Type))
  679. n += 1 + sovRaft(uint64(m.To))
  680. n += 1 + sovRaft(uint64(m.From))
  681. n += 1 + sovRaft(uint64(m.Term))
  682. n += 1 + sovRaft(uint64(m.LogTerm))
  683. n += 1 + sovRaft(uint64(m.Index))
  684. if len(m.Entries) > 0 {
  685. for _, e := range m.Entries {
  686. l = e.Size()
  687. n += 1 + l + sovRaft(uint64(l))
  688. }
  689. }
  690. n += 1 + sovRaft(uint64(m.Commit))
  691. l = m.Snapshot.Size()
  692. n += 1 + l + sovRaft(uint64(l))
  693. if m.XXX_unrecognized != nil {
  694. n += len(m.XXX_unrecognized)
  695. }
  696. return n
  697. }
  698. func (m *State) Size() (n int) {
  699. var l int
  700. _ = l
  701. n += 1 + sovRaft(uint64(m.Term))
  702. n += 1 + sovRaft(uint64(m.Vote))
  703. n += 1 + sovRaft(uint64(m.Commit))
  704. n += 1 + sovRaft(uint64(m.LastIndex))
  705. if m.XXX_unrecognized != nil {
  706. n += len(m.XXX_unrecognized)
  707. }
  708. return n
  709. }
  710. func sovRaft(x uint64) (n int) {
  711. for {
  712. n++
  713. x >>= 7
  714. if x == 0 {
  715. break
  716. }
  717. }
  718. return n
  719. }
  720. func sozRaft(x uint64) (n int) {
  721. return sovRaft(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  722. }
  723. func (m *Info) Marshal() (data []byte, err error) {
  724. size := m.Size()
  725. data = make([]byte, size)
  726. n, err := m.MarshalTo(data)
  727. if err != nil {
  728. return nil, err
  729. }
  730. return data[:n], nil
  731. }
  732. func (m *Info) MarshalTo(data []byte) (n int, err error) {
  733. var i int
  734. _ = i
  735. var l int
  736. _ = l
  737. data[i] = 0x8
  738. i++
  739. i = encodeVarintRaft(data, i, uint64(m.Id))
  740. if m.XXX_unrecognized != nil {
  741. i += copy(data[i:], m.XXX_unrecognized)
  742. }
  743. return i, nil
  744. }
  745. func (m *Entry) Marshal() (data []byte, err error) {
  746. size := m.Size()
  747. data = make([]byte, size)
  748. n, err := m.MarshalTo(data)
  749. if err != nil {
  750. return nil, err
  751. }
  752. return data[:n], nil
  753. }
  754. func (m *Entry) MarshalTo(data []byte) (n int, err error) {
  755. var i int
  756. _ = i
  757. var l int
  758. _ = l
  759. data[i] = 0x10
  760. i++
  761. i = encodeVarintRaft(data, i, uint64(m.Term))
  762. data[i] = 0x18
  763. i++
  764. i = encodeVarintRaft(data, i, uint64(m.Index))
  765. data[i] = 0x22
  766. i++
  767. i = encodeVarintRaft(data, i, uint64(len(m.Data)))
  768. i += copy(data[i:], m.Data)
  769. if m.XXX_unrecognized != nil {
  770. i += copy(data[i:], m.XXX_unrecognized)
  771. }
  772. return i, nil
  773. }
  774. func (m *Snapshot) Marshal() (data []byte, err error) {
  775. size := m.Size()
  776. data = make([]byte, size)
  777. n, err := m.MarshalTo(data)
  778. if err != nil {
  779. return nil, err
  780. }
  781. return data[:n], nil
  782. }
  783. func (m *Snapshot) MarshalTo(data []byte) (n int, err error) {
  784. var i int
  785. _ = i
  786. var l int
  787. _ = l
  788. data[i] = 0xa
  789. i++
  790. i = encodeVarintRaft(data, i, uint64(len(m.Data)))
  791. i += copy(data[i:], m.Data)
  792. if len(m.Nodes) > 0 {
  793. for _, num := range m.Nodes {
  794. data[i] = 0x10
  795. i++
  796. i = encodeVarintRaft(data, i, uint64(num))
  797. }
  798. }
  799. data[i] = 0x18
  800. i++
  801. i = encodeVarintRaft(data, i, uint64(m.Index))
  802. data[i] = 0x20
  803. i++
  804. i = encodeVarintRaft(data, i, uint64(m.Term))
  805. if m.XXX_unrecognized != nil {
  806. i += copy(data[i:], m.XXX_unrecognized)
  807. }
  808. return i, nil
  809. }
  810. func (m *Message) Marshal() (data []byte, err error) {
  811. size := m.Size()
  812. data = make([]byte, size)
  813. n, err := m.MarshalTo(data)
  814. if err != nil {
  815. return nil, err
  816. }
  817. return data[:n], nil
  818. }
  819. func (m *Message) MarshalTo(data []byte) (n int, err error) {
  820. var i int
  821. _ = i
  822. var l int
  823. _ = l
  824. data[i] = 0x8
  825. i++
  826. i = encodeVarintRaft(data, i, uint64(m.Type))
  827. data[i] = 0x10
  828. i++
  829. i = encodeVarintRaft(data, i, uint64(m.To))
  830. data[i] = 0x18
  831. i++
  832. i = encodeVarintRaft(data, i, uint64(m.From))
  833. data[i] = 0x20
  834. i++
  835. i = encodeVarintRaft(data, i, uint64(m.Term))
  836. data[i] = 0x28
  837. i++
  838. i = encodeVarintRaft(data, i, uint64(m.LogTerm))
  839. data[i] = 0x30
  840. i++
  841. i = encodeVarintRaft(data, i, uint64(m.Index))
  842. if len(m.Entries) > 0 {
  843. for _, msg := range m.Entries {
  844. data[i] = 0x3a
  845. i++
  846. i = encodeVarintRaft(data, i, uint64(msg.Size()))
  847. n, err := msg.MarshalTo(data[i:])
  848. if err != nil {
  849. return 0, err
  850. }
  851. i += n
  852. }
  853. }
  854. data[i] = 0x40
  855. i++
  856. i = encodeVarintRaft(data, i, uint64(m.Commit))
  857. data[i] = 0x4a
  858. i++
  859. i = encodeVarintRaft(data, i, uint64(m.Snapshot.Size()))
  860. n1, err := m.Snapshot.MarshalTo(data[i:])
  861. if err != nil {
  862. return 0, err
  863. }
  864. i += n1
  865. if m.XXX_unrecognized != nil {
  866. i += copy(data[i:], m.XXX_unrecognized)
  867. }
  868. return i, nil
  869. }
  870. func (m *State) Marshal() (data []byte, err error) {
  871. size := m.Size()
  872. data = make([]byte, size)
  873. n, err := m.MarshalTo(data)
  874. if err != nil {
  875. return nil, err
  876. }
  877. return data[:n], nil
  878. }
  879. func (m *State) MarshalTo(data []byte) (n int, err error) {
  880. var i int
  881. _ = i
  882. var l int
  883. _ = l
  884. data[i] = 0x8
  885. i++
  886. i = encodeVarintRaft(data, i, uint64(m.Term))
  887. data[i] = 0x10
  888. i++
  889. i = encodeVarintRaft(data, i, uint64(m.Vote))
  890. data[i] = 0x18
  891. i++
  892. i = encodeVarintRaft(data, i, uint64(m.Commit))
  893. data[i] = 0x20
  894. i++
  895. i = encodeVarintRaft(data, i, uint64(m.LastIndex))
  896. if m.XXX_unrecognized != nil {
  897. i += copy(data[i:], m.XXX_unrecognized)
  898. }
  899. return i, nil
  900. }
  901. func encodeFixed64Raft(data []byte, offset int, v uint64) int {
  902. data[offset] = uint8(v)
  903. data[offset+1] = uint8(v >> 8)
  904. data[offset+2] = uint8(v >> 16)
  905. data[offset+3] = uint8(v >> 24)
  906. data[offset+4] = uint8(v >> 32)
  907. data[offset+5] = uint8(v >> 40)
  908. data[offset+6] = uint8(v >> 48)
  909. data[offset+7] = uint8(v >> 56)
  910. return offset + 8
  911. }
  912. func encodeFixed32Raft(data []byte, offset int, v uint32) int {
  913. data[offset] = uint8(v)
  914. data[offset+1] = uint8(v >> 8)
  915. data[offset+2] = uint8(v >> 16)
  916. data[offset+3] = uint8(v >> 24)
  917. return offset + 4
  918. }
  919. func encodeVarintRaft(data []byte, offset int, v uint64) int {
  920. for v >= 1<<7 {
  921. data[offset] = uint8(v&0x7f | 0x80)
  922. v >>= 7
  923. offset++
  924. }
  925. data[offset] = uint8(v)
  926. return offset + 1
  927. }