etcdserver.pb.go 11 KB

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