etcdserver.pb.go 19 KB

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