request.pb.go 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380
  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. Key string `protobuf:"bytes,3,req,name=key" json:"key"`
  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 int64 `protobuf:"varint,7,req,name=prevIndex" json:"prevIndex"`
  30. PrevExists bool `protobuf:"varint,8,req,name=prevExists" json:"prevExists"`
  31. Expiration int64 `protobuf:"varint,9,req,name=expiration" json:"expiration"`
  32. XXX_unrecognized []byte `json:"-"`
  33. }
  34. func (m *Request) Reset() { *m = Request{} }
  35. func (m *Request) String() string { return proto.CompactTextString(m) }
  36. func (*Request) ProtoMessage() {}
  37. func init() {
  38. }
  39. func (m *Request) Unmarshal(data []byte) error {
  40. l := len(data)
  41. index := 0
  42. for index < l {
  43. var wire uint64
  44. for shift := uint(0); ; shift += 7 {
  45. if index >= l {
  46. return io.ErrUnexpectedEOF
  47. }
  48. b := data[index]
  49. index++
  50. wire |= (uint64(b) & 0x7F) << shift
  51. if b < 0x80 {
  52. break
  53. }
  54. }
  55. fieldNum := int32(wire >> 3)
  56. wireType := int(wire & 0x7)
  57. switch fieldNum {
  58. case 1:
  59. if wireType != 0 {
  60. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  61. }
  62. for shift := uint(0); ; shift += 7 {
  63. if index >= l {
  64. return io.ErrUnexpectedEOF
  65. }
  66. b := data[index]
  67. index++
  68. m.Id |= (int64(b) & 0x7F) << shift
  69. if b < 0x80 {
  70. break
  71. }
  72. }
  73. case 2:
  74. if wireType != 2 {
  75. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  76. }
  77. var stringLen uint64
  78. for shift := uint(0); ; shift += 7 {
  79. if index >= l {
  80. return io.ErrUnexpectedEOF
  81. }
  82. b := data[index]
  83. index++
  84. stringLen |= (uint64(b) & 0x7F) << shift
  85. if b < 0x80 {
  86. break
  87. }
  88. }
  89. postIndex := index + int(stringLen)
  90. if postIndex > l {
  91. return io.ErrUnexpectedEOF
  92. }
  93. m.Method = string(data[index:postIndex])
  94. index = postIndex
  95. case 3:
  96. if wireType != 2 {
  97. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  98. }
  99. var stringLen uint64
  100. for shift := uint(0); ; shift += 7 {
  101. if index >= l {
  102. return io.ErrUnexpectedEOF
  103. }
  104. b := data[index]
  105. index++
  106. stringLen |= (uint64(b) & 0x7F) << shift
  107. if b < 0x80 {
  108. break
  109. }
  110. }
  111. postIndex := index + int(stringLen)
  112. if postIndex > l {
  113. return io.ErrUnexpectedEOF
  114. }
  115. m.Key = string(data[index:postIndex])
  116. index = postIndex
  117. case 4:
  118. if wireType != 2 {
  119. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  120. }
  121. var stringLen uint64
  122. for shift := uint(0); ; shift += 7 {
  123. if index >= l {
  124. return io.ErrUnexpectedEOF
  125. }
  126. b := data[index]
  127. index++
  128. stringLen |= (uint64(b) & 0x7F) << shift
  129. if b < 0x80 {
  130. break
  131. }
  132. }
  133. postIndex := index + int(stringLen)
  134. if postIndex > l {
  135. return io.ErrUnexpectedEOF
  136. }
  137. m.Val = string(data[index:postIndex])
  138. index = postIndex
  139. case 5:
  140. if wireType != 0 {
  141. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  142. }
  143. var v int
  144. for shift := uint(0); ; shift += 7 {
  145. if index >= l {
  146. return io.ErrUnexpectedEOF
  147. }
  148. b := data[index]
  149. index++
  150. v |= (int(b) & 0x7F) << shift
  151. if b < 0x80 {
  152. break
  153. }
  154. }
  155. m.Dir = bool(v != 0)
  156. case 6:
  157. if wireType != 2 {
  158. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  159. }
  160. var stringLen uint64
  161. for shift := uint(0); ; shift += 7 {
  162. if index >= l {
  163. return io.ErrUnexpectedEOF
  164. }
  165. b := data[index]
  166. index++
  167. stringLen |= (uint64(b) & 0x7F) << shift
  168. if b < 0x80 {
  169. break
  170. }
  171. }
  172. postIndex := index + int(stringLen)
  173. if postIndex > l {
  174. return io.ErrUnexpectedEOF
  175. }
  176. m.PrevValue = string(data[index:postIndex])
  177. index = postIndex
  178. case 7:
  179. if wireType != 0 {
  180. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  181. }
  182. for shift := uint(0); ; shift += 7 {
  183. if index >= l {
  184. return io.ErrUnexpectedEOF
  185. }
  186. b := data[index]
  187. index++
  188. m.PrevIndex |= (int64(b) & 0x7F) << shift
  189. if b < 0x80 {
  190. break
  191. }
  192. }
  193. case 8:
  194. if wireType != 0 {
  195. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  196. }
  197. var v int
  198. for shift := uint(0); ; shift += 7 {
  199. if index >= l {
  200. return io.ErrUnexpectedEOF
  201. }
  202. b := data[index]
  203. index++
  204. v |= (int(b) & 0x7F) << shift
  205. if b < 0x80 {
  206. break
  207. }
  208. }
  209. m.PrevExists = bool(v != 0)
  210. case 9:
  211. if wireType != 0 {
  212. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  213. }
  214. for shift := uint(0); ; shift += 7 {
  215. if index >= l {
  216. return io.ErrUnexpectedEOF
  217. }
  218. b := data[index]
  219. index++
  220. m.Expiration |= (int64(b) & 0x7F) << shift
  221. if b < 0x80 {
  222. break
  223. }
  224. }
  225. default:
  226. var sizeOfWire int
  227. for {
  228. sizeOfWire++
  229. wire >>= 7
  230. if wire == 0 {
  231. break
  232. }
  233. }
  234. index -= sizeOfWire
  235. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  236. if err != nil {
  237. return err
  238. }
  239. if (index + skippy) > l {
  240. return io.ErrUnexpectedEOF
  241. }
  242. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  243. index += skippy
  244. }
  245. }
  246. return nil
  247. }
  248. func (m *Request) Size() (n int) {
  249. var l int
  250. _ = l
  251. n += 1 + sovRequest(uint64(m.Id))
  252. l = len(m.Method)
  253. n += 1 + l + sovRequest(uint64(l))
  254. l = len(m.Key)
  255. n += 1 + l + sovRequest(uint64(l))
  256. l = len(m.Val)
  257. n += 1 + l + sovRequest(uint64(l))
  258. n += 2
  259. l = len(m.PrevValue)
  260. n += 1 + l + sovRequest(uint64(l))
  261. n += 1 + sovRequest(uint64(m.PrevIndex))
  262. n += 2
  263. n += 1 + sovRequest(uint64(m.Expiration))
  264. if m.XXX_unrecognized != nil {
  265. n += len(m.XXX_unrecognized)
  266. }
  267. return n
  268. }
  269. func sovRequest(x uint64) (n int) {
  270. for {
  271. n++
  272. x >>= 7
  273. if x == 0 {
  274. break
  275. }
  276. }
  277. return n
  278. }
  279. func sozRequest(x uint64) (n int) {
  280. return sovRequest(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  281. }
  282. func (m *Request) Marshal() (data []byte, err error) {
  283. size := m.Size()
  284. data = make([]byte, size)
  285. n, err := m.MarshalTo(data)
  286. if err != nil {
  287. return nil, err
  288. }
  289. return data[:n], nil
  290. }
  291. func (m *Request) MarshalTo(data []byte) (n int, err error) {
  292. var i int
  293. _ = i
  294. var l int
  295. _ = l
  296. data[i] = 0x8
  297. i++
  298. i = encodeVarintRequest(data, i, uint64(m.Id))
  299. data[i] = 0x12
  300. i++
  301. i = encodeVarintRequest(data, i, uint64(len(m.Method)))
  302. i += copy(data[i:], m.Method)
  303. data[i] = 0x1a
  304. i++
  305. i = encodeVarintRequest(data, i, uint64(len(m.Key)))
  306. i += copy(data[i:], m.Key)
  307. data[i] = 0x22
  308. i++
  309. i = encodeVarintRequest(data, i, uint64(len(m.Val)))
  310. i += copy(data[i:], m.Val)
  311. data[i] = 0x28
  312. i++
  313. if m.Dir {
  314. data[i] = 1
  315. } else {
  316. data[i] = 0
  317. }
  318. i++
  319. data[i] = 0x32
  320. i++
  321. i = encodeVarintRequest(data, i, uint64(len(m.PrevValue)))
  322. i += copy(data[i:], m.PrevValue)
  323. data[i] = 0x38
  324. i++
  325. i = encodeVarintRequest(data, i, uint64(m.PrevIndex))
  326. data[i] = 0x40
  327. i++
  328. if m.PrevExists {
  329. data[i] = 1
  330. } else {
  331. data[i] = 0
  332. }
  333. i++
  334. data[i] = 0x48
  335. i++
  336. i = encodeVarintRequest(data, i, uint64(m.Expiration))
  337. if m.XXX_unrecognized != nil {
  338. i += copy(data[i:], m.XXX_unrecognized)
  339. }
  340. return i, nil
  341. }
  342. func encodeFixed64Request(data []byte, offset int, v uint64) int {
  343. data[offset] = uint8(v)
  344. data[offset+1] = uint8(v >> 8)
  345. data[offset+2] = uint8(v >> 16)
  346. data[offset+3] = uint8(v >> 24)
  347. data[offset+4] = uint8(v >> 32)
  348. data[offset+5] = uint8(v >> 40)
  349. data[offset+6] = uint8(v >> 48)
  350. data[offset+7] = uint8(v >> 56)
  351. return offset + 8
  352. }
  353. func encodeFixed32Request(data []byte, offset int, v uint32) int {
  354. data[offset] = uint8(v)
  355. data[offset+1] = uint8(v >> 8)
  356. data[offset+2] = uint8(v >> 16)
  357. data[offset+3] = uint8(v >> 24)
  358. return offset + 4
  359. }
  360. func encodeVarintRequest(data []byte, offset int, v uint64) int {
  361. for v >= 1<<7 {
  362. data[offset] = uint8(v&0x7f | 0x80)
  363. v >>= 7
  364. offset++
  365. }
  366. data[offset] = uint8(v)
  367. return offset + 1
  368. }