etcdserver.pb.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035
  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. RequestHeader
  14. InternalRaftRequest
  15. EmptyResponse
  16. ResponseHeader
  17. RangeRequest
  18. RangeResponse
  19. PutRequest
  20. PutResponse
  21. DeleteRangeRequest
  22. DeleteRangeResponse
  23. RequestUnion
  24. ResponseUnion
  25. Compare
  26. TxnRequest
  27. TxnResponse
  28. CompactionRequest
  29. CompactionResponse
  30. HashRequest
  31. HashResponse
  32. SnapshotRequest
  33. SnapshotResponse
  34. WatchRequest
  35. WatchCreateRequest
  36. WatchCancelRequest
  37. WatchResponse
  38. LeaseGrantRequest
  39. LeaseGrantResponse
  40. LeaseRevokeRequest
  41. LeaseRevokeResponse
  42. LeaseKeepAliveRequest
  43. LeaseKeepAliveResponse
  44. Member
  45. MemberAddRequest
  46. MemberAddResponse
  47. MemberRemoveRequest
  48. MemberRemoveResponse
  49. MemberUpdateRequest
  50. MemberUpdateResponse
  51. MemberListRequest
  52. MemberListResponse
  53. DefragmentRequest
  54. DefragmentResponse
  55. AlarmRequest
  56. AlarmMember
  57. AlarmResponse
  58. StatusRequest
  59. StatusResponse
  60. AuthEnableRequest
  61. AuthDisableRequest
  62. AuthenticateRequest
  63. AuthUserAddRequest
  64. AuthUserGetRequest
  65. AuthUserDeleteRequest
  66. AuthUserChangePasswordRequest
  67. AuthUserGrantRequest
  68. AuthUserRevokeRequest
  69. AuthRoleAddRequest
  70. AuthRoleGetRequest
  71. AuthRoleDeleteRequest
  72. AuthRoleGrantRequest
  73. AuthRoleRevokeRequest
  74. AuthEnableResponse
  75. AuthDisableResponse
  76. AuthenticateResponse
  77. AuthUserAddResponse
  78. AuthUserGetResponse
  79. AuthUserDeleteResponse
  80. AuthUserChangePasswordResponse
  81. AuthUserGrantResponse
  82. AuthUserRevokeResponse
  83. AuthRoleAddResponse
  84. AuthRoleGetResponse
  85. AuthRoleDeleteResponse
  86. AuthRoleGrantResponse
  87. AuthRoleRevokeResponse
  88. */
  89. package etcdserverpb
  90. import (
  91. "fmt"
  92. proto "github.com/gogo/protobuf/proto"
  93. math "math"
  94. )
  95. import io "io"
  96. // Reference imports to suppress errors if they are not otherwise used.
  97. var _ = proto.Marshal
  98. var _ = fmt.Errorf
  99. var _ = math.Inf
  100. // This is a compile-time assertion to ensure that this generated file
  101. // is compatible with the proto package it is being compiled against.
  102. const _ = proto.GoGoProtoPackageIsVersion1
  103. type Request struct {
  104. ID uint64 `protobuf:"varint,1,opt,name=ID,json=iD" json:"ID"`
  105. Method string `protobuf:"bytes,2,opt,name=Method,json=method" json:"Method"`
  106. Path string `protobuf:"bytes,3,opt,name=Path,json=path" json:"Path"`
  107. Val string `protobuf:"bytes,4,opt,name=Val,json=val" json:"Val"`
  108. Dir bool `protobuf:"varint,5,opt,name=Dir,json=dir" json:"Dir"`
  109. PrevValue string `protobuf:"bytes,6,opt,name=PrevValue,json=prevValue" json:"PrevValue"`
  110. PrevIndex uint64 `protobuf:"varint,7,opt,name=PrevIndex,json=prevIndex" json:"PrevIndex"`
  111. PrevExist *bool `protobuf:"varint,8,opt,name=PrevExist,json=prevExist" json:"PrevExist,omitempty"`
  112. Expiration int64 `protobuf:"varint,9,opt,name=Expiration,json=expiration" json:"Expiration"`
  113. Wait bool `protobuf:"varint,10,opt,name=Wait,json=wait" json:"Wait"`
  114. Since uint64 `protobuf:"varint,11,opt,name=Since,json=since" json:"Since"`
  115. Recursive bool `protobuf:"varint,12,opt,name=Recursive,json=recursive" json:"Recursive"`
  116. Sorted bool `protobuf:"varint,13,opt,name=Sorted,json=sorted" json:"Sorted"`
  117. Quorum bool `protobuf:"varint,14,opt,name=Quorum,json=quorum" json:"Quorum"`
  118. Time int64 `protobuf:"varint,15,opt,name=Time,json=time" json:"Time"`
  119. Stream bool `protobuf:"varint,16,opt,name=Stream,json=stream" json:"Stream"`
  120. Refresh *bool `protobuf:"varint,17,opt,name=Refresh,json=refresh" json:"Refresh,omitempty"`
  121. XXX_unrecognized []byte `json:"-"`
  122. }
  123. func (m *Request) Reset() { *m = Request{} }
  124. func (m *Request) String() string { return proto.CompactTextString(m) }
  125. func (*Request) ProtoMessage() {}
  126. func (*Request) Descriptor() ([]byte, []int) { return fileDescriptorEtcdserver, []int{0} }
  127. type Metadata struct {
  128. NodeID uint64 `protobuf:"varint,1,opt,name=NodeID,json=nodeID" json:"NodeID"`
  129. ClusterID uint64 `protobuf:"varint,2,opt,name=ClusterID,json=clusterID" json:"ClusterID"`
  130. XXX_unrecognized []byte `json:"-"`
  131. }
  132. func (m *Metadata) Reset() { *m = Metadata{} }
  133. func (m *Metadata) String() string { return proto.CompactTextString(m) }
  134. func (*Metadata) ProtoMessage() {}
  135. func (*Metadata) Descriptor() ([]byte, []int) { return fileDescriptorEtcdserver, []int{1} }
  136. func init() {
  137. proto.RegisterType((*Request)(nil), "etcdserverpb.Request")
  138. proto.RegisterType((*Metadata)(nil), "etcdserverpb.Metadata")
  139. }
  140. func (m *Request) Marshal() (data []byte, err error) {
  141. size := m.Size()
  142. data = make([]byte, size)
  143. n, err := m.MarshalTo(data)
  144. if err != nil {
  145. return nil, err
  146. }
  147. return data[:n], nil
  148. }
  149. func (m *Request) MarshalTo(data []byte) (int, error) {
  150. var i int
  151. _ = i
  152. var l int
  153. _ = l
  154. data[i] = 0x8
  155. i++
  156. i = encodeVarintEtcdserver(data, i, uint64(m.ID))
  157. data[i] = 0x12
  158. i++
  159. i = encodeVarintEtcdserver(data, i, uint64(len(m.Method)))
  160. i += copy(data[i:], m.Method)
  161. data[i] = 0x1a
  162. i++
  163. i = encodeVarintEtcdserver(data, i, uint64(len(m.Path)))
  164. i += copy(data[i:], m.Path)
  165. data[i] = 0x22
  166. i++
  167. i = encodeVarintEtcdserver(data, i, uint64(len(m.Val)))
  168. i += copy(data[i:], m.Val)
  169. data[i] = 0x28
  170. i++
  171. if m.Dir {
  172. data[i] = 1
  173. } else {
  174. data[i] = 0
  175. }
  176. i++
  177. data[i] = 0x32
  178. i++
  179. i = encodeVarintEtcdserver(data, i, uint64(len(m.PrevValue)))
  180. i += copy(data[i:], m.PrevValue)
  181. data[i] = 0x38
  182. i++
  183. i = encodeVarintEtcdserver(data, i, uint64(m.PrevIndex))
  184. if m.PrevExist != nil {
  185. data[i] = 0x40
  186. i++
  187. if *m.PrevExist {
  188. data[i] = 1
  189. } else {
  190. data[i] = 0
  191. }
  192. i++
  193. }
  194. data[i] = 0x48
  195. i++
  196. i = encodeVarintEtcdserver(data, i, uint64(m.Expiration))
  197. data[i] = 0x50
  198. i++
  199. if m.Wait {
  200. data[i] = 1
  201. } else {
  202. data[i] = 0
  203. }
  204. i++
  205. data[i] = 0x58
  206. i++
  207. i = encodeVarintEtcdserver(data, i, uint64(m.Since))
  208. data[i] = 0x60
  209. i++
  210. if m.Recursive {
  211. data[i] = 1
  212. } else {
  213. data[i] = 0
  214. }
  215. i++
  216. data[i] = 0x68
  217. i++
  218. if m.Sorted {
  219. data[i] = 1
  220. } else {
  221. data[i] = 0
  222. }
  223. i++
  224. data[i] = 0x70
  225. i++
  226. if m.Quorum {
  227. data[i] = 1
  228. } else {
  229. data[i] = 0
  230. }
  231. i++
  232. data[i] = 0x78
  233. i++
  234. i = encodeVarintEtcdserver(data, i, uint64(m.Time))
  235. data[i] = 0x80
  236. i++
  237. data[i] = 0x1
  238. i++
  239. if m.Stream {
  240. data[i] = 1
  241. } else {
  242. data[i] = 0
  243. }
  244. i++
  245. if m.Refresh != nil {
  246. data[i] = 0x88
  247. i++
  248. data[i] = 0x1
  249. i++
  250. if *m.Refresh {
  251. data[i] = 1
  252. } else {
  253. data[i] = 0
  254. }
  255. i++
  256. }
  257. if m.XXX_unrecognized != nil {
  258. i += copy(data[i:], m.XXX_unrecognized)
  259. }
  260. return i, nil
  261. }
  262. func (m *Metadata) Marshal() (data []byte, err error) {
  263. size := m.Size()
  264. data = make([]byte, size)
  265. n, err := m.MarshalTo(data)
  266. if err != nil {
  267. return nil, err
  268. }
  269. return data[:n], nil
  270. }
  271. func (m *Metadata) MarshalTo(data []byte) (int, error) {
  272. var i int
  273. _ = i
  274. var l int
  275. _ = l
  276. data[i] = 0x8
  277. i++
  278. i = encodeVarintEtcdserver(data, i, uint64(m.NodeID))
  279. data[i] = 0x10
  280. i++
  281. i = encodeVarintEtcdserver(data, i, uint64(m.ClusterID))
  282. if m.XXX_unrecognized != nil {
  283. i += copy(data[i:], m.XXX_unrecognized)
  284. }
  285. return i, nil
  286. }
  287. func encodeFixed64Etcdserver(data []byte, offset int, v uint64) int {
  288. data[offset] = uint8(v)
  289. data[offset+1] = uint8(v >> 8)
  290. data[offset+2] = uint8(v >> 16)
  291. data[offset+3] = uint8(v >> 24)
  292. data[offset+4] = uint8(v >> 32)
  293. data[offset+5] = uint8(v >> 40)
  294. data[offset+6] = uint8(v >> 48)
  295. data[offset+7] = uint8(v >> 56)
  296. return offset + 8
  297. }
  298. func encodeFixed32Etcdserver(data []byte, offset int, v uint32) int {
  299. data[offset] = uint8(v)
  300. data[offset+1] = uint8(v >> 8)
  301. data[offset+2] = uint8(v >> 16)
  302. data[offset+3] = uint8(v >> 24)
  303. return offset + 4
  304. }
  305. func encodeVarintEtcdserver(data []byte, offset int, v uint64) int {
  306. for v >= 1<<7 {
  307. data[offset] = uint8(v&0x7f | 0x80)
  308. v >>= 7
  309. offset++
  310. }
  311. data[offset] = uint8(v)
  312. return offset + 1
  313. }
  314. func (m *Request) Size() (n int) {
  315. var l int
  316. _ = l
  317. n += 1 + sovEtcdserver(uint64(m.ID))
  318. l = len(m.Method)
  319. n += 1 + l + sovEtcdserver(uint64(l))
  320. l = len(m.Path)
  321. n += 1 + l + sovEtcdserver(uint64(l))
  322. l = len(m.Val)
  323. n += 1 + l + sovEtcdserver(uint64(l))
  324. n += 2
  325. l = len(m.PrevValue)
  326. n += 1 + l + sovEtcdserver(uint64(l))
  327. n += 1 + sovEtcdserver(uint64(m.PrevIndex))
  328. if m.PrevExist != nil {
  329. n += 2
  330. }
  331. n += 1 + sovEtcdserver(uint64(m.Expiration))
  332. n += 2
  333. n += 1 + sovEtcdserver(uint64(m.Since))
  334. n += 2
  335. n += 2
  336. n += 2
  337. n += 1 + sovEtcdserver(uint64(m.Time))
  338. n += 3
  339. if m.Refresh != nil {
  340. n += 3
  341. }
  342. if m.XXX_unrecognized != nil {
  343. n += len(m.XXX_unrecognized)
  344. }
  345. return n
  346. }
  347. func (m *Metadata) Size() (n int) {
  348. var l int
  349. _ = l
  350. n += 1 + sovEtcdserver(uint64(m.NodeID))
  351. n += 1 + sovEtcdserver(uint64(m.ClusterID))
  352. if m.XXX_unrecognized != nil {
  353. n += len(m.XXX_unrecognized)
  354. }
  355. return n
  356. }
  357. func sovEtcdserver(x uint64) (n int) {
  358. for {
  359. n++
  360. x >>= 7
  361. if x == 0 {
  362. break
  363. }
  364. }
  365. return n
  366. }
  367. func sozEtcdserver(x uint64) (n int) {
  368. return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  369. }
  370. func (m *Request) Unmarshal(data []byte) error {
  371. l := len(data)
  372. iNdEx := 0
  373. for iNdEx < l {
  374. preIndex := iNdEx
  375. var wire uint64
  376. for shift := uint(0); ; shift += 7 {
  377. if shift >= 64 {
  378. return ErrIntOverflowEtcdserver
  379. }
  380. if iNdEx >= l {
  381. return io.ErrUnexpectedEOF
  382. }
  383. b := data[iNdEx]
  384. iNdEx++
  385. wire |= (uint64(b) & 0x7F) << shift
  386. if b < 0x80 {
  387. break
  388. }
  389. }
  390. fieldNum := int32(wire >> 3)
  391. wireType := int(wire & 0x7)
  392. if wireType == 4 {
  393. return fmt.Errorf("proto: Request: wiretype end group for non-group")
  394. }
  395. if fieldNum <= 0 {
  396. return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
  397. }
  398. switch fieldNum {
  399. case 1:
  400. if wireType != 0 {
  401. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  402. }
  403. m.ID = 0
  404. for shift := uint(0); ; shift += 7 {
  405. if shift >= 64 {
  406. return ErrIntOverflowEtcdserver
  407. }
  408. if iNdEx >= l {
  409. return io.ErrUnexpectedEOF
  410. }
  411. b := data[iNdEx]
  412. iNdEx++
  413. m.ID |= (uint64(b) & 0x7F) << shift
  414. if b < 0x80 {
  415. break
  416. }
  417. }
  418. case 2:
  419. if wireType != 2 {
  420. return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
  421. }
  422. var stringLen uint64
  423. for shift := uint(0); ; shift += 7 {
  424. if shift >= 64 {
  425. return ErrIntOverflowEtcdserver
  426. }
  427. if iNdEx >= l {
  428. return io.ErrUnexpectedEOF
  429. }
  430. b := data[iNdEx]
  431. iNdEx++
  432. stringLen |= (uint64(b) & 0x7F) << shift
  433. if b < 0x80 {
  434. break
  435. }
  436. }
  437. intStringLen := int(stringLen)
  438. if intStringLen < 0 {
  439. return ErrInvalidLengthEtcdserver
  440. }
  441. postIndex := iNdEx + intStringLen
  442. if postIndex > l {
  443. return io.ErrUnexpectedEOF
  444. }
  445. m.Method = string(data[iNdEx:postIndex])
  446. iNdEx = postIndex
  447. case 3:
  448. if wireType != 2 {
  449. return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
  450. }
  451. var stringLen uint64
  452. for shift := uint(0); ; shift += 7 {
  453. if shift >= 64 {
  454. return ErrIntOverflowEtcdserver
  455. }
  456. if iNdEx >= l {
  457. return io.ErrUnexpectedEOF
  458. }
  459. b := data[iNdEx]
  460. iNdEx++
  461. stringLen |= (uint64(b) & 0x7F) << shift
  462. if b < 0x80 {
  463. break
  464. }
  465. }
  466. intStringLen := int(stringLen)
  467. if intStringLen < 0 {
  468. return ErrInvalidLengthEtcdserver
  469. }
  470. postIndex := iNdEx + intStringLen
  471. if postIndex > l {
  472. return io.ErrUnexpectedEOF
  473. }
  474. m.Path = string(data[iNdEx:postIndex])
  475. iNdEx = postIndex
  476. case 4:
  477. if wireType != 2 {
  478. return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
  479. }
  480. var stringLen uint64
  481. for shift := uint(0); ; shift += 7 {
  482. if shift >= 64 {
  483. return ErrIntOverflowEtcdserver
  484. }
  485. if iNdEx >= l {
  486. return io.ErrUnexpectedEOF
  487. }
  488. b := data[iNdEx]
  489. iNdEx++
  490. stringLen |= (uint64(b) & 0x7F) << shift
  491. if b < 0x80 {
  492. break
  493. }
  494. }
  495. intStringLen := int(stringLen)
  496. if intStringLen < 0 {
  497. return ErrInvalidLengthEtcdserver
  498. }
  499. postIndex := iNdEx + intStringLen
  500. if postIndex > l {
  501. return io.ErrUnexpectedEOF
  502. }
  503. m.Val = string(data[iNdEx:postIndex])
  504. iNdEx = postIndex
  505. case 5:
  506. if wireType != 0 {
  507. return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
  508. }
  509. var v int
  510. for shift := uint(0); ; shift += 7 {
  511. if shift >= 64 {
  512. return ErrIntOverflowEtcdserver
  513. }
  514. if iNdEx >= l {
  515. return io.ErrUnexpectedEOF
  516. }
  517. b := data[iNdEx]
  518. iNdEx++
  519. v |= (int(b) & 0x7F) << shift
  520. if b < 0x80 {
  521. break
  522. }
  523. }
  524. m.Dir = bool(v != 0)
  525. case 6:
  526. if wireType != 2 {
  527. return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
  528. }
  529. var stringLen uint64
  530. for shift := uint(0); ; shift += 7 {
  531. if shift >= 64 {
  532. return ErrIntOverflowEtcdserver
  533. }
  534. if iNdEx >= l {
  535. return io.ErrUnexpectedEOF
  536. }
  537. b := data[iNdEx]
  538. iNdEx++
  539. stringLen |= (uint64(b) & 0x7F) << shift
  540. if b < 0x80 {
  541. break
  542. }
  543. }
  544. intStringLen := int(stringLen)
  545. if intStringLen < 0 {
  546. return ErrInvalidLengthEtcdserver
  547. }
  548. postIndex := iNdEx + intStringLen
  549. if postIndex > l {
  550. return io.ErrUnexpectedEOF
  551. }
  552. m.PrevValue = string(data[iNdEx:postIndex])
  553. iNdEx = postIndex
  554. case 7:
  555. if wireType != 0 {
  556. return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
  557. }
  558. m.PrevIndex = 0
  559. for shift := uint(0); ; shift += 7 {
  560. if shift >= 64 {
  561. return ErrIntOverflowEtcdserver
  562. }
  563. if iNdEx >= l {
  564. return io.ErrUnexpectedEOF
  565. }
  566. b := data[iNdEx]
  567. iNdEx++
  568. m.PrevIndex |= (uint64(b) & 0x7F) << shift
  569. if b < 0x80 {
  570. break
  571. }
  572. }
  573. case 8:
  574. if wireType != 0 {
  575. return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
  576. }
  577. var v int
  578. for shift := uint(0); ; shift += 7 {
  579. if shift >= 64 {
  580. return ErrIntOverflowEtcdserver
  581. }
  582. if iNdEx >= l {
  583. return io.ErrUnexpectedEOF
  584. }
  585. b := data[iNdEx]
  586. iNdEx++
  587. v |= (int(b) & 0x7F) << shift
  588. if b < 0x80 {
  589. break
  590. }
  591. }
  592. b := bool(v != 0)
  593. m.PrevExist = &b
  594. case 9:
  595. if wireType != 0 {
  596. return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
  597. }
  598. m.Expiration = 0
  599. for shift := uint(0); ; shift += 7 {
  600. if shift >= 64 {
  601. return ErrIntOverflowEtcdserver
  602. }
  603. if iNdEx >= l {
  604. return io.ErrUnexpectedEOF
  605. }
  606. b := data[iNdEx]
  607. iNdEx++
  608. m.Expiration |= (int64(b) & 0x7F) << shift
  609. if b < 0x80 {
  610. break
  611. }
  612. }
  613. case 10:
  614. if wireType != 0 {
  615. return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
  616. }
  617. var v int
  618. for shift := uint(0); ; shift += 7 {
  619. if shift >= 64 {
  620. return ErrIntOverflowEtcdserver
  621. }
  622. if iNdEx >= l {
  623. return io.ErrUnexpectedEOF
  624. }
  625. b := data[iNdEx]
  626. iNdEx++
  627. v |= (int(b) & 0x7F) << shift
  628. if b < 0x80 {
  629. break
  630. }
  631. }
  632. m.Wait = bool(v != 0)
  633. case 11:
  634. if wireType != 0 {
  635. return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
  636. }
  637. m.Since = 0
  638. for shift := uint(0); ; shift += 7 {
  639. if shift >= 64 {
  640. return ErrIntOverflowEtcdserver
  641. }
  642. if iNdEx >= l {
  643. return io.ErrUnexpectedEOF
  644. }
  645. b := data[iNdEx]
  646. iNdEx++
  647. m.Since |= (uint64(b) & 0x7F) << shift
  648. if b < 0x80 {
  649. break
  650. }
  651. }
  652. case 12:
  653. if wireType != 0 {
  654. return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
  655. }
  656. var v int
  657. for shift := uint(0); ; shift += 7 {
  658. if shift >= 64 {
  659. return ErrIntOverflowEtcdserver
  660. }
  661. if iNdEx >= l {
  662. return io.ErrUnexpectedEOF
  663. }
  664. b := data[iNdEx]
  665. iNdEx++
  666. v |= (int(b) & 0x7F) << shift
  667. if b < 0x80 {
  668. break
  669. }
  670. }
  671. m.Recursive = bool(v != 0)
  672. case 13:
  673. if wireType != 0 {
  674. return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
  675. }
  676. var v int
  677. for shift := uint(0); ; shift += 7 {
  678. if shift >= 64 {
  679. return ErrIntOverflowEtcdserver
  680. }
  681. if iNdEx >= l {
  682. return io.ErrUnexpectedEOF
  683. }
  684. b := data[iNdEx]
  685. iNdEx++
  686. v |= (int(b) & 0x7F) << shift
  687. if b < 0x80 {
  688. break
  689. }
  690. }
  691. m.Sorted = bool(v != 0)
  692. case 14:
  693. if wireType != 0 {
  694. return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
  695. }
  696. var v int
  697. for shift := uint(0); ; shift += 7 {
  698. if shift >= 64 {
  699. return ErrIntOverflowEtcdserver
  700. }
  701. if iNdEx >= l {
  702. return io.ErrUnexpectedEOF
  703. }
  704. b := data[iNdEx]
  705. iNdEx++
  706. v |= (int(b) & 0x7F) << shift
  707. if b < 0x80 {
  708. break
  709. }
  710. }
  711. m.Quorum = bool(v != 0)
  712. case 15:
  713. if wireType != 0 {
  714. return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
  715. }
  716. m.Time = 0
  717. for shift := uint(0); ; shift += 7 {
  718. if shift >= 64 {
  719. return ErrIntOverflowEtcdserver
  720. }
  721. if iNdEx >= l {
  722. return io.ErrUnexpectedEOF
  723. }
  724. b := data[iNdEx]
  725. iNdEx++
  726. m.Time |= (int64(b) & 0x7F) << shift
  727. if b < 0x80 {
  728. break
  729. }
  730. }
  731. case 16:
  732. if wireType != 0 {
  733. return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
  734. }
  735. var v int
  736. for shift := uint(0); ; shift += 7 {
  737. if shift >= 64 {
  738. return ErrIntOverflowEtcdserver
  739. }
  740. if iNdEx >= l {
  741. return io.ErrUnexpectedEOF
  742. }
  743. b := data[iNdEx]
  744. iNdEx++
  745. v |= (int(b) & 0x7F) << shift
  746. if b < 0x80 {
  747. break
  748. }
  749. }
  750. m.Stream = bool(v != 0)
  751. case 17:
  752. if wireType != 0 {
  753. return fmt.Errorf("proto: wrong wireType = %d for field Refresh", wireType)
  754. }
  755. var v int
  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. v |= (int(b) & 0x7F) << shift
  766. if b < 0x80 {
  767. break
  768. }
  769. }
  770. b := bool(v != 0)
  771. m.Refresh = &b
  772. default:
  773. iNdEx = preIndex
  774. skippy, err := skipEtcdserver(data[iNdEx:])
  775. if err != nil {
  776. return err
  777. }
  778. if skippy < 0 {
  779. return ErrInvalidLengthEtcdserver
  780. }
  781. if (iNdEx + skippy) > l {
  782. return io.ErrUnexpectedEOF
  783. }
  784. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  785. iNdEx += skippy
  786. }
  787. }
  788. if iNdEx > l {
  789. return io.ErrUnexpectedEOF
  790. }
  791. return nil
  792. }
  793. func (m *Metadata) Unmarshal(data []byte) error {
  794. l := len(data)
  795. iNdEx := 0
  796. for iNdEx < l {
  797. preIndex := iNdEx
  798. var wire uint64
  799. for shift := uint(0); ; shift += 7 {
  800. if shift >= 64 {
  801. return ErrIntOverflowEtcdserver
  802. }
  803. if iNdEx >= l {
  804. return io.ErrUnexpectedEOF
  805. }
  806. b := data[iNdEx]
  807. iNdEx++
  808. wire |= (uint64(b) & 0x7F) << shift
  809. if b < 0x80 {
  810. break
  811. }
  812. }
  813. fieldNum := int32(wire >> 3)
  814. wireType := int(wire & 0x7)
  815. if wireType == 4 {
  816. return fmt.Errorf("proto: Metadata: wiretype end group for non-group")
  817. }
  818. if fieldNum <= 0 {
  819. return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire)
  820. }
  821. switch fieldNum {
  822. case 1:
  823. if wireType != 0 {
  824. return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
  825. }
  826. m.NodeID = 0
  827. for shift := uint(0); ; shift += 7 {
  828. if shift >= 64 {
  829. return ErrIntOverflowEtcdserver
  830. }
  831. if iNdEx >= l {
  832. return io.ErrUnexpectedEOF
  833. }
  834. b := data[iNdEx]
  835. iNdEx++
  836. m.NodeID |= (uint64(b) & 0x7F) << shift
  837. if b < 0x80 {
  838. break
  839. }
  840. }
  841. case 2:
  842. if wireType != 0 {
  843. return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
  844. }
  845. m.ClusterID = 0
  846. for shift := uint(0); ; shift += 7 {
  847. if shift >= 64 {
  848. return ErrIntOverflowEtcdserver
  849. }
  850. if iNdEx >= l {
  851. return io.ErrUnexpectedEOF
  852. }
  853. b := data[iNdEx]
  854. iNdEx++
  855. m.ClusterID |= (uint64(b) & 0x7F) << shift
  856. if b < 0x80 {
  857. break
  858. }
  859. }
  860. default:
  861. iNdEx = preIndex
  862. skippy, err := skipEtcdserver(data[iNdEx:])
  863. if err != nil {
  864. return err
  865. }
  866. if skippy < 0 {
  867. return ErrInvalidLengthEtcdserver
  868. }
  869. if (iNdEx + skippy) > l {
  870. return io.ErrUnexpectedEOF
  871. }
  872. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  873. iNdEx += skippy
  874. }
  875. }
  876. if iNdEx > l {
  877. return io.ErrUnexpectedEOF
  878. }
  879. return nil
  880. }
  881. func skipEtcdserver(data []byte) (n int, err error) {
  882. l := len(data)
  883. iNdEx := 0
  884. for iNdEx < l {
  885. var wire uint64
  886. for shift := uint(0); ; shift += 7 {
  887. if shift >= 64 {
  888. return 0, ErrIntOverflowEtcdserver
  889. }
  890. if iNdEx >= l {
  891. return 0, io.ErrUnexpectedEOF
  892. }
  893. b := data[iNdEx]
  894. iNdEx++
  895. wire |= (uint64(b) & 0x7F) << shift
  896. if b < 0x80 {
  897. break
  898. }
  899. }
  900. wireType := int(wire & 0x7)
  901. switch wireType {
  902. case 0:
  903. for shift := uint(0); ; shift += 7 {
  904. if shift >= 64 {
  905. return 0, ErrIntOverflowEtcdserver
  906. }
  907. if iNdEx >= l {
  908. return 0, io.ErrUnexpectedEOF
  909. }
  910. iNdEx++
  911. if data[iNdEx-1] < 0x80 {
  912. break
  913. }
  914. }
  915. return iNdEx, nil
  916. case 1:
  917. iNdEx += 8
  918. return iNdEx, nil
  919. case 2:
  920. var length int
  921. for shift := uint(0); ; shift += 7 {
  922. if shift >= 64 {
  923. return 0, ErrIntOverflowEtcdserver
  924. }
  925. if iNdEx >= l {
  926. return 0, io.ErrUnexpectedEOF
  927. }
  928. b := data[iNdEx]
  929. iNdEx++
  930. length |= (int(b) & 0x7F) << shift
  931. if b < 0x80 {
  932. break
  933. }
  934. }
  935. iNdEx += length
  936. if length < 0 {
  937. return 0, ErrInvalidLengthEtcdserver
  938. }
  939. return iNdEx, nil
  940. case 3:
  941. for {
  942. var innerWire uint64
  943. var start int = iNdEx
  944. for shift := uint(0); ; shift += 7 {
  945. if shift >= 64 {
  946. return 0, ErrIntOverflowEtcdserver
  947. }
  948. if iNdEx >= l {
  949. return 0, io.ErrUnexpectedEOF
  950. }
  951. b := data[iNdEx]
  952. iNdEx++
  953. innerWire |= (uint64(b) & 0x7F) << shift
  954. if b < 0x80 {
  955. break
  956. }
  957. }
  958. innerWireType := int(innerWire & 0x7)
  959. if innerWireType == 4 {
  960. break
  961. }
  962. next, err := skipEtcdserver(data[start:])
  963. if err != nil {
  964. return 0, err
  965. }
  966. iNdEx = start + next
  967. }
  968. return iNdEx, nil
  969. case 4:
  970. return iNdEx, nil
  971. case 5:
  972. iNdEx += 4
  973. return iNdEx, nil
  974. default:
  975. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  976. }
  977. }
  978. panic("unreachable")
  979. }
  980. var (
  981. ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
  982. ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow")
  983. )
  984. var fileDescriptorEtcdserver = []byte{
  985. // 388 bytes of a gzipped FileDescriptorProto
  986. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x5c, 0x92, 0xd1, 0xee, 0xd2, 0x30,
  987. 0x14, 0xc6, 0xff, 0xdb, 0xca, 0x60, 0x15, 0x15, 0x1b, 0x62, 0x4e, 0x88, 0x41, 0x43, 0xbc, 0xf0,
  988. 0x4a, 0xdf, 0x01, 0xe1, 0x82, 0x44, 0x0d, 0x82, 0xd1, 0xeb, 0xba, 0x1d, 0xa1, 0x09, 0x5b, 0x47,
  989. 0xdb, 0x4d, 0xde, 0xc0, 0x57, 0xe3, 0xd2, 0x27, 0x30, 0xea, 0x93, 0xd8, 0x16, 0x86, 0xd5, 0x8b,
  990. 0x26, 0xcb, 0xef, 0xfb, 0xce, 0xe9, 0xd7, 0x73, 0x46, 0x47, 0x68, 0xf2, 0x42, 0xa3, 0x6a, 0x51,
  991. 0xbd, 0xac, 0x95, 0x34, 0x92, 0x0d, 0xff, 0x92, 0xfa, 0xf3, 0x64, 0xbc, 0x93, 0x3b, 0xe9, 0x85,
  992. 0x57, 0xee, 0xeb, 0xe2, 0x99, 0x7d, 0x23, 0xb4, 0xbf, 0xc1, 0x63, 0x83, 0xda, 0xb0, 0x31, 0x8d,
  993. 0x57, 0x0b, 0x88, 0x9e, 0x45, 0x2f, 0xc8, 0x9c, 0x9c, 0x7f, 0x3c, 0xbd, 0xdb, 0xc4, 0x62, 0xc1,
  994. 0x9e, 0xd0, 0xf4, 0x2d, 0x9a, 0xbd, 0x2c, 0x20, 0xb6, 0x4a, 0x76, 0x55, 0xd2, 0xd2, 0x33, 0x06,
  995. 0x94, 0xac, 0xb9, 0xd9, 0x43, 0x12, 0x68, 0xa4, 0xb6, 0x84, 0x3d, 0xa6, 0xc9, 0x47, 0x7e, 0x00,
  996. 0x12, 0x08, 0x49, 0xcb, 0x0f, 0x8e, 0x2f, 0x84, 0x82, 0x9e, 0xe5, 0x83, 0x8e, 0x17, 0x42, 0xb1,
  997. 0x19, 0xcd, 0xd6, 0x0a, 0x5b, 0x5b, 0xd3, 0x20, 0xa4, 0x41, 0x55, 0x56, 0x77, 0xb8, 0xf3, 0xac,
  998. 0xaa, 0x02, 0x4f, 0xd0, 0x0f, 0x82, 0x7a, 0x8f, 0xc7, 0x9d, 0x67, 0x79, 0x12, 0xda, 0xc0, 0xe0,
  999. 0x76, 0x4b, 0x74, 0xf1, 0x78, 0xcc, 0x9e, 0x53, 0xba, 0x3c, 0xd5, 0x42, 0x71, 0x23, 0x64, 0x05,
  1000. 0x99, 0x35, 0x25, 0xd7, 0x46, 0x14, 0x6f, 0xdc, 0xbd, 0xed, 0x13, 0x17, 0x06, 0x68, 0x10, 0x95,
  1001. 0x7c, 0xb5, 0x84, 0x4d, 0x68, 0x6f, 0x2b, 0xaa, 0x1c, 0xe1, 0x5e, 0x90, 0xa1, 0xa7, 0x1d, 0x72,
  1002. 0xf7, 0x6f, 0x30, 0x6f, 0x94, 0x16, 0x2d, 0xc2, 0x30, 0x28, 0xcd, 0x54, 0x87, 0xdd, 0x4c, 0xb7,
  1003. 0x52, 0x19, 0x2c, 0xe0, 0x7e, 0x60, 0x48, 0xb5, 0x67, 0x4e, 0x7d, 0xdf, 0x48, 0xd5, 0x94, 0xf0,
  1004. 0x20, 0x54, 0x8f, 0x9e, 0xb9, 0x54, 0x1f, 0x44, 0x89, 0xf0, 0x30, 0x48, 0x4d, 0x8c, 0x25, 0xbe,
  1005. 0xab, 0x51, 0xc8, 0x4b, 0x18, 0xfd, 0xd3, 0xd5, 0x33, 0x36, 0x75, 0x8b, 0xfe, 0xa2, 0x50, 0xef,
  1006. 0xe1, 0x51, 0x30, 0x95, 0xbe, 0xba, 0xc0, 0xd9, 0x1b, 0x3a, 0xb0, 0x7b, 0xe6, 0x05, 0x37, 0xdc,
  1007. 0x75, 0x7a, 0x27, 0x0b, 0xfc, 0xef, 0x6f, 0x48, 0x2b, 0xcf, 0xdc, 0x0b, 0x5f, 0x1f, 0x1a, 0x6d,
  1008. 0x50, 0x59, 0x43, 0x1c, 0x6e, 0x21, 0xef, 0xf0, 0x7c, 0x74, 0xfe, 0x35, 0xbd, 0x3b, 0xff, 0x9e,
  1009. 0x46, 0xdf, 0xed, 0xf9, 0x69, 0xcf, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xfb, 0x8e, 0x1a, 0x0d,
  1010. 0xa0, 0x02, 0x00, 0x00,
  1011. }