etcdserver.pb.go 21 KB

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