request.pb.go 11 KB

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