etcdserver.pb.go 25 KB

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