etcdserver.pb.go 12 KB

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