etcdserver.pb.go 21 KB

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