etcdserver.pb.go 24 KB

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