etcdserver.pb.go 15 KB

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