etcdserver.pb.go 24 KB

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