etcdserver.pb.go 12 KB

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