etcdserver.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962
  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. raft_internal.proto
  9. rpc.proto
  10. It has these top-level messages:
  11. Request
  12. Metadata
  13. InternalRaftRequest
  14. EmptyResponse
  15. ResponseHeader
  16. RangeRequest
  17. RangeResponse
  18. PutRequest
  19. PutResponse
  20. DeleteRangeRequest
  21. DeleteRangeResponse
  22. RequestUnion
  23. ResponseUnion
  24. Compare
  25. TxnRequest
  26. TxnResponse
  27. CompactionRequest
  28. CompactionResponse
  29. HashRequest
  30. HashResponse
  31. WatchRequest
  32. WatchCreateRequest
  33. WatchCancelRequest
  34. WatchResponse
  35. LeaseCreateRequest
  36. LeaseCreateResponse
  37. LeaseRevokeRequest
  38. LeaseRevokeResponse
  39. LeaseKeepAliveRequest
  40. LeaseKeepAliveResponse
  41. Member
  42. MemberAddRequest
  43. MemberAddResponse
  44. MemberRemoveRequest
  45. MemberRemoveResponse
  46. MemberUpdateRequest
  47. MemberUpdateResponse
  48. MemberListRequest
  49. MemberListResponse
  50. */
  51. package etcdserverpb
  52. import (
  53. "fmt"
  54. proto "github.com/coreos/etcd/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
  55. )
  56. import math "math"
  57. import io "io"
  58. // Reference imports to suppress errors if they are not otherwise used.
  59. var _ = proto.Marshal
  60. var _ = fmt.Errorf
  61. var _ = math.Inf
  62. type Request struct {
  63. ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID"`
  64. Method string `protobuf:"bytes,2,opt,name=Method" json:"Method"`
  65. Path string `protobuf:"bytes,3,opt,name=Path" json:"Path"`
  66. Val string `protobuf:"bytes,4,opt,name=Val" json:"Val"`
  67. Dir bool `protobuf:"varint,5,opt,name=Dir" json:"Dir"`
  68. PrevValue string `protobuf:"bytes,6,opt,name=PrevValue" json:"PrevValue"`
  69. PrevIndex uint64 `protobuf:"varint,7,opt,name=PrevIndex" json:"PrevIndex"`
  70. PrevExist *bool `protobuf:"varint,8,opt,name=PrevExist" json:"PrevExist,omitempty"`
  71. Expiration int64 `protobuf:"varint,9,opt,name=Expiration" json:"Expiration"`
  72. Wait bool `protobuf:"varint,10,opt,name=Wait" json:"Wait"`
  73. Since uint64 `protobuf:"varint,11,opt,name=Since" json:"Since"`
  74. Recursive bool `protobuf:"varint,12,opt,name=Recursive" json:"Recursive"`
  75. Sorted bool `protobuf:"varint,13,opt,name=Sorted" json:"Sorted"`
  76. Quorum bool `protobuf:"varint,14,opt,name=Quorum" json:"Quorum"`
  77. Time int64 `protobuf:"varint,15,opt,name=Time" json:"Time"`
  78. Stream bool `protobuf:"varint,16,opt,name=Stream" json:"Stream"`
  79. Refresh *bool `protobuf:"varint,17,opt,name=Refresh" json:"Refresh,omitempty"`
  80. XXX_unrecognized []byte `json:"-"`
  81. }
  82. func (m *Request) Reset() { *m = Request{} }
  83. func (m *Request) String() string { return proto.CompactTextString(m) }
  84. func (*Request) ProtoMessage() {}
  85. type Metadata struct {
  86. NodeID uint64 `protobuf:"varint,1,opt,name=NodeID" json:"NodeID"`
  87. ClusterID uint64 `protobuf:"varint,2,opt,name=ClusterID" json:"ClusterID"`
  88. XXX_unrecognized []byte `json:"-"`
  89. }
  90. func (m *Metadata) Reset() { *m = Metadata{} }
  91. func (m *Metadata) String() string { return proto.CompactTextString(m) }
  92. func (*Metadata) ProtoMessage() {}
  93. func init() {
  94. proto.RegisterType((*Request)(nil), "etcdserverpb.Request")
  95. proto.RegisterType((*Metadata)(nil), "etcdserverpb.Metadata")
  96. }
  97. func (m *Request) Marshal() (data []byte, err error) {
  98. size := m.Size()
  99. data = make([]byte, size)
  100. n, err := m.MarshalTo(data)
  101. if err != nil {
  102. return nil, err
  103. }
  104. return data[:n], nil
  105. }
  106. func (m *Request) MarshalTo(data []byte) (int, error) {
  107. var i int
  108. _ = i
  109. var l int
  110. _ = l
  111. data[i] = 0x8
  112. i++
  113. i = encodeVarintEtcdserver(data, i, uint64(m.ID))
  114. data[i] = 0x12
  115. i++
  116. i = encodeVarintEtcdserver(data, i, uint64(len(m.Method)))
  117. i += copy(data[i:], m.Method)
  118. data[i] = 0x1a
  119. i++
  120. i = encodeVarintEtcdserver(data, i, uint64(len(m.Path)))
  121. i += copy(data[i:], m.Path)
  122. data[i] = 0x22
  123. i++
  124. i = encodeVarintEtcdserver(data, i, uint64(len(m.Val)))
  125. i += copy(data[i:], m.Val)
  126. data[i] = 0x28
  127. i++
  128. if m.Dir {
  129. data[i] = 1
  130. } else {
  131. data[i] = 0
  132. }
  133. i++
  134. data[i] = 0x32
  135. i++
  136. i = encodeVarintEtcdserver(data, i, uint64(len(m.PrevValue)))
  137. i += copy(data[i:], m.PrevValue)
  138. data[i] = 0x38
  139. i++
  140. i = encodeVarintEtcdserver(data, i, uint64(m.PrevIndex))
  141. if m.PrevExist != nil {
  142. data[i] = 0x40
  143. i++
  144. if *m.PrevExist {
  145. data[i] = 1
  146. } else {
  147. data[i] = 0
  148. }
  149. i++
  150. }
  151. data[i] = 0x48
  152. i++
  153. i = encodeVarintEtcdserver(data, i, uint64(m.Expiration))
  154. data[i] = 0x50
  155. i++
  156. if m.Wait {
  157. data[i] = 1
  158. } else {
  159. data[i] = 0
  160. }
  161. i++
  162. data[i] = 0x58
  163. i++
  164. i = encodeVarintEtcdserver(data, i, uint64(m.Since))
  165. data[i] = 0x60
  166. i++
  167. if m.Recursive {
  168. data[i] = 1
  169. } else {
  170. data[i] = 0
  171. }
  172. i++
  173. data[i] = 0x68
  174. i++
  175. if m.Sorted {
  176. data[i] = 1
  177. } else {
  178. data[i] = 0
  179. }
  180. i++
  181. data[i] = 0x70
  182. i++
  183. if m.Quorum {
  184. data[i] = 1
  185. } else {
  186. data[i] = 0
  187. }
  188. i++
  189. data[i] = 0x78
  190. i++
  191. i = encodeVarintEtcdserver(data, i, uint64(m.Time))
  192. data[i] = 0x80
  193. i++
  194. data[i] = 0x1
  195. i++
  196. if m.Stream {
  197. data[i] = 1
  198. } else {
  199. data[i] = 0
  200. }
  201. i++
  202. if m.Refresh != nil {
  203. data[i] = 0x88
  204. i++
  205. data[i] = 0x1
  206. i++
  207. if *m.Refresh {
  208. data[i] = 1
  209. } else {
  210. data[i] = 0
  211. }
  212. i++
  213. }
  214. if m.XXX_unrecognized != nil {
  215. i += copy(data[i:], m.XXX_unrecognized)
  216. }
  217. return i, nil
  218. }
  219. func (m *Metadata) Marshal() (data []byte, err error) {
  220. size := m.Size()
  221. data = make([]byte, size)
  222. n, err := m.MarshalTo(data)
  223. if err != nil {
  224. return nil, err
  225. }
  226. return data[:n], nil
  227. }
  228. func (m *Metadata) MarshalTo(data []byte) (int, error) {
  229. var i int
  230. _ = i
  231. var l int
  232. _ = l
  233. data[i] = 0x8
  234. i++
  235. i = encodeVarintEtcdserver(data, i, uint64(m.NodeID))
  236. data[i] = 0x10
  237. i++
  238. i = encodeVarintEtcdserver(data, i, uint64(m.ClusterID))
  239. if m.XXX_unrecognized != nil {
  240. i += copy(data[i:], m.XXX_unrecognized)
  241. }
  242. return i, nil
  243. }
  244. func encodeFixed64Etcdserver(data []byte, offset int, v uint64) int {
  245. data[offset] = uint8(v)
  246. data[offset+1] = uint8(v >> 8)
  247. data[offset+2] = uint8(v >> 16)
  248. data[offset+3] = uint8(v >> 24)
  249. data[offset+4] = uint8(v >> 32)
  250. data[offset+5] = uint8(v >> 40)
  251. data[offset+6] = uint8(v >> 48)
  252. data[offset+7] = uint8(v >> 56)
  253. return offset + 8
  254. }
  255. func encodeFixed32Etcdserver(data []byte, offset int, v uint32) int {
  256. data[offset] = uint8(v)
  257. data[offset+1] = uint8(v >> 8)
  258. data[offset+2] = uint8(v >> 16)
  259. data[offset+3] = uint8(v >> 24)
  260. return offset + 4
  261. }
  262. func encodeVarintEtcdserver(data []byte, offset int, v uint64) int {
  263. for v >= 1<<7 {
  264. data[offset] = uint8(v&0x7f | 0x80)
  265. v >>= 7
  266. offset++
  267. }
  268. data[offset] = uint8(v)
  269. return offset + 1
  270. }
  271. func (m *Request) Size() (n int) {
  272. var l int
  273. _ = l
  274. n += 1 + sovEtcdserver(uint64(m.ID))
  275. l = len(m.Method)
  276. n += 1 + l + sovEtcdserver(uint64(l))
  277. l = len(m.Path)
  278. n += 1 + l + sovEtcdserver(uint64(l))
  279. l = len(m.Val)
  280. n += 1 + l + sovEtcdserver(uint64(l))
  281. n += 2
  282. l = len(m.PrevValue)
  283. n += 1 + l + sovEtcdserver(uint64(l))
  284. n += 1 + sovEtcdserver(uint64(m.PrevIndex))
  285. if m.PrevExist != nil {
  286. n += 2
  287. }
  288. n += 1 + sovEtcdserver(uint64(m.Expiration))
  289. n += 2
  290. n += 1 + sovEtcdserver(uint64(m.Since))
  291. n += 2
  292. n += 2
  293. n += 2
  294. n += 1 + sovEtcdserver(uint64(m.Time))
  295. n += 3
  296. if m.Refresh != nil {
  297. n += 3
  298. }
  299. if m.XXX_unrecognized != nil {
  300. n += len(m.XXX_unrecognized)
  301. }
  302. return n
  303. }
  304. func (m *Metadata) Size() (n int) {
  305. var l int
  306. _ = l
  307. n += 1 + sovEtcdserver(uint64(m.NodeID))
  308. n += 1 + sovEtcdserver(uint64(m.ClusterID))
  309. if m.XXX_unrecognized != nil {
  310. n += len(m.XXX_unrecognized)
  311. }
  312. return n
  313. }
  314. func sovEtcdserver(x uint64) (n int) {
  315. for {
  316. n++
  317. x >>= 7
  318. if x == 0 {
  319. break
  320. }
  321. }
  322. return n
  323. }
  324. func sozEtcdserver(x uint64) (n int) {
  325. return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  326. }
  327. func (m *Request) Unmarshal(data []byte) error {
  328. l := len(data)
  329. iNdEx := 0
  330. for iNdEx < l {
  331. preIndex := iNdEx
  332. var wire uint64
  333. for shift := uint(0); ; shift += 7 {
  334. if shift >= 64 {
  335. return ErrIntOverflowEtcdserver
  336. }
  337. if iNdEx >= l {
  338. return io.ErrUnexpectedEOF
  339. }
  340. b := data[iNdEx]
  341. iNdEx++
  342. wire |= (uint64(b) & 0x7F) << shift
  343. if b < 0x80 {
  344. break
  345. }
  346. }
  347. fieldNum := int32(wire >> 3)
  348. wireType := int(wire & 0x7)
  349. if wireType == 4 {
  350. return fmt.Errorf("proto: Request: wiretype end group for non-group")
  351. }
  352. if fieldNum <= 0 {
  353. return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
  354. }
  355. switch fieldNum {
  356. case 1:
  357. if wireType != 0 {
  358. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  359. }
  360. m.ID = 0
  361. for shift := uint(0); ; shift += 7 {
  362. if shift >= 64 {
  363. return ErrIntOverflowEtcdserver
  364. }
  365. if iNdEx >= l {
  366. return io.ErrUnexpectedEOF
  367. }
  368. b := data[iNdEx]
  369. iNdEx++
  370. m.ID |= (uint64(b) & 0x7F) << shift
  371. if b < 0x80 {
  372. break
  373. }
  374. }
  375. case 2:
  376. if wireType != 2 {
  377. return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
  378. }
  379. var stringLen uint64
  380. for shift := uint(0); ; shift += 7 {
  381. if shift >= 64 {
  382. return ErrIntOverflowEtcdserver
  383. }
  384. if iNdEx >= l {
  385. return io.ErrUnexpectedEOF
  386. }
  387. b := data[iNdEx]
  388. iNdEx++
  389. stringLen |= (uint64(b) & 0x7F) << shift
  390. if b < 0x80 {
  391. break
  392. }
  393. }
  394. intStringLen := int(stringLen)
  395. if intStringLen < 0 {
  396. return ErrInvalidLengthEtcdserver
  397. }
  398. postIndex := iNdEx + intStringLen
  399. if postIndex > l {
  400. return io.ErrUnexpectedEOF
  401. }
  402. m.Method = string(data[iNdEx:postIndex])
  403. iNdEx = postIndex
  404. case 3:
  405. if wireType != 2 {
  406. return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
  407. }
  408. var stringLen uint64
  409. for shift := uint(0); ; shift += 7 {
  410. if shift >= 64 {
  411. return ErrIntOverflowEtcdserver
  412. }
  413. if iNdEx >= l {
  414. return io.ErrUnexpectedEOF
  415. }
  416. b := data[iNdEx]
  417. iNdEx++
  418. stringLen |= (uint64(b) & 0x7F) << shift
  419. if b < 0x80 {
  420. break
  421. }
  422. }
  423. intStringLen := int(stringLen)
  424. if intStringLen < 0 {
  425. return ErrInvalidLengthEtcdserver
  426. }
  427. postIndex := iNdEx + intStringLen
  428. if postIndex > l {
  429. return io.ErrUnexpectedEOF
  430. }
  431. m.Path = string(data[iNdEx:postIndex])
  432. iNdEx = postIndex
  433. case 4:
  434. if wireType != 2 {
  435. return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
  436. }
  437. var stringLen uint64
  438. for shift := uint(0); ; shift += 7 {
  439. if shift >= 64 {
  440. return ErrIntOverflowEtcdserver
  441. }
  442. if iNdEx >= l {
  443. return io.ErrUnexpectedEOF
  444. }
  445. b := data[iNdEx]
  446. iNdEx++
  447. stringLen |= (uint64(b) & 0x7F) << shift
  448. if b < 0x80 {
  449. break
  450. }
  451. }
  452. intStringLen := int(stringLen)
  453. if intStringLen < 0 {
  454. return ErrInvalidLengthEtcdserver
  455. }
  456. postIndex := iNdEx + intStringLen
  457. if postIndex > l {
  458. return io.ErrUnexpectedEOF
  459. }
  460. m.Val = string(data[iNdEx:postIndex])
  461. iNdEx = postIndex
  462. case 5:
  463. if wireType != 0 {
  464. return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
  465. }
  466. var v int
  467. for shift := uint(0); ; shift += 7 {
  468. if shift >= 64 {
  469. return ErrIntOverflowEtcdserver
  470. }
  471. if iNdEx >= l {
  472. return io.ErrUnexpectedEOF
  473. }
  474. b := data[iNdEx]
  475. iNdEx++
  476. v |= (int(b) & 0x7F) << shift
  477. if b < 0x80 {
  478. break
  479. }
  480. }
  481. m.Dir = bool(v != 0)
  482. case 6:
  483. if wireType != 2 {
  484. return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
  485. }
  486. var stringLen uint64
  487. for shift := uint(0); ; shift += 7 {
  488. if shift >= 64 {
  489. return ErrIntOverflowEtcdserver
  490. }
  491. if iNdEx >= l {
  492. return io.ErrUnexpectedEOF
  493. }
  494. b := data[iNdEx]
  495. iNdEx++
  496. stringLen |= (uint64(b) & 0x7F) << shift
  497. if b < 0x80 {
  498. break
  499. }
  500. }
  501. intStringLen := int(stringLen)
  502. if intStringLen < 0 {
  503. return ErrInvalidLengthEtcdserver
  504. }
  505. postIndex := iNdEx + intStringLen
  506. if postIndex > l {
  507. return io.ErrUnexpectedEOF
  508. }
  509. m.PrevValue = string(data[iNdEx:postIndex])
  510. iNdEx = postIndex
  511. case 7:
  512. if wireType != 0 {
  513. return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
  514. }
  515. m.PrevIndex = 0
  516. for shift := uint(0); ; shift += 7 {
  517. if shift >= 64 {
  518. return ErrIntOverflowEtcdserver
  519. }
  520. if iNdEx >= l {
  521. return io.ErrUnexpectedEOF
  522. }
  523. b := data[iNdEx]
  524. iNdEx++
  525. m.PrevIndex |= (uint64(b) & 0x7F) << shift
  526. if b < 0x80 {
  527. break
  528. }
  529. }
  530. case 8:
  531. if wireType != 0 {
  532. return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
  533. }
  534. var v int
  535. for shift := uint(0); ; shift += 7 {
  536. if shift >= 64 {
  537. return ErrIntOverflowEtcdserver
  538. }
  539. if iNdEx >= l {
  540. return io.ErrUnexpectedEOF
  541. }
  542. b := data[iNdEx]
  543. iNdEx++
  544. v |= (int(b) & 0x7F) << shift
  545. if b < 0x80 {
  546. break
  547. }
  548. }
  549. b := bool(v != 0)
  550. m.PrevExist = &b
  551. case 9:
  552. if wireType != 0 {
  553. return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
  554. }
  555. m.Expiration = 0
  556. for shift := uint(0); ; shift += 7 {
  557. if shift >= 64 {
  558. return ErrIntOverflowEtcdserver
  559. }
  560. if iNdEx >= l {
  561. return io.ErrUnexpectedEOF
  562. }
  563. b := data[iNdEx]
  564. iNdEx++
  565. m.Expiration |= (int64(b) & 0x7F) << shift
  566. if b < 0x80 {
  567. break
  568. }
  569. }
  570. case 10:
  571. if wireType != 0 {
  572. return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
  573. }
  574. var v int
  575. for shift := uint(0); ; shift += 7 {
  576. if shift >= 64 {
  577. return ErrIntOverflowEtcdserver
  578. }
  579. if iNdEx >= l {
  580. return io.ErrUnexpectedEOF
  581. }
  582. b := data[iNdEx]
  583. iNdEx++
  584. v |= (int(b) & 0x7F) << shift
  585. if b < 0x80 {
  586. break
  587. }
  588. }
  589. m.Wait = bool(v != 0)
  590. case 11:
  591. if wireType != 0 {
  592. return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
  593. }
  594. m.Since = 0
  595. for shift := uint(0); ; shift += 7 {
  596. if shift >= 64 {
  597. return ErrIntOverflowEtcdserver
  598. }
  599. if iNdEx >= l {
  600. return io.ErrUnexpectedEOF
  601. }
  602. b := data[iNdEx]
  603. iNdEx++
  604. m.Since |= (uint64(b) & 0x7F) << shift
  605. if b < 0x80 {
  606. break
  607. }
  608. }
  609. case 12:
  610. if wireType != 0 {
  611. return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
  612. }
  613. var v int
  614. for shift := uint(0); ; shift += 7 {
  615. if shift >= 64 {
  616. return ErrIntOverflowEtcdserver
  617. }
  618. if iNdEx >= l {
  619. return io.ErrUnexpectedEOF
  620. }
  621. b := data[iNdEx]
  622. iNdEx++
  623. v |= (int(b) & 0x7F) << shift
  624. if b < 0x80 {
  625. break
  626. }
  627. }
  628. m.Recursive = bool(v != 0)
  629. case 13:
  630. if wireType != 0 {
  631. return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
  632. }
  633. var v int
  634. for shift := uint(0); ; shift += 7 {
  635. if shift >= 64 {
  636. return ErrIntOverflowEtcdserver
  637. }
  638. if iNdEx >= l {
  639. return io.ErrUnexpectedEOF
  640. }
  641. b := data[iNdEx]
  642. iNdEx++
  643. v |= (int(b) & 0x7F) << shift
  644. if b < 0x80 {
  645. break
  646. }
  647. }
  648. m.Sorted = bool(v != 0)
  649. case 14:
  650. if wireType != 0 {
  651. return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
  652. }
  653. var v int
  654. for shift := uint(0); ; shift += 7 {
  655. if shift >= 64 {
  656. return ErrIntOverflowEtcdserver
  657. }
  658. if iNdEx >= l {
  659. return io.ErrUnexpectedEOF
  660. }
  661. b := data[iNdEx]
  662. iNdEx++
  663. v |= (int(b) & 0x7F) << shift
  664. if b < 0x80 {
  665. break
  666. }
  667. }
  668. m.Quorum = bool(v != 0)
  669. case 15:
  670. if wireType != 0 {
  671. return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
  672. }
  673. m.Time = 0
  674. for shift := uint(0); ; shift += 7 {
  675. if shift >= 64 {
  676. return ErrIntOverflowEtcdserver
  677. }
  678. if iNdEx >= l {
  679. return io.ErrUnexpectedEOF
  680. }
  681. b := data[iNdEx]
  682. iNdEx++
  683. m.Time |= (int64(b) & 0x7F) << shift
  684. if b < 0x80 {
  685. break
  686. }
  687. }
  688. case 16:
  689. if wireType != 0 {
  690. return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
  691. }
  692. var v int
  693. for shift := uint(0); ; shift += 7 {
  694. if shift >= 64 {
  695. return ErrIntOverflowEtcdserver
  696. }
  697. if iNdEx >= l {
  698. return io.ErrUnexpectedEOF
  699. }
  700. b := data[iNdEx]
  701. iNdEx++
  702. v |= (int(b) & 0x7F) << shift
  703. if b < 0x80 {
  704. break
  705. }
  706. }
  707. m.Stream = bool(v != 0)
  708. case 17:
  709. if wireType != 0 {
  710. return fmt.Errorf("proto: wrong wireType = %d for field Refresh", wireType)
  711. }
  712. var v int
  713. for shift := uint(0); ; shift += 7 {
  714. if shift >= 64 {
  715. return ErrIntOverflowEtcdserver
  716. }
  717. if iNdEx >= l {
  718. return io.ErrUnexpectedEOF
  719. }
  720. b := data[iNdEx]
  721. iNdEx++
  722. v |= (int(b) & 0x7F) << shift
  723. if b < 0x80 {
  724. break
  725. }
  726. }
  727. b := bool(v != 0)
  728. m.Refresh = &b
  729. default:
  730. iNdEx = preIndex
  731. skippy, err := skipEtcdserver(data[iNdEx:])
  732. if err != nil {
  733. return err
  734. }
  735. if skippy < 0 {
  736. return ErrInvalidLengthEtcdserver
  737. }
  738. if (iNdEx + skippy) > l {
  739. return io.ErrUnexpectedEOF
  740. }
  741. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  742. iNdEx += skippy
  743. }
  744. }
  745. if iNdEx > l {
  746. return io.ErrUnexpectedEOF
  747. }
  748. return nil
  749. }
  750. func (m *Metadata) Unmarshal(data []byte) error {
  751. l := len(data)
  752. iNdEx := 0
  753. for iNdEx < l {
  754. preIndex := iNdEx
  755. var wire uint64
  756. for shift := uint(0); ; shift += 7 {
  757. if shift >= 64 {
  758. return ErrIntOverflowEtcdserver
  759. }
  760. if iNdEx >= l {
  761. return io.ErrUnexpectedEOF
  762. }
  763. b := data[iNdEx]
  764. iNdEx++
  765. wire |= (uint64(b) & 0x7F) << shift
  766. if b < 0x80 {
  767. break
  768. }
  769. }
  770. fieldNum := int32(wire >> 3)
  771. wireType := int(wire & 0x7)
  772. if wireType == 4 {
  773. return fmt.Errorf("proto: Metadata: wiretype end group for non-group")
  774. }
  775. if fieldNum <= 0 {
  776. return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire)
  777. }
  778. switch fieldNum {
  779. case 1:
  780. if wireType != 0 {
  781. return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
  782. }
  783. m.NodeID = 0
  784. for shift := uint(0); ; shift += 7 {
  785. if shift >= 64 {
  786. return ErrIntOverflowEtcdserver
  787. }
  788. if iNdEx >= l {
  789. return io.ErrUnexpectedEOF
  790. }
  791. b := data[iNdEx]
  792. iNdEx++
  793. m.NodeID |= (uint64(b) & 0x7F) << shift
  794. if b < 0x80 {
  795. break
  796. }
  797. }
  798. case 2:
  799. if wireType != 0 {
  800. return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
  801. }
  802. m.ClusterID = 0
  803. for shift := uint(0); ; shift += 7 {
  804. if shift >= 64 {
  805. return ErrIntOverflowEtcdserver
  806. }
  807. if iNdEx >= l {
  808. return io.ErrUnexpectedEOF
  809. }
  810. b := data[iNdEx]
  811. iNdEx++
  812. m.ClusterID |= (uint64(b) & 0x7F) << shift
  813. if b < 0x80 {
  814. break
  815. }
  816. }
  817. default:
  818. iNdEx = preIndex
  819. skippy, err := skipEtcdserver(data[iNdEx:])
  820. if err != nil {
  821. return err
  822. }
  823. if skippy < 0 {
  824. return ErrInvalidLengthEtcdserver
  825. }
  826. if (iNdEx + skippy) > l {
  827. return io.ErrUnexpectedEOF
  828. }
  829. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  830. iNdEx += skippy
  831. }
  832. }
  833. if iNdEx > l {
  834. return io.ErrUnexpectedEOF
  835. }
  836. return nil
  837. }
  838. func skipEtcdserver(data []byte) (n int, err error) {
  839. l := len(data)
  840. iNdEx := 0
  841. for iNdEx < l {
  842. var wire uint64
  843. for shift := uint(0); ; shift += 7 {
  844. if shift >= 64 {
  845. return 0, ErrIntOverflowEtcdserver
  846. }
  847. if iNdEx >= l {
  848. return 0, io.ErrUnexpectedEOF
  849. }
  850. b := data[iNdEx]
  851. iNdEx++
  852. wire |= (uint64(b) & 0x7F) << shift
  853. if b < 0x80 {
  854. break
  855. }
  856. }
  857. wireType := int(wire & 0x7)
  858. switch wireType {
  859. case 0:
  860. for shift := uint(0); ; shift += 7 {
  861. if shift >= 64 {
  862. return 0, ErrIntOverflowEtcdserver
  863. }
  864. if iNdEx >= l {
  865. return 0, io.ErrUnexpectedEOF
  866. }
  867. iNdEx++
  868. if data[iNdEx-1] < 0x80 {
  869. break
  870. }
  871. }
  872. return iNdEx, nil
  873. case 1:
  874. iNdEx += 8
  875. return iNdEx, nil
  876. case 2:
  877. var length int
  878. for shift := uint(0); ; shift += 7 {
  879. if shift >= 64 {
  880. return 0, ErrIntOverflowEtcdserver
  881. }
  882. if iNdEx >= l {
  883. return 0, io.ErrUnexpectedEOF
  884. }
  885. b := data[iNdEx]
  886. iNdEx++
  887. length |= (int(b) & 0x7F) << shift
  888. if b < 0x80 {
  889. break
  890. }
  891. }
  892. iNdEx += length
  893. if length < 0 {
  894. return 0, ErrInvalidLengthEtcdserver
  895. }
  896. return iNdEx, nil
  897. case 3:
  898. for {
  899. var innerWire uint64
  900. var start int = iNdEx
  901. for shift := uint(0); ; shift += 7 {
  902. if shift >= 64 {
  903. return 0, ErrIntOverflowEtcdserver
  904. }
  905. if iNdEx >= l {
  906. return 0, io.ErrUnexpectedEOF
  907. }
  908. b := data[iNdEx]
  909. iNdEx++
  910. innerWire |= (uint64(b) & 0x7F) << shift
  911. if b < 0x80 {
  912. break
  913. }
  914. }
  915. innerWireType := int(innerWire & 0x7)
  916. if innerWireType == 4 {
  917. break
  918. }
  919. next, err := skipEtcdserver(data[start:])
  920. if err != nil {
  921. return 0, err
  922. }
  923. iNdEx = start + next
  924. }
  925. return iNdEx, nil
  926. case 4:
  927. return iNdEx, nil
  928. case 5:
  929. iNdEx += 4
  930. return iNdEx, nil
  931. default:
  932. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  933. }
  934. }
  935. panic("unreachable")
  936. }
  937. var (
  938. ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
  939. ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow")
  940. )