etcdserver.pb.go 25 KB

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