etcdserver.pb.go 25 KB

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