etcdserver.pb.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035
  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. WatchResponse
  40. LeaseGrantRequest
  41. LeaseGrantResponse
  42. LeaseRevokeRequest
  43. LeaseRevokeResponse
  44. LeaseKeepAliveRequest
  45. LeaseKeepAliveResponse
  46. LeaseTimeToLiveRequest
  47. LeaseTimeToLiveResponse
  48. LeaseLeasesRequest
  49. LeaseStatus
  50. LeaseLeasesResponse
  51. Member
  52. MemberAddRequest
  53. MemberAddResponse
  54. MemberRemoveRequest
  55. MemberRemoveResponse
  56. MemberUpdateRequest
  57. MemberUpdateResponse
  58. MemberListRequest
  59. MemberListResponse
  60. DefragmentRequest
  61. DefragmentResponse
  62. MoveLeaderRequest
  63. MoveLeaderResponse
  64. AlarmRequest
  65. AlarmMember
  66. AlarmResponse
  67. StatusRequest
  68. StatusResponse
  69. AuthEnableRequest
  70. AuthDisableRequest
  71. AuthenticateRequest
  72. AuthUserAddRequest
  73. AuthUserGetRequest
  74. AuthUserDeleteRequest
  75. AuthUserChangePasswordRequest
  76. AuthUserGrantRoleRequest
  77. AuthUserRevokeRoleRequest
  78. AuthRoleAddRequest
  79. AuthRoleGetRequest
  80. AuthUserListRequest
  81. AuthRoleListRequest
  82. AuthRoleDeleteRequest
  83. AuthRoleGrantPermissionRequest
  84. AuthRoleRevokePermissionRequest
  85. AuthEnableResponse
  86. AuthDisableResponse
  87. AuthenticateResponse
  88. AuthUserAddResponse
  89. AuthUserGetResponse
  90. AuthUserDeleteResponse
  91. AuthUserChangePasswordResponse
  92. AuthUserGrantRoleResponse
  93. AuthUserRevokeRoleResponse
  94. AuthRoleAddResponse
  95. AuthRoleGetResponse
  96. AuthRoleListResponse
  97. AuthUserListResponse
  98. AuthRoleDeleteResponse
  99. AuthRoleGrantPermissionResponse
  100. AuthRoleRevokePermissionResponse
  101. */
  102. package etcdserverpb
  103. import (
  104. "fmt"
  105. proto "github.com/golang/protobuf/proto"
  106. math "math"
  107. _ "github.com/gogo/protobuf/gogoproto"
  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 encodeVarintEtcdserver(dAtA []byte, offset int, v uint64) int {
  304. for v >= 1<<7 {
  305. dAtA[offset] = uint8(v&0x7f | 0x80)
  306. v >>= 7
  307. offset++
  308. }
  309. dAtA[offset] = uint8(v)
  310. return offset + 1
  311. }
  312. func (m *Request) Size() (n int) {
  313. var l int
  314. _ = l
  315. n += 1 + sovEtcdserver(uint64(m.ID))
  316. l = len(m.Method)
  317. n += 1 + l + sovEtcdserver(uint64(l))
  318. l = len(m.Path)
  319. n += 1 + l + sovEtcdserver(uint64(l))
  320. l = len(m.Val)
  321. n += 1 + l + sovEtcdserver(uint64(l))
  322. n += 2
  323. l = len(m.PrevValue)
  324. n += 1 + l + sovEtcdserver(uint64(l))
  325. n += 1 + sovEtcdserver(uint64(m.PrevIndex))
  326. if m.PrevExist != nil {
  327. n += 2
  328. }
  329. n += 1 + sovEtcdserver(uint64(m.Expiration))
  330. n += 2
  331. n += 1 + sovEtcdserver(uint64(m.Since))
  332. n += 2
  333. n += 2
  334. n += 2
  335. n += 1 + sovEtcdserver(uint64(m.Time))
  336. n += 3
  337. if m.Refresh != nil {
  338. n += 3
  339. }
  340. if m.XXX_unrecognized != nil {
  341. n += len(m.XXX_unrecognized)
  342. }
  343. return n
  344. }
  345. func (m *Metadata) Size() (n int) {
  346. var l int
  347. _ = l
  348. n += 1 + sovEtcdserver(uint64(m.NodeID))
  349. n += 1 + sovEtcdserver(uint64(m.ClusterID))
  350. if m.XXX_unrecognized != nil {
  351. n += len(m.XXX_unrecognized)
  352. }
  353. return n
  354. }
  355. func sovEtcdserver(x uint64) (n int) {
  356. for {
  357. n++
  358. x >>= 7
  359. if x == 0 {
  360. break
  361. }
  362. }
  363. return n
  364. }
  365. func sozEtcdserver(x uint64) (n int) {
  366. return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  367. }
  368. func (m *Request) Unmarshal(dAtA []byte) error {
  369. l := len(dAtA)
  370. iNdEx := 0
  371. for iNdEx < l {
  372. preIndex := iNdEx
  373. var wire uint64
  374. for shift := uint(0); ; shift += 7 {
  375. if shift >= 64 {
  376. return ErrIntOverflowEtcdserver
  377. }
  378. if iNdEx >= l {
  379. return io.ErrUnexpectedEOF
  380. }
  381. b := dAtA[iNdEx]
  382. iNdEx++
  383. wire |= (uint64(b) & 0x7F) << shift
  384. if b < 0x80 {
  385. break
  386. }
  387. }
  388. fieldNum := int32(wire >> 3)
  389. wireType := int(wire & 0x7)
  390. if wireType == 4 {
  391. return fmt.Errorf("proto: Request: wiretype end group for non-group")
  392. }
  393. if fieldNum <= 0 {
  394. return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
  395. }
  396. switch fieldNum {
  397. case 1:
  398. if wireType != 0 {
  399. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  400. }
  401. m.ID = 0
  402. for shift := uint(0); ; shift += 7 {
  403. if shift >= 64 {
  404. return ErrIntOverflowEtcdserver
  405. }
  406. if iNdEx >= l {
  407. return io.ErrUnexpectedEOF
  408. }
  409. b := dAtA[iNdEx]
  410. iNdEx++
  411. m.ID |= (uint64(b) & 0x7F) << shift
  412. if b < 0x80 {
  413. break
  414. }
  415. }
  416. case 2:
  417. if wireType != 2 {
  418. return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
  419. }
  420. var stringLen uint64
  421. for shift := uint(0); ; shift += 7 {
  422. if shift >= 64 {
  423. return ErrIntOverflowEtcdserver
  424. }
  425. if iNdEx >= l {
  426. return io.ErrUnexpectedEOF
  427. }
  428. b := dAtA[iNdEx]
  429. iNdEx++
  430. stringLen |= (uint64(b) & 0x7F) << shift
  431. if b < 0x80 {
  432. break
  433. }
  434. }
  435. intStringLen := int(stringLen)
  436. if intStringLen < 0 {
  437. return ErrInvalidLengthEtcdserver
  438. }
  439. postIndex := iNdEx + intStringLen
  440. if postIndex > l {
  441. return io.ErrUnexpectedEOF
  442. }
  443. m.Method = string(dAtA[iNdEx:postIndex])
  444. iNdEx = postIndex
  445. case 3:
  446. if wireType != 2 {
  447. return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
  448. }
  449. var stringLen uint64
  450. for shift := uint(0); ; shift += 7 {
  451. if shift >= 64 {
  452. return ErrIntOverflowEtcdserver
  453. }
  454. if iNdEx >= l {
  455. return io.ErrUnexpectedEOF
  456. }
  457. b := dAtA[iNdEx]
  458. iNdEx++
  459. stringLen |= (uint64(b) & 0x7F) << shift
  460. if b < 0x80 {
  461. break
  462. }
  463. }
  464. intStringLen := int(stringLen)
  465. if intStringLen < 0 {
  466. return ErrInvalidLengthEtcdserver
  467. }
  468. postIndex := iNdEx + intStringLen
  469. if postIndex > l {
  470. return io.ErrUnexpectedEOF
  471. }
  472. m.Path = string(dAtA[iNdEx:postIndex])
  473. iNdEx = postIndex
  474. case 4:
  475. if wireType != 2 {
  476. return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
  477. }
  478. var stringLen uint64
  479. for shift := uint(0); ; shift += 7 {
  480. if shift >= 64 {
  481. return ErrIntOverflowEtcdserver
  482. }
  483. if iNdEx >= l {
  484. return io.ErrUnexpectedEOF
  485. }
  486. b := dAtA[iNdEx]
  487. iNdEx++
  488. stringLen |= (uint64(b) & 0x7F) << shift
  489. if b < 0x80 {
  490. break
  491. }
  492. }
  493. intStringLen := int(stringLen)
  494. if intStringLen < 0 {
  495. return ErrInvalidLengthEtcdserver
  496. }
  497. postIndex := iNdEx + intStringLen
  498. if postIndex > l {
  499. return io.ErrUnexpectedEOF
  500. }
  501. m.Val = string(dAtA[iNdEx:postIndex])
  502. iNdEx = postIndex
  503. case 5:
  504. if wireType != 0 {
  505. return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
  506. }
  507. var v int
  508. for shift := uint(0); ; shift += 7 {
  509. if shift >= 64 {
  510. return ErrIntOverflowEtcdserver
  511. }
  512. if iNdEx >= l {
  513. return io.ErrUnexpectedEOF
  514. }
  515. b := dAtA[iNdEx]
  516. iNdEx++
  517. v |= (int(b) & 0x7F) << shift
  518. if b < 0x80 {
  519. break
  520. }
  521. }
  522. m.Dir = bool(v != 0)
  523. case 6:
  524. if wireType != 2 {
  525. return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
  526. }
  527. var stringLen uint64
  528. for shift := uint(0); ; shift += 7 {
  529. if shift >= 64 {
  530. return ErrIntOverflowEtcdserver
  531. }
  532. if iNdEx >= l {
  533. return io.ErrUnexpectedEOF
  534. }
  535. b := dAtA[iNdEx]
  536. iNdEx++
  537. stringLen |= (uint64(b) & 0x7F) << shift
  538. if b < 0x80 {
  539. break
  540. }
  541. }
  542. intStringLen := int(stringLen)
  543. if intStringLen < 0 {
  544. return ErrInvalidLengthEtcdserver
  545. }
  546. postIndex := iNdEx + intStringLen
  547. if postIndex > l {
  548. return io.ErrUnexpectedEOF
  549. }
  550. m.PrevValue = string(dAtA[iNdEx:postIndex])
  551. iNdEx = postIndex
  552. case 7:
  553. if wireType != 0 {
  554. return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
  555. }
  556. m.PrevIndex = 0
  557. for shift := uint(0); ; shift += 7 {
  558. if shift >= 64 {
  559. return ErrIntOverflowEtcdserver
  560. }
  561. if iNdEx >= l {
  562. return io.ErrUnexpectedEOF
  563. }
  564. b := dAtA[iNdEx]
  565. iNdEx++
  566. m.PrevIndex |= (uint64(b) & 0x7F) << shift
  567. if b < 0x80 {
  568. break
  569. }
  570. }
  571. case 8:
  572. if wireType != 0 {
  573. return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
  574. }
  575. var v int
  576. for shift := uint(0); ; shift += 7 {
  577. if shift >= 64 {
  578. return ErrIntOverflowEtcdserver
  579. }
  580. if iNdEx >= l {
  581. return io.ErrUnexpectedEOF
  582. }
  583. b := dAtA[iNdEx]
  584. iNdEx++
  585. v |= (int(b) & 0x7F) << shift
  586. if b < 0x80 {
  587. break
  588. }
  589. }
  590. b := bool(v != 0)
  591. m.PrevExist = &b
  592. case 9:
  593. if wireType != 0 {
  594. return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
  595. }
  596. m.Expiration = 0
  597. for shift := uint(0); ; shift += 7 {
  598. if shift >= 64 {
  599. return ErrIntOverflowEtcdserver
  600. }
  601. if iNdEx >= l {
  602. return io.ErrUnexpectedEOF
  603. }
  604. b := dAtA[iNdEx]
  605. iNdEx++
  606. m.Expiration |= (int64(b) & 0x7F) << shift
  607. if b < 0x80 {
  608. break
  609. }
  610. }
  611. case 10:
  612. if wireType != 0 {
  613. return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
  614. }
  615. var v int
  616. for shift := uint(0); ; shift += 7 {
  617. if shift >= 64 {
  618. return ErrIntOverflowEtcdserver
  619. }
  620. if iNdEx >= l {
  621. return io.ErrUnexpectedEOF
  622. }
  623. b := dAtA[iNdEx]
  624. iNdEx++
  625. v |= (int(b) & 0x7F) << shift
  626. if b < 0x80 {
  627. break
  628. }
  629. }
  630. m.Wait = bool(v != 0)
  631. case 11:
  632. if wireType != 0 {
  633. return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
  634. }
  635. m.Since = 0
  636. for shift := uint(0); ; shift += 7 {
  637. if shift >= 64 {
  638. return ErrIntOverflowEtcdserver
  639. }
  640. if iNdEx >= l {
  641. return io.ErrUnexpectedEOF
  642. }
  643. b := dAtA[iNdEx]
  644. iNdEx++
  645. m.Since |= (uint64(b) & 0x7F) << shift
  646. if b < 0x80 {
  647. break
  648. }
  649. }
  650. case 12:
  651. if wireType != 0 {
  652. return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
  653. }
  654. var v int
  655. for shift := uint(0); ; shift += 7 {
  656. if shift >= 64 {
  657. return ErrIntOverflowEtcdserver
  658. }
  659. if iNdEx >= l {
  660. return io.ErrUnexpectedEOF
  661. }
  662. b := dAtA[iNdEx]
  663. iNdEx++
  664. v |= (int(b) & 0x7F) << shift
  665. if b < 0x80 {
  666. break
  667. }
  668. }
  669. m.Recursive = bool(v != 0)
  670. case 13:
  671. if wireType != 0 {
  672. return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
  673. }
  674. var v int
  675. for shift := uint(0); ; shift += 7 {
  676. if shift >= 64 {
  677. return ErrIntOverflowEtcdserver
  678. }
  679. if iNdEx >= l {
  680. return io.ErrUnexpectedEOF
  681. }
  682. b := dAtA[iNdEx]
  683. iNdEx++
  684. v |= (int(b) & 0x7F) << shift
  685. if b < 0x80 {
  686. break
  687. }
  688. }
  689. m.Sorted = bool(v != 0)
  690. case 14:
  691. if wireType != 0 {
  692. return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
  693. }
  694. var v int
  695. for shift := uint(0); ; shift += 7 {
  696. if shift >= 64 {
  697. return ErrIntOverflowEtcdserver
  698. }
  699. if iNdEx >= l {
  700. return io.ErrUnexpectedEOF
  701. }
  702. b := dAtA[iNdEx]
  703. iNdEx++
  704. v |= (int(b) & 0x7F) << shift
  705. if b < 0x80 {
  706. break
  707. }
  708. }
  709. m.Quorum = bool(v != 0)
  710. case 15:
  711. if wireType != 0 {
  712. return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
  713. }
  714. m.Time = 0
  715. for shift := uint(0); ; shift += 7 {
  716. if shift >= 64 {
  717. return ErrIntOverflowEtcdserver
  718. }
  719. if iNdEx >= l {
  720. return io.ErrUnexpectedEOF
  721. }
  722. b := dAtA[iNdEx]
  723. iNdEx++
  724. m.Time |= (int64(b) & 0x7F) << shift
  725. if b < 0x80 {
  726. break
  727. }
  728. }
  729. case 16:
  730. if wireType != 0 {
  731. return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
  732. }
  733. var v int
  734. for shift := uint(0); ; shift += 7 {
  735. if shift >= 64 {
  736. return ErrIntOverflowEtcdserver
  737. }
  738. if iNdEx >= l {
  739. return io.ErrUnexpectedEOF
  740. }
  741. b := dAtA[iNdEx]
  742. iNdEx++
  743. v |= (int(b) & 0x7F) << shift
  744. if b < 0x80 {
  745. break
  746. }
  747. }
  748. m.Stream = bool(v != 0)
  749. case 17:
  750. if wireType != 0 {
  751. return fmt.Errorf("proto: wrong wireType = %d for field Refresh", wireType)
  752. }
  753. var v int
  754. for shift := uint(0); ; shift += 7 {
  755. if shift >= 64 {
  756. return ErrIntOverflowEtcdserver
  757. }
  758. if iNdEx >= l {
  759. return io.ErrUnexpectedEOF
  760. }
  761. b := dAtA[iNdEx]
  762. iNdEx++
  763. v |= (int(b) & 0x7F) << shift
  764. if b < 0x80 {
  765. break
  766. }
  767. }
  768. b := bool(v != 0)
  769. m.Refresh = &b
  770. default:
  771. iNdEx = preIndex
  772. skippy, err := skipEtcdserver(dAtA[iNdEx:])
  773. if err != nil {
  774. return err
  775. }
  776. if skippy < 0 {
  777. return ErrInvalidLengthEtcdserver
  778. }
  779. if (iNdEx + skippy) > l {
  780. return io.ErrUnexpectedEOF
  781. }
  782. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  783. iNdEx += skippy
  784. }
  785. }
  786. if iNdEx > l {
  787. return io.ErrUnexpectedEOF
  788. }
  789. return nil
  790. }
  791. func (m *Metadata) Unmarshal(dAtA []byte) error {
  792. l := len(dAtA)
  793. iNdEx := 0
  794. for iNdEx < l {
  795. preIndex := iNdEx
  796. var wire uint64
  797. for shift := uint(0); ; shift += 7 {
  798. if shift >= 64 {
  799. return ErrIntOverflowEtcdserver
  800. }
  801. if iNdEx >= l {
  802. return io.ErrUnexpectedEOF
  803. }
  804. b := dAtA[iNdEx]
  805. iNdEx++
  806. wire |= (uint64(b) & 0x7F) << shift
  807. if b < 0x80 {
  808. break
  809. }
  810. }
  811. fieldNum := int32(wire >> 3)
  812. wireType := int(wire & 0x7)
  813. if wireType == 4 {
  814. return fmt.Errorf("proto: Metadata: wiretype end group for non-group")
  815. }
  816. if fieldNum <= 0 {
  817. return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire)
  818. }
  819. switch fieldNum {
  820. case 1:
  821. if wireType != 0 {
  822. return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
  823. }
  824. m.NodeID = 0
  825. for shift := uint(0); ; shift += 7 {
  826. if shift >= 64 {
  827. return ErrIntOverflowEtcdserver
  828. }
  829. if iNdEx >= l {
  830. return io.ErrUnexpectedEOF
  831. }
  832. b := dAtA[iNdEx]
  833. iNdEx++
  834. m.NodeID |= (uint64(b) & 0x7F) << shift
  835. if b < 0x80 {
  836. break
  837. }
  838. }
  839. case 2:
  840. if wireType != 0 {
  841. return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
  842. }
  843. m.ClusterID = 0
  844. for shift := uint(0); ; shift += 7 {
  845. if shift >= 64 {
  846. return ErrIntOverflowEtcdserver
  847. }
  848. if iNdEx >= l {
  849. return io.ErrUnexpectedEOF
  850. }
  851. b := dAtA[iNdEx]
  852. iNdEx++
  853. m.ClusterID |= (uint64(b) & 0x7F) << shift
  854. if b < 0x80 {
  855. break
  856. }
  857. }
  858. default:
  859. iNdEx = preIndex
  860. skippy, err := skipEtcdserver(dAtA[iNdEx:])
  861. if err != nil {
  862. return err
  863. }
  864. if skippy < 0 {
  865. return ErrInvalidLengthEtcdserver
  866. }
  867. if (iNdEx + skippy) > l {
  868. return io.ErrUnexpectedEOF
  869. }
  870. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  871. iNdEx += skippy
  872. }
  873. }
  874. if iNdEx > l {
  875. return io.ErrUnexpectedEOF
  876. }
  877. return nil
  878. }
  879. func skipEtcdserver(dAtA []byte) (n int, err error) {
  880. l := len(dAtA)
  881. iNdEx := 0
  882. for iNdEx < l {
  883. var wire uint64
  884. for shift := uint(0); ; shift += 7 {
  885. if shift >= 64 {
  886. return 0, ErrIntOverflowEtcdserver
  887. }
  888. if iNdEx >= l {
  889. return 0, io.ErrUnexpectedEOF
  890. }
  891. b := dAtA[iNdEx]
  892. iNdEx++
  893. wire |= (uint64(b) & 0x7F) << shift
  894. if b < 0x80 {
  895. break
  896. }
  897. }
  898. wireType := int(wire & 0x7)
  899. switch wireType {
  900. case 0:
  901. for shift := uint(0); ; shift += 7 {
  902. if shift >= 64 {
  903. return 0, ErrIntOverflowEtcdserver
  904. }
  905. if iNdEx >= l {
  906. return 0, io.ErrUnexpectedEOF
  907. }
  908. iNdEx++
  909. if dAtA[iNdEx-1] < 0x80 {
  910. break
  911. }
  912. }
  913. return iNdEx, nil
  914. case 1:
  915. iNdEx += 8
  916. return iNdEx, nil
  917. case 2:
  918. var length int
  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. b := dAtA[iNdEx]
  927. iNdEx++
  928. length |= (int(b) & 0x7F) << shift
  929. if b < 0x80 {
  930. break
  931. }
  932. }
  933. iNdEx += length
  934. if length < 0 {
  935. return 0, ErrInvalidLengthEtcdserver
  936. }
  937. return iNdEx, nil
  938. case 3:
  939. for {
  940. var innerWire uint64
  941. var start int = iNdEx
  942. for shift := uint(0); ; shift += 7 {
  943. if shift >= 64 {
  944. return 0, ErrIntOverflowEtcdserver
  945. }
  946. if iNdEx >= l {
  947. return 0, io.ErrUnexpectedEOF
  948. }
  949. b := dAtA[iNdEx]
  950. iNdEx++
  951. innerWire |= (uint64(b) & 0x7F) << shift
  952. if b < 0x80 {
  953. break
  954. }
  955. }
  956. innerWireType := int(innerWire & 0x7)
  957. if innerWireType == 4 {
  958. break
  959. }
  960. next, err := skipEtcdserver(dAtA[start:])
  961. if err != nil {
  962. return 0, err
  963. }
  964. iNdEx = start + next
  965. }
  966. return iNdEx, nil
  967. case 4:
  968. return iNdEx, nil
  969. case 5:
  970. iNdEx += 4
  971. return iNdEx, nil
  972. default:
  973. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  974. }
  975. }
  976. panic("unreachable")
  977. }
  978. var (
  979. ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
  980. ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow")
  981. )
  982. func init() { proto.RegisterFile("etcdserver.proto", fileDescriptorEtcdserver) }
  983. var fileDescriptorEtcdserver = []byte{
  984. // 380 bytes of a gzipped FileDescriptorProto
  985. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0xd2, 0xdd, 0x6e, 0xda, 0x30,
  986. 0x14, 0x07, 0x70, 0x0c, 0xe1, 0xcb, 0x63, 0x1b, 0xb3, 0xd0, 0x74, 0x84, 0xa6, 0x2c, 0x42, 0xbb,
  987. 0xc8, 0xd5, 0xf6, 0x0e, 0x2c, 0x5c, 0x44, 0x2a, 0x15, 0x0d, 0x15, 0xbd, 0x76, 0xc9, 0x29, 0x58,
  988. 0x02, 0x4c, 0x1d, 0x07, 0xf1, 0x06, 0x7d, 0x85, 0x3e, 0x12, 0x97, 0x7d, 0x82, 0xaa, 0xa5, 0x2f,
  989. 0x52, 0x39, 0x24, 0xc4, 0xed, 0x5d, 0xf4, 0xfb, 0x9f, 0x1c, 0x1f, 0x7f, 0xd0, 0x2e, 0xea, 0x79,
  990. 0x9c, 0xa0, 0xda, 0xa1, 0xfa, 0xbb, 0x55, 0x52, 0x4b, 0xd6, 0x29, 0x65, 0x7b, 0xdb, 0xef, 0x2d,
  991. 0xe4, 0x42, 0x66, 0xc1, 0x3f, 0xf3, 0x75, 0xaa, 0x19, 0x3c, 0x38, 0xb4, 0x19, 0xe1, 0x7d, 0x8a,
  992. 0x89, 0x66, 0x3d, 0x5a, 0x0d, 0x03, 0x20, 0x1e, 0xf1, 0x9d, 0xa1, 0x73, 0x78, 0xfe, 0x5d, 0x89,
  993. 0xaa, 0x61, 0xc0, 0x7e, 0xd1, 0xc6, 0x18, 0xf5, 0x52, 0xc6, 0x50, 0xf5, 0x88, 0xdf, 0xce, 0x93,
  994. 0xdc, 0x18, 0x50, 0x67, 0xc2, 0xf5, 0x12, 0x6a, 0x56, 0x96, 0x09, 0xfb, 0x49, 0x6b, 0x33, 0xbe,
  995. 0x02, 0xc7, 0x0a, 0x0c, 0x18, 0x0f, 0x84, 0x82, 0xba, 0x47, 0xfc, 0x56, 0xe1, 0x81, 0x50, 0x6c,
  996. 0x40, 0xdb, 0x13, 0x85, 0xbb, 0x19, 0x5f, 0xa5, 0x08, 0x0d, 0xeb, 0xaf, 0x92, 0x8b, 0x9a, 0x70,
  997. 0x13, 0xe3, 0x1e, 0x9a, 0xd6, 0xa0, 0x25, 0x17, 0x35, 0xa3, 0xbd, 0x48, 0x34, 0xb4, 0xce, 0xab,
  998. 0x90, 0xa8, 0x64, 0xf6, 0x87, 0xd2, 0xd1, 0x7e, 0x2b, 0x14, 0xd7, 0x42, 0x6e, 0xa0, 0xed, 0x11,
  999. 0xbf, 0x96, 0x37, 0xb2, 0xdc, 0xec, 0xed, 0x86, 0x0b, 0x0d, 0xd4, 0x1a, 0x35, 0x13, 0xd6, 0xa7,
  1000. 0xf5, 0xa9, 0xd8, 0xcc, 0x11, 0xbe, 0x58, 0x33, 0x9c, 0xc8, 0xac, 0x1f, 0xe1, 0x3c, 0x55, 0x89,
  1001. 0xd8, 0x21, 0x74, 0xac, 0x5f, 0x4b, 0x36, 0x67, 0x3a, 0x95, 0x4a, 0x63, 0x0c, 0x5f, 0xad, 0x82,
  1002. 0xdc, 0x4c, 0x7a, 0x95, 0x4a, 0x95, 0xae, 0xe1, 0x9b, 0x9d, 0x9e, 0xcc, 0x4c, 0x75, 0x2d, 0xd6,
  1003. 0x08, 0xdf, 0xad, 0xa9, 0x33, 0xc9, 0xba, 0x6a, 0x85, 0x7c, 0x0d, 0xdd, 0x0f, 0x5d, 0x33, 0x63,
  1004. 0xae, 0xb9, 0xe8, 0x3b, 0x85, 0xc9, 0x12, 0x7e, 0x58, 0xa7, 0x52, 0xe0, 0xe0, 0x82, 0xb6, 0xc6,
  1005. 0xa8, 0x79, 0xcc, 0x35, 0x37, 0x9d, 0x2e, 0x65, 0x8c, 0x9f, 0x5e, 0x43, 0x6e, 0x66, 0x87, 0xff,
  1006. 0x57, 0x69, 0xa2, 0x51, 0x85, 0x41, 0xf6, 0x28, 0xce, 0xb7, 0x70, 0xe6, 0x61, 0xef, 0xf0, 0xea,
  1007. 0x56, 0x0e, 0x47, 0x97, 0x3c, 0x1d, 0x5d, 0xf2, 0x72, 0x74, 0xc9, 0xe3, 0x9b, 0x5b, 0x79, 0x0f,
  1008. 0x00, 0x00, 0xff, 0xff, 0xee, 0x40, 0xba, 0xd6, 0xa4, 0x02, 0x00, 0x00,
  1009. }