etcdserver.pb.go 24 KB

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