etcdserver.pb.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661
  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. It has these top-level messages:
  9. Request
  10. Info
  11. */
  12. package etcdserverpb
  13. import proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  14. import json "encoding/json"
  15. import math "math"
  16. // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
  17. import io "io"
  18. import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
  19. // Reference proto, json, and math imports to suppress error if they are not otherwise used.
  20. var _ = proto.Marshal
  21. var _ = &json.SyntaxError{}
  22. var _ = math.Inf
  23. type Request struct {
  24. ID int64 `protobuf:"varint,1,req" json:"ID"`
  25. Method string `protobuf:"bytes,2,req" json:"Method"`
  26. Path string `protobuf:"bytes,3,req" json:"Path"`
  27. Val string `protobuf:"bytes,4,req" json:"Val"`
  28. Dir bool `protobuf:"varint,5,req" json:"Dir"`
  29. PrevValue string `protobuf:"bytes,6,req" json:"PrevValue"`
  30. PrevIndex uint64 `protobuf:"varint,7,req" json:"PrevIndex"`
  31. PrevExist *bool `protobuf:"varint,8,req" json:"PrevExist,omitempty"`
  32. Expiration int64 `protobuf:"varint,9,req" json:"Expiration"`
  33. Wait bool `protobuf:"varint,10,req" json:"Wait"`
  34. Since uint64 `protobuf:"varint,11,req" json:"Since"`
  35. Recursive bool `protobuf:"varint,12,req" json:"Recursive"`
  36. Sorted bool `protobuf:"varint,13,req" json:"Sorted"`
  37. Quorum bool `protobuf:"varint,14,req" json:"Quorum"`
  38. Time int64 `protobuf:"varint,15,req" json:"Time"`
  39. Stream bool `protobuf:"varint,16,req" 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 Info struct {
  46. ID uint64 `protobuf:"varint,1,req" json:"ID"`
  47. XXX_unrecognized []byte `json:"-"`
  48. }
  49. func (m *Info) Reset() { *m = Info{} }
  50. func (m *Info) String() string { return proto.CompactTextString(m) }
  51. func (*Info) ProtoMessage() {}
  52. func init() {
  53. }
  54. func (m *Request) Unmarshal(data []byte) error {
  55. l := len(data)
  56. index := 0
  57. for index < l {
  58. var wire uint64
  59. for shift := uint(0); ; shift += 7 {
  60. if index >= l {
  61. return io.ErrUnexpectedEOF
  62. }
  63. b := data[index]
  64. index++
  65. wire |= (uint64(b) & 0x7F) << shift
  66. if b < 0x80 {
  67. break
  68. }
  69. }
  70. fieldNum := int32(wire >> 3)
  71. wireType := int(wire & 0x7)
  72. switch fieldNum {
  73. case 1:
  74. if wireType != 0 {
  75. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  76. }
  77. for shift := uint(0); ; shift += 7 {
  78. if index >= l {
  79. return io.ErrUnexpectedEOF
  80. }
  81. b := data[index]
  82. index++
  83. m.ID |= (int64(b) & 0x7F) << shift
  84. if b < 0x80 {
  85. break
  86. }
  87. }
  88. case 2:
  89. if wireType != 2 {
  90. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  91. }
  92. var stringLen uint64
  93. for shift := uint(0); ; shift += 7 {
  94. if index >= l {
  95. return io.ErrUnexpectedEOF
  96. }
  97. b := data[index]
  98. index++
  99. stringLen |= (uint64(b) & 0x7F) << shift
  100. if b < 0x80 {
  101. break
  102. }
  103. }
  104. postIndex := index + int(stringLen)
  105. if postIndex > l {
  106. return io.ErrUnexpectedEOF
  107. }
  108. m.Method = string(data[index:postIndex])
  109. index = postIndex
  110. case 3:
  111. if wireType != 2 {
  112. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  113. }
  114. var stringLen uint64
  115. for shift := uint(0); ; shift += 7 {
  116. if index >= l {
  117. return io.ErrUnexpectedEOF
  118. }
  119. b := data[index]
  120. index++
  121. stringLen |= (uint64(b) & 0x7F) << shift
  122. if b < 0x80 {
  123. break
  124. }
  125. }
  126. postIndex := index + int(stringLen)
  127. if postIndex > l {
  128. return io.ErrUnexpectedEOF
  129. }
  130. m.Path = string(data[index:postIndex])
  131. index = postIndex
  132. case 4:
  133. if wireType != 2 {
  134. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  135. }
  136. var stringLen uint64
  137. for shift := uint(0); ; shift += 7 {
  138. if index >= l {
  139. return io.ErrUnexpectedEOF
  140. }
  141. b := data[index]
  142. index++
  143. stringLen |= (uint64(b) & 0x7F) << shift
  144. if b < 0x80 {
  145. break
  146. }
  147. }
  148. postIndex := index + int(stringLen)
  149. if postIndex > l {
  150. return io.ErrUnexpectedEOF
  151. }
  152. m.Val = string(data[index:postIndex])
  153. index = postIndex
  154. case 5:
  155. if wireType != 0 {
  156. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  157. }
  158. var v int
  159. for shift := uint(0); ; shift += 7 {
  160. if index >= l {
  161. return io.ErrUnexpectedEOF
  162. }
  163. b := data[index]
  164. index++
  165. v |= (int(b) & 0x7F) << shift
  166. if b < 0x80 {
  167. break
  168. }
  169. }
  170. m.Dir = bool(v != 0)
  171. case 6:
  172. if wireType != 2 {
  173. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  174. }
  175. var stringLen uint64
  176. for shift := uint(0); ; shift += 7 {
  177. if index >= l {
  178. return io.ErrUnexpectedEOF
  179. }
  180. b := data[index]
  181. index++
  182. stringLen |= (uint64(b) & 0x7F) << shift
  183. if b < 0x80 {
  184. break
  185. }
  186. }
  187. postIndex := index + int(stringLen)
  188. if postIndex > l {
  189. return io.ErrUnexpectedEOF
  190. }
  191. m.PrevValue = string(data[index:postIndex])
  192. index = postIndex
  193. case 7:
  194. if wireType != 0 {
  195. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  196. }
  197. for shift := uint(0); ; shift += 7 {
  198. if index >= l {
  199. return io.ErrUnexpectedEOF
  200. }
  201. b := data[index]
  202. index++
  203. m.PrevIndex |= (uint64(b) & 0x7F) << shift
  204. if b < 0x80 {
  205. break
  206. }
  207. }
  208. case 8:
  209. if wireType != 0 {
  210. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  211. }
  212. var v int
  213. for shift := uint(0); ; shift += 7 {
  214. if index >= l {
  215. return io.ErrUnexpectedEOF
  216. }
  217. b := data[index]
  218. index++
  219. v |= (int(b) & 0x7F) << shift
  220. if b < 0x80 {
  221. break
  222. }
  223. }
  224. b := bool(v != 0)
  225. m.PrevExist = &b
  226. case 9:
  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.Expiration |= (int64(b) & 0x7F) << shift
  237. if b < 0x80 {
  238. break
  239. }
  240. }
  241. case 10:
  242. if wireType != 0 {
  243. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  244. }
  245. var v int
  246. for shift := uint(0); ; shift += 7 {
  247. if index >= l {
  248. return io.ErrUnexpectedEOF
  249. }
  250. b := data[index]
  251. index++
  252. v |= (int(b) & 0x7F) << shift
  253. if b < 0x80 {
  254. break
  255. }
  256. }
  257. m.Wait = bool(v != 0)
  258. case 11:
  259. if wireType != 0 {
  260. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  261. }
  262. for shift := uint(0); ; shift += 7 {
  263. if index >= l {
  264. return io.ErrUnexpectedEOF
  265. }
  266. b := data[index]
  267. index++
  268. m.Since |= (uint64(b) & 0x7F) << shift
  269. if b < 0x80 {
  270. break
  271. }
  272. }
  273. case 12:
  274. if wireType != 0 {
  275. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  276. }
  277. var v int
  278. for shift := uint(0); ; shift += 7 {
  279. if index >= l {
  280. return io.ErrUnexpectedEOF
  281. }
  282. b := data[index]
  283. index++
  284. v |= (int(b) & 0x7F) << shift
  285. if b < 0x80 {
  286. break
  287. }
  288. }
  289. m.Recursive = bool(v != 0)
  290. case 13:
  291. if wireType != 0 {
  292. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  293. }
  294. var v int
  295. for shift := uint(0); ; shift += 7 {
  296. if index >= l {
  297. return io.ErrUnexpectedEOF
  298. }
  299. b := data[index]
  300. index++
  301. v |= (int(b) & 0x7F) << shift
  302. if b < 0x80 {
  303. break
  304. }
  305. }
  306. m.Sorted = bool(v != 0)
  307. case 14:
  308. if wireType != 0 {
  309. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  310. }
  311. var v int
  312. for shift := uint(0); ; shift += 7 {
  313. if index >= l {
  314. return io.ErrUnexpectedEOF
  315. }
  316. b := data[index]
  317. index++
  318. v |= (int(b) & 0x7F) << shift
  319. if b < 0x80 {
  320. break
  321. }
  322. }
  323. m.Quorum = bool(v != 0)
  324. case 15:
  325. if wireType != 0 {
  326. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  327. }
  328. for shift := uint(0); ; shift += 7 {
  329. if index >= l {
  330. return io.ErrUnexpectedEOF
  331. }
  332. b := data[index]
  333. index++
  334. m.Time |= (int64(b) & 0x7F) << shift
  335. if b < 0x80 {
  336. break
  337. }
  338. }
  339. case 16:
  340. if wireType != 0 {
  341. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  342. }
  343. var v int
  344. for shift := uint(0); ; shift += 7 {
  345. if index >= l {
  346. return io.ErrUnexpectedEOF
  347. }
  348. b := data[index]
  349. index++
  350. v |= (int(b) & 0x7F) << shift
  351. if b < 0x80 {
  352. break
  353. }
  354. }
  355. m.Stream = bool(v != 0)
  356. default:
  357. var sizeOfWire int
  358. for {
  359. sizeOfWire++
  360. wire >>= 7
  361. if wire == 0 {
  362. break
  363. }
  364. }
  365. index -= sizeOfWire
  366. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  367. if err != nil {
  368. return err
  369. }
  370. if (index + skippy) > l {
  371. return io.ErrUnexpectedEOF
  372. }
  373. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  374. index += skippy
  375. }
  376. }
  377. return nil
  378. }
  379. func (m *Info) Unmarshal(data []byte) error {
  380. l := len(data)
  381. index := 0
  382. for index < l {
  383. var wire uint64
  384. for shift := uint(0); ; shift += 7 {
  385. if index >= l {
  386. return io.ErrUnexpectedEOF
  387. }
  388. b := data[index]
  389. index++
  390. wire |= (uint64(b) & 0x7F) << shift
  391. if b < 0x80 {
  392. break
  393. }
  394. }
  395. fieldNum := int32(wire >> 3)
  396. wireType := int(wire & 0x7)
  397. switch fieldNum {
  398. case 1:
  399. if wireType != 0 {
  400. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  401. }
  402. for shift := uint(0); ; shift += 7 {
  403. if index >= l {
  404. return io.ErrUnexpectedEOF
  405. }
  406. b := data[index]
  407. index++
  408. m.ID |= (uint64(b) & 0x7F) << shift
  409. if b < 0x80 {
  410. break
  411. }
  412. }
  413. default:
  414. var sizeOfWire int
  415. for {
  416. sizeOfWire++
  417. wire >>= 7
  418. if wire == 0 {
  419. break
  420. }
  421. }
  422. index -= sizeOfWire
  423. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  424. if err != nil {
  425. return err
  426. }
  427. if (index + skippy) > l {
  428. return io.ErrUnexpectedEOF
  429. }
  430. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  431. index += skippy
  432. }
  433. }
  434. return nil
  435. }
  436. func (m *Request) Size() (n int) {
  437. var l int
  438. _ = l
  439. n += 1 + sovEtcdserver(uint64(m.ID))
  440. l = len(m.Method)
  441. n += 1 + l + sovEtcdserver(uint64(l))
  442. l = len(m.Path)
  443. n += 1 + l + sovEtcdserver(uint64(l))
  444. l = len(m.Val)
  445. n += 1 + l + sovEtcdserver(uint64(l))
  446. n += 2
  447. l = len(m.PrevValue)
  448. n += 1 + l + sovEtcdserver(uint64(l))
  449. n += 1 + sovEtcdserver(uint64(m.PrevIndex))
  450. if m.PrevExist != nil {
  451. n += 2
  452. }
  453. n += 1 + sovEtcdserver(uint64(m.Expiration))
  454. n += 2
  455. n += 1 + sovEtcdserver(uint64(m.Since))
  456. n += 2
  457. n += 2
  458. n += 2
  459. n += 1 + sovEtcdserver(uint64(m.Time))
  460. n += 3
  461. if m.XXX_unrecognized != nil {
  462. n += len(m.XXX_unrecognized)
  463. }
  464. return n
  465. }
  466. func (m *Info) Size() (n int) {
  467. var l int
  468. _ = l
  469. n += 1 + sovEtcdserver(uint64(m.ID))
  470. if m.XXX_unrecognized != nil {
  471. n += len(m.XXX_unrecognized)
  472. }
  473. return n
  474. }
  475. func sovEtcdserver(x uint64) (n int) {
  476. for {
  477. n++
  478. x >>= 7
  479. if x == 0 {
  480. break
  481. }
  482. }
  483. return n
  484. }
  485. func sozEtcdserver(x uint64) (n int) {
  486. return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  487. }
  488. func (m *Request) Marshal() (data []byte, err error) {
  489. size := m.Size()
  490. data = make([]byte, size)
  491. n, err := m.MarshalTo(data)
  492. if err != nil {
  493. return nil, err
  494. }
  495. return data[:n], nil
  496. }
  497. func (m *Request) MarshalTo(data []byte) (n int, err error) {
  498. var i int
  499. _ = i
  500. var l int
  501. _ = l
  502. data[i] = 0x8
  503. i++
  504. i = encodeVarintEtcdserver(data, i, uint64(m.ID))
  505. data[i] = 0x12
  506. i++
  507. i = encodeVarintEtcdserver(data, i, uint64(len(m.Method)))
  508. i += copy(data[i:], m.Method)
  509. data[i] = 0x1a
  510. i++
  511. i = encodeVarintEtcdserver(data, i, uint64(len(m.Path)))
  512. i += copy(data[i:], m.Path)
  513. data[i] = 0x22
  514. i++
  515. i = encodeVarintEtcdserver(data, i, uint64(len(m.Val)))
  516. i += copy(data[i:], m.Val)
  517. data[i] = 0x28
  518. i++
  519. if m.Dir {
  520. data[i] = 1
  521. } else {
  522. data[i] = 0
  523. }
  524. i++
  525. data[i] = 0x32
  526. i++
  527. i = encodeVarintEtcdserver(data, i, uint64(len(m.PrevValue)))
  528. i += copy(data[i:], m.PrevValue)
  529. data[i] = 0x38
  530. i++
  531. i = encodeVarintEtcdserver(data, i, uint64(m.PrevIndex))
  532. if m.PrevExist != nil {
  533. data[i] = 0x40
  534. i++
  535. if *m.PrevExist {
  536. data[i] = 1
  537. } else {
  538. data[i] = 0
  539. }
  540. i++
  541. }
  542. data[i] = 0x48
  543. i++
  544. i = encodeVarintEtcdserver(data, i, uint64(m.Expiration))
  545. data[i] = 0x50
  546. i++
  547. if m.Wait {
  548. data[i] = 1
  549. } else {
  550. data[i] = 0
  551. }
  552. i++
  553. data[i] = 0x58
  554. i++
  555. i = encodeVarintEtcdserver(data, i, uint64(m.Since))
  556. data[i] = 0x60
  557. i++
  558. if m.Recursive {
  559. data[i] = 1
  560. } else {
  561. data[i] = 0
  562. }
  563. i++
  564. data[i] = 0x68
  565. i++
  566. if m.Sorted {
  567. data[i] = 1
  568. } else {
  569. data[i] = 0
  570. }
  571. i++
  572. data[i] = 0x70
  573. i++
  574. if m.Quorum {
  575. data[i] = 1
  576. } else {
  577. data[i] = 0
  578. }
  579. i++
  580. data[i] = 0x78
  581. i++
  582. i = encodeVarintEtcdserver(data, i, uint64(m.Time))
  583. data[i] = 0x80
  584. i++
  585. data[i] = 0x1
  586. i++
  587. if m.Stream {
  588. data[i] = 1
  589. } else {
  590. data[i] = 0
  591. }
  592. i++
  593. if m.XXX_unrecognized != nil {
  594. i += copy(data[i:], m.XXX_unrecognized)
  595. }
  596. return i, nil
  597. }
  598. func (m *Info) Marshal() (data []byte, err error) {
  599. size := m.Size()
  600. data = make([]byte, size)
  601. n, err := m.MarshalTo(data)
  602. if err != nil {
  603. return nil, err
  604. }
  605. return data[:n], nil
  606. }
  607. func (m *Info) MarshalTo(data []byte) (n int, err error) {
  608. var i int
  609. _ = i
  610. var l int
  611. _ = l
  612. data[i] = 0x8
  613. i++
  614. i = encodeVarintEtcdserver(data, i, uint64(m.ID))
  615. if m.XXX_unrecognized != nil {
  616. i += copy(data[i:], m.XXX_unrecognized)
  617. }
  618. return i, nil
  619. }
  620. func encodeFixed64Etcdserver(data []byte, offset int, v uint64) int {
  621. data[offset] = uint8(v)
  622. data[offset+1] = uint8(v >> 8)
  623. data[offset+2] = uint8(v >> 16)
  624. data[offset+3] = uint8(v >> 24)
  625. data[offset+4] = uint8(v >> 32)
  626. data[offset+5] = uint8(v >> 40)
  627. data[offset+6] = uint8(v >> 48)
  628. data[offset+7] = uint8(v >> 56)
  629. return offset + 8
  630. }
  631. func encodeFixed32Etcdserver(data []byte, offset int, v uint32) int {
  632. data[offset] = uint8(v)
  633. data[offset+1] = uint8(v >> 8)
  634. data[offset+2] = uint8(v >> 16)
  635. data[offset+3] = uint8(v >> 24)
  636. return offset + 4
  637. }
  638. func encodeVarintEtcdserver(data []byte, offset int, v uint64) int {
  639. for v >= 1<<7 {
  640. data[offset] = uint8(v&0x7f | 0x80)
  641. v >>= 7
  642. offset++
  643. }
  644. data[offset] = uint8(v)
  645. return offset + 1
  646. }