etcdserver.pb.go 24 KB

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