etcdserver.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992
  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. InternalRaftRequest
  14. EmptyResponse
  15. ResponseHeader
  16. RangeRequest
  17. RangeResponse
  18. PutRequest
  19. PutResponse
  20. DeleteRangeRequest
  21. DeleteRangeResponse
  22. RequestUnion
  23. ResponseUnion
  24. Compare
  25. TxnRequest
  26. TxnResponse
  27. CompactionRequest
  28. CompactionResponse
  29. HashRequest
  30. HashResponse
  31. WatchRequest
  32. WatchCreateRequest
  33. WatchCancelRequest
  34. WatchResponse
  35. LeaseCreateRequest
  36. LeaseCreateResponse
  37. LeaseRevokeRequest
  38. LeaseRevokeResponse
  39. LeaseKeepAliveRequest
  40. LeaseKeepAliveResponse
  41. Member
  42. MemberAddRequest
  43. MemberAddResponse
  44. MemberRemoveRequest
  45. MemberRemoveResponse
  46. MemberUpdateRequest
  47. MemberUpdateResponse
  48. MemberListRequest
  49. MemberListResponse
  50. DefragmentRequest
  51. DefragmentResponse
  52. AuthEnableRequest
  53. AuthDisableRequest
  54. AuthenticateRequest
  55. UserAddRequest
  56. UserGetRequest
  57. UserDeleteRequest
  58. UserChangePasswordRequest
  59. UserGrantRequest
  60. UserRevokeRequest
  61. RoleAddRequest
  62. RoleGetRequest
  63. RoleDeleteRequest
  64. RoleGrantRequest
  65. RoleRevokeRequest
  66. AuthEnableResponse
  67. AuthDisableResponse
  68. AuthenticateResponse
  69. UserAddResponse
  70. UserGetResponse
  71. UserDeleteResponse
  72. UserChangePasswordResponse
  73. UserGrantResponse
  74. UserRevokeResponse
  75. RoleAddResponse
  76. RoleGetResponse
  77. RoleDeleteResponse
  78. RoleGrantResponse
  79. RoleRevokeResponse
  80. */
  81. package etcdserverpb
  82. import (
  83. "fmt"
  84. proto "github.com/coreos/etcd/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
  85. )
  86. import math "math"
  87. import io "io"
  88. // Reference imports to suppress errors if they are not otherwise used.
  89. var _ = proto.Marshal
  90. var _ = fmt.Errorf
  91. var _ = math.Inf
  92. type Request struct {
  93. ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID"`
  94. Method string `protobuf:"bytes,2,opt,name=Method" json:"Method"`
  95. Path string `protobuf:"bytes,3,opt,name=Path" json:"Path"`
  96. Val string `protobuf:"bytes,4,opt,name=Val" json:"Val"`
  97. Dir bool `protobuf:"varint,5,opt,name=Dir" json:"Dir"`
  98. PrevValue string `protobuf:"bytes,6,opt,name=PrevValue" json:"PrevValue"`
  99. PrevIndex uint64 `protobuf:"varint,7,opt,name=PrevIndex" json:"PrevIndex"`
  100. PrevExist *bool `protobuf:"varint,8,opt,name=PrevExist" json:"PrevExist,omitempty"`
  101. Expiration int64 `protobuf:"varint,9,opt,name=Expiration" json:"Expiration"`
  102. Wait bool `protobuf:"varint,10,opt,name=Wait" json:"Wait"`
  103. Since uint64 `protobuf:"varint,11,opt,name=Since" json:"Since"`
  104. Recursive bool `protobuf:"varint,12,opt,name=Recursive" json:"Recursive"`
  105. Sorted bool `protobuf:"varint,13,opt,name=Sorted" json:"Sorted"`
  106. Quorum bool `protobuf:"varint,14,opt,name=Quorum" json:"Quorum"`
  107. Time int64 `protobuf:"varint,15,opt,name=Time" json:"Time"`
  108. Stream bool `protobuf:"varint,16,opt,name=Stream" json:"Stream"`
  109. Refresh *bool `protobuf:"varint,17,opt,name=Refresh" json:"Refresh,omitempty"`
  110. XXX_unrecognized []byte `json:"-"`
  111. }
  112. func (m *Request) Reset() { *m = Request{} }
  113. func (m *Request) String() string { return proto.CompactTextString(m) }
  114. func (*Request) ProtoMessage() {}
  115. type Metadata struct {
  116. NodeID uint64 `protobuf:"varint,1,opt,name=NodeID" json:"NodeID"`
  117. ClusterID uint64 `protobuf:"varint,2,opt,name=ClusterID" json:"ClusterID"`
  118. XXX_unrecognized []byte `json:"-"`
  119. }
  120. func (m *Metadata) Reset() { *m = Metadata{} }
  121. func (m *Metadata) String() string { return proto.CompactTextString(m) }
  122. func (*Metadata) ProtoMessage() {}
  123. func init() {
  124. proto.RegisterType((*Request)(nil), "etcdserverpb.Request")
  125. proto.RegisterType((*Metadata)(nil), "etcdserverpb.Metadata")
  126. }
  127. func (m *Request) Marshal() (data []byte, err error) {
  128. size := m.Size()
  129. data = make([]byte, size)
  130. n, err := m.MarshalTo(data)
  131. if err != nil {
  132. return nil, err
  133. }
  134. return data[:n], nil
  135. }
  136. func (m *Request) MarshalTo(data []byte) (int, error) {
  137. var i int
  138. _ = i
  139. var l int
  140. _ = l
  141. data[i] = 0x8
  142. i++
  143. i = encodeVarintEtcdserver(data, i, uint64(m.ID))
  144. data[i] = 0x12
  145. i++
  146. i = encodeVarintEtcdserver(data, i, uint64(len(m.Method)))
  147. i += copy(data[i:], m.Method)
  148. data[i] = 0x1a
  149. i++
  150. i = encodeVarintEtcdserver(data, i, uint64(len(m.Path)))
  151. i += copy(data[i:], m.Path)
  152. data[i] = 0x22
  153. i++
  154. i = encodeVarintEtcdserver(data, i, uint64(len(m.Val)))
  155. i += copy(data[i:], m.Val)
  156. data[i] = 0x28
  157. i++
  158. if m.Dir {
  159. data[i] = 1
  160. } else {
  161. data[i] = 0
  162. }
  163. i++
  164. data[i] = 0x32
  165. i++
  166. i = encodeVarintEtcdserver(data, i, uint64(len(m.PrevValue)))
  167. i += copy(data[i:], m.PrevValue)
  168. data[i] = 0x38
  169. i++
  170. i = encodeVarintEtcdserver(data, i, uint64(m.PrevIndex))
  171. if m.PrevExist != nil {
  172. data[i] = 0x40
  173. i++
  174. if *m.PrevExist {
  175. data[i] = 1
  176. } else {
  177. data[i] = 0
  178. }
  179. i++
  180. }
  181. data[i] = 0x48
  182. i++
  183. i = encodeVarintEtcdserver(data, i, uint64(m.Expiration))
  184. data[i] = 0x50
  185. i++
  186. if m.Wait {
  187. data[i] = 1
  188. } else {
  189. data[i] = 0
  190. }
  191. i++
  192. data[i] = 0x58
  193. i++
  194. i = encodeVarintEtcdserver(data, i, uint64(m.Since))
  195. data[i] = 0x60
  196. i++
  197. if m.Recursive {
  198. data[i] = 1
  199. } else {
  200. data[i] = 0
  201. }
  202. i++
  203. data[i] = 0x68
  204. i++
  205. if m.Sorted {
  206. data[i] = 1
  207. } else {
  208. data[i] = 0
  209. }
  210. i++
  211. data[i] = 0x70
  212. i++
  213. if m.Quorum {
  214. data[i] = 1
  215. } else {
  216. data[i] = 0
  217. }
  218. i++
  219. data[i] = 0x78
  220. i++
  221. i = encodeVarintEtcdserver(data, i, uint64(m.Time))
  222. data[i] = 0x80
  223. i++
  224. data[i] = 0x1
  225. i++
  226. if m.Stream {
  227. data[i] = 1
  228. } else {
  229. data[i] = 0
  230. }
  231. i++
  232. if m.Refresh != nil {
  233. data[i] = 0x88
  234. i++
  235. data[i] = 0x1
  236. i++
  237. if *m.Refresh {
  238. data[i] = 1
  239. } else {
  240. data[i] = 0
  241. }
  242. i++
  243. }
  244. if m.XXX_unrecognized != nil {
  245. i += copy(data[i:], m.XXX_unrecognized)
  246. }
  247. return i, nil
  248. }
  249. func (m *Metadata) Marshal() (data []byte, err error) {
  250. size := m.Size()
  251. data = make([]byte, size)
  252. n, err := m.MarshalTo(data)
  253. if err != nil {
  254. return nil, err
  255. }
  256. return data[:n], nil
  257. }
  258. func (m *Metadata) MarshalTo(data []byte) (int, error) {
  259. var i int
  260. _ = i
  261. var l int
  262. _ = l
  263. data[i] = 0x8
  264. i++
  265. i = encodeVarintEtcdserver(data, i, uint64(m.NodeID))
  266. data[i] = 0x10
  267. i++
  268. i = encodeVarintEtcdserver(data, i, uint64(m.ClusterID))
  269. if m.XXX_unrecognized != nil {
  270. i += copy(data[i:], m.XXX_unrecognized)
  271. }
  272. return i, nil
  273. }
  274. func encodeFixed64Etcdserver(data []byte, offset int, v uint64) int {
  275. data[offset] = uint8(v)
  276. data[offset+1] = uint8(v >> 8)
  277. data[offset+2] = uint8(v >> 16)
  278. data[offset+3] = uint8(v >> 24)
  279. data[offset+4] = uint8(v >> 32)
  280. data[offset+5] = uint8(v >> 40)
  281. data[offset+6] = uint8(v >> 48)
  282. data[offset+7] = uint8(v >> 56)
  283. return offset + 8
  284. }
  285. func encodeFixed32Etcdserver(data []byte, offset int, v uint32) int {
  286. data[offset] = uint8(v)
  287. data[offset+1] = uint8(v >> 8)
  288. data[offset+2] = uint8(v >> 16)
  289. data[offset+3] = uint8(v >> 24)
  290. return offset + 4
  291. }
  292. func encodeVarintEtcdserver(data []byte, offset int, v uint64) int {
  293. for v >= 1<<7 {
  294. data[offset] = uint8(v&0x7f | 0x80)
  295. v >>= 7
  296. offset++
  297. }
  298. data[offset] = uint8(v)
  299. return offset + 1
  300. }
  301. func (m *Request) Size() (n int) {
  302. var l int
  303. _ = l
  304. n += 1 + sovEtcdserver(uint64(m.ID))
  305. l = len(m.Method)
  306. n += 1 + l + sovEtcdserver(uint64(l))
  307. l = len(m.Path)
  308. n += 1 + l + sovEtcdserver(uint64(l))
  309. l = len(m.Val)
  310. n += 1 + l + sovEtcdserver(uint64(l))
  311. n += 2
  312. l = len(m.PrevValue)
  313. n += 1 + l + sovEtcdserver(uint64(l))
  314. n += 1 + sovEtcdserver(uint64(m.PrevIndex))
  315. if m.PrevExist != nil {
  316. n += 2
  317. }
  318. n += 1 + sovEtcdserver(uint64(m.Expiration))
  319. n += 2
  320. n += 1 + sovEtcdserver(uint64(m.Since))
  321. n += 2
  322. n += 2
  323. n += 2
  324. n += 1 + sovEtcdserver(uint64(m.Time))
  325. n += 3
  326. if m.Refresh != nil {
  327. n += 3
  328. }
  329. if m.XXX_unrecognized != nil {
  330. n += len(m.XXX_unrecognized)
  331. }
  332. return n
  333. }
  334. func (m *Metadata) Size() (n int) {
  335. var l int
  336. _ = l
  337. n += 1 + sovEtcdserver(uint64(m.NodeID))
  338. n += 1 + sovEtcdserver(uint64(m.ClusterID))
  339. if m.XXX_unrecognized != nil {
  340. n += len(m.XXX_unrecognized)
  341. }
  342. return n
  343. }
  344. func sovEtcdserver(x uint64) (n int) {
  345. for {
  346. n++
  347. x >>= 7
  348. if x == 0 {
  349. break
  350. }
  351. }
  352. return n
  353. }
  354. func sozEtcdserver(x uint64) (n int) {
  355. return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  356. }
  357. func (m *Request) Unmarshal(data []byte) error {
  358. l := len(data)
  359. iNdEx := 0
  360. for iNdEx < l {
  361. preIndex := iNdEx
  362. var wire uint64
  363. for shift := uint(0); ; shift += 7 {
  364. if shift >= 64 {
  365. return ErrIntOverflowEtcdserver
  366. }
  367. if iNdEx >= l {
  368. return io.ErrUnexpectedEOF
  369. }
  370. b := data[iNdEx]
  371. iNdEx++
  372. wire |= (uint64(b) & 0x7F) << shift
  373. if b < 0x80 {
  374. break
  375. }
  376. }
  377. fieldNum := int32(wire >> 3)
  378. wireType := int(wire & 0x7)
  379. if wireType == 4 {
  380. return fmt.Errorf("proto: Request: wiretype end group for non-group")
  381. }
  382. if fieldNum <= 0 {
  383. return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
  384. }
  385. switch fieldNum {
  386. case 1:
  387. if wireType != 0 {
  388. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  389. }
  390. m.ID = 0
  391. for shift := uint(0); ; shift += 7 {
  392. if shift >= 64 {
  393. return ErrIntOverflowEtcdserver
  394. }
  395. if iNdEx >= l {
  396. return io.ErrUnexpectedEOF
  397. }
  398. b := data[iNdEx]
  399. iNdEx++
  400. m.ID |= (uint64(b) & 0x7F) << shift
  401. if b < 0x80 {
  402. break
  403. }
  404. }
  405. case 2:
  406. if wireType != 2 {
  407. return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
  408. }
  409. var stringLen uint64
  410. for shift := uint(0); ; shift += 7 {
  411. if shift >= 64 {
  412. return ErrIntOverflowEtcdserver
  413. }
  414. if iNdEx >= l {
  415. return io.ErrUnexpectedEOF
  416. }
  417. b := data[iNdEx]
  418. iNdEx++
  419. stringLen |= (uint64(b) & 0x7F) << shift
  420. if b < 0x80 {
  421. break
  422. }
  423. }
  424. intStringLen := int(stringLen)
  425. if intStringLen < 0 {
  426. return ErrInvalidLengthEtcdserver
  427. }
  428. postIndex := iNdEx + intStringLen
  429. if postIndex > l {
  430. return io.ErrUnexpectedEOF
  431. }
  432. m.Method = string(data[iNdEx:postIndex])
  433. iNdEx = postIndex
  434. case 3:
  435. if wireType != 2 {
  436. return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
  437. }
  438. var stringLen uint64
  439. for shift := uint(0); ; shift += 7 {
  440. if shift >= 64 {
  441. return ErrIntOverflowEtcdserver
  442. }
  443. if iNdEx >= l {
  444. return io.ErrUnexpectedEOF
  445. }
  446. b := data[iNdEx]
  447. iNdEx++
  448. stringLen |= (uint64(b) & 0x7F) << shift
  449. if b < 0x80 {
  450. break
  451. }
  452. }
  453. intStringLen := int(stringLen)
  454. if intStringLen < 0 {
  455. return ErrInvalidLengthEtcdserver
  456. }
  457. postIndex := iNdEx + intStringLen
  458. if postIndex > l {
  459. return io.ErrUnexpectedEOF
  460. }
  461. m.Path = string(data[iNdEx:postIndex])
  462. iNdEx = postIndex
  463. case 4:
  464. if wireType != 2 {
  465. return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
  466. }
  467. var stringLen uint64
  468. for shift := uint(0); ; shift += 7 {
  469. if shift >= 64 {
  470. return ErrIntOverflowEtcdserver
  471. }
  472. if iNdEx >= l {
  473. return io.ErrUnexpectedEOF
  474. }
  475. b := data[iNdEx]
  476. iNdEx++
  477. stringLen |= (uint64(b) & 0x7F) << shift
  478. if b < 0x80 {
  479. break
  480. }
  481. }
  482. intStringLen := int(stringLen)
  483. if intStringLen < 0 {
  484. return ErrInvalidLengthEtcdserver
  485. }
  486. postIndex := iNdEx + intStringLen
  487. if postIndex > l {
  488. return io.ErrUnexpectedEOF
  489. }
  490. m.Val = string(data[iNdEx:postIndex])
  491. iNdEx = postIndex
  492. case 5:
  493. if wireType != 0 {
  494. return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
  495. }
  496. var v int
  497. for shift := uint(0); ; shift += 7 {
  498. if shift >= 64 {
  499. return ErrIntOverflowEtcdserver
  500. }
  501. if iNdEx >= l {
  502. return io.ErrUnexpectedEOF
  503. }
  504. b := data[iNdEx]
  505. iNdEx++
  506. v |= (int(b) & 0x7F) << shift
  507. if b < 0x80 {
  508. break
  509. }
  510. }
  511. m.Dir = bool(v != 0)
  512. case 6:
  513. if wireType != 2 {
  514. return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
  515. }
  516. var stringLen uint64
  517. for shift := uint(0); ; shift += 7 {
  518. if shift >= 64 {
  519. return ErrIntOverflowEtcdserver
  520. }
  521. if iNdEx >= l {
  522. return io.ErrUnexpectedEOF
  523. }
  524. b := data[iNdEx]
  525. iNdEx++
  526. stringLen |= (uint64(b) & 0x7F) << shift
  527. if b < 0x80 {
  528. break
  529. }
  530. }
  531. intStringLen := int(stringLen)
  532. if intStringLen < 0 {
  533. return ErrInvalidLengthEtcdserver
  534. }
  535. postIndex := iNdEx + intStringLen
  536. if postIndex > l {
  537. return io.ErrUnexpectedEOF
  538. }
  539. m.PrevValue = string(data[iNdEx:postIndex])
  540. iNdEx = postIndex
  541. case 7:
  542. if wireType != 0 {
  543. return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
  544. }
  545. m.PrevIndex = 0
  546. for shift := uint(0); ; shift += 7 {
  547. if shift >= 64 {
  548. return ErrIntOverflowEtcdserver
  549. }
  550. if iNdEx >= l {
  551. return io.ErrUnexpectedEOF
  552. }
  553. b := data[iNdEx]
  554. iNdEx++
  555. m.PrevIndex |= (uint64(b) & 0x7F) << shift
  556. if b < 0x80 {
  557. break
  558. }
  559. }
  560. case 8:
  561. if wireType != 0 {
  562. return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
  563. }
  564. var v int
  565. for shift := uint(0); ; shift += 7 {
  566. if shift >= 64 {
  567. return ErrIntOverflowEtcdserver
  568. }
  569. if iNdEx >= l {
  570. return io.ErrUnexpectedEOF
  571. }
  572. b := data[iNdEx]
  573. iNdEx++
  574. v |= (int(b) & 0x7F) << shift
  575. if b < 0x80 {
  576. break
  577. }
  578. }
  579. b := bool(v != 0)
  580. m.PrevExist = &b
  581. case 9:
  582. if wireType != 0 {
  583. return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
  584. }
  585. m.Expiration = 0
  586. for shift := uint(0); ; shift += 7 {
  587. if shift >= 64 {
  588. return ErrIntOverflowEtcdserver
  589. }
  590. if iNdEx >= l {
  591. return io.ErrUnexpectedEOF
  592. }
  593. b := data[iNdEx]
  594. iNdEx++
  595. m.Expiration |= (int64(b) & 0x7F) << shift
  596. if b < 0x80 {
  597. break
  598. }
  599. }
  600. case 10:
  601. if wireType != 0 {
  602. return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
  603. }
  604. var v int
  605. for shift := uint(0); ; shift += 7 {
  606. if shift >= 64 {
  607. return ErrIntOverflowEtcdserver
  608. }
  609. if iNdEx >= l {
  610. return io.ErrUnexpectedEOF
  611. }
  612. b := data[iNdEx]
  613. iNdEx++
  614. v |= (int(b) & 0x7F) << shift
  615. if b < 0x80 {
  616. break
  617. }
  618. }
  619. m.Wait = bool(v != 0)
  620. case 11:
  621. if wireType != 0 {
  622. return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
  623. }
  624. m.Since = 0
  625. for shift := uint(0); ; shift += 7 {
  626. if shift >= 64 {
  627. return ErrIntOverflowEtcdserver
  628. }
  629. if iNdEx >= l {
  630. return io.ErrUnexpectedEOF
  631. }
  632. b := data[iNdEx]
  633. iNdEx++
  634. m.Since |= (uint64(b) & 0x7F) << shift
  635. if b < 0x80 {
  636. break
  637. }
  638. }
  639. case 12:
  640. if wireType != 0 {
  641. return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
  642. }
  643. var v int
  644. for shift := uint(0); ; shift += 7 {
  645. if shift >= 64 {
  646. return ErrIntOverflowEtcdserver
  647. }
  648. if iNdEx >= l {
  649. return io.ErrUnexpectedEOF
  650. }
  651. b := data[iNdEx]
  652. iNdEx++
  653. v |= (int(b) & 0x7F) << shift
  654. if b < 0x80 {
  655. break
  656. }
  657. }
  658. m.Recursive = bool(v != 0)
  659. case 13:
  660. if wireType != 0 {
  661. return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
  662. }
  663. var v int
  664. for shift := uint(0); ; shift += 7 {
  665. if shift >= 64 {
  666. return ErrIntOverflowEtcdserver
  667. }
  668. if iNdEx >= l {
  669. return io.ErrUnexpectedEOF
  670. }
  671. b := data[iNdEx]
  672. iNdEx++
  673. v |= (int(b) & 0x7F) << shift
  674. if b < 0x80 {
  675. break
  676. }
  677. }
  678. m.Sorted = bool(v != 0)
  679. case 14:
  680. if wireType != 0 {
  681. return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
  682. }
  683. var v int
  684. for shift := uint(0); ; shift += 7 {
  685. if shift >= 64 {
  686. return ErrIntOverflowEtcdserver
  687. }
  688. if iNdEx >= l {
  689. return io.ErrUnexpectedEOF
  690. }
  691. b := data[iNdEx]
  692. iNdEx++
  693. v |= (int(b) & 0x7F) << shift
  694. if b < 0x80 {
  695. break
  696. }
  697. }
  698. m.Quorum = bool(v != 0)
  699. case 15:
  700. if wireType != 0 {
  701. return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
  702. }
  703. m.Time = 0
  704. for shift := uint(0); ; shift += 7 {
  705. if shift >= 64 {
  706. return ErrIntOverflowEtcdserver
  707. }
  708. if iNdEx >= l {
  709. return io.ErrUnexpectedEOF
  710. }
  711. b := data[iNdEx]
  712. iNdEx++
  713. m.Time |= (int64(b) & 0x7F) << shift
  714. if b < 0x80 {
  715. break
  716. }
  717. }
  718. case 16:
  719. if wireType != 0 {
  720. return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
  721. }
  722. var v int
  723. for shift := uint(0); ; shift += 7 {
  724. if shift >= 64 {
  725. return ErrIntOverflowEtcdserver
  726. }
  727. if iNdEx >= l {
  728. return io.ErrUnexpectedEOF
  729. }
  730. b := data[iNdEx]
  731. iNdEx++
  732. v |= (int(b) & 0x7F) << shift
  733. if b < 0x80 {
  734. break
  735. }
  736. }
  737. m.Stream = bool(v != 0)
  738. case 17:
  739. if wireType != 0 {
  740. return fmt.Errorf("proto: wrong wireType = %d for field Refresh", wireType)
  741. }
  742. var v int
  743. for shift := uint(0); ; shift += 7 {
  744. if shift >= 64 {
  745. return ErrIntOverflowEtcdserver
  746. }
  747. if iNdEx >= l {
  748. return io.ErrUnexpectedEOF
  749. }
  750. b := data[iNdEx]
  751. iNdEx++
  752. v |= (int(b) & 0x7F) << shift
  753. if b < 0x80 {
  754. break
  755. }
  756. }
  757. b := bool(v != 0)
  758. m.Refresh = &b
  759. default:
  760. iNdEx = preIndex
  761. skippy, err := skipEtcdserver(data[iNdEx:])
  762. if err != nil {
  763. return err
  764. }
  765. if skippy < 0 {
  766. return ErrInvalidLengthEtcdserver
  767. }
  768. if (iNdEx + skippy) > l {
  769. return io.ErrUnexpectedEOF
  770. }
  771. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  772. iNdEx += skippy
  773. }
  774. }
  775. if iNdEx > l {
  776. return io.ErrUnexpectedEOF
  777. }
  778. return nil
  779. }
  780. func (m *Metadata) Unmarshal(data []byte) error {
  781. l := len(data)
  782. iNdEx := 0
  783. for iNdEx < l {
  784. preIndex := iNdEx
  785. var wire uint64
  786. for shift := uint(0); ; shift += 7 {
  787. if shift >= 64 {
  788. return ErrIntOverflowEtcdserver
  789. }
  790. if iNdEx >= l {
  791. return io.ErrUnexpectedEOF
  792. }
  793. b := data[iNdEx]
  794. iNdEx++
  795. wire |= (uint64(b) & 0x7F) << shift
  796. if b < 0x80 {
  797. break
  798. }
  799. }
  800. fieldNum := int32(wire >> 3)
  801. wireType := int(wire & 0x7)
  802. if wireType == 4 {
  803. return fmt.Errorf("proto: Metadata: wiretype end group for non-group")
  804. }
  805. if fieldNum <= 0 {
  806. return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire)
  807. }
  808. switch fieldNum {
  809. case 1:
  810. if wireType != 0 {
  811. return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
  812. }
  813. m.NodeID = 0
  814. for shift := uint(0); ; shift += 7 {
  815. if shift >= 64 {
  816. return ErrIntOverflowEtcdserver
  817. }
  818. if iNdEx >= l {
  819. return io.ErrUnexpectedEOF
  820. }
  821. b := data[iNdEx]
  822. iNdEx++
  823. m.NodeID |= (uint64(b) & 0x7F) << shift
  824. if b < 0x80 {
  825. break
  826. }
  827. }
  828. case 2:
  829. if wireType != 0 {
  830. return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
  831. }
  832. m.ClusterID = 0
  833. for shift := uint(0); ; shift += 7 {
  834. if shift >= 64 {
  835. return ErrIntOverflowEtcdserver
  836. }
  837. if iNdEx >= l {
  838. return io.ErrUnexpectedEOF
  839. }
  840. b := data[iNdEx]
  841. iNdEx++
  842. m.ClusterID |= (uint64(b) & 0x7F) << shift
  843. if b < 0x80 {
  844. break
  845. }
  846. }
  847. default:
  848. iNdEx = preIndex
  849. skippy, err := skipEtcdserver(data[iNdEx:])
  850. if err != nil {
  851. return err
  852. }
  853. if skippy < 0 {
  854. return ErrInvalidLengthEtcdserver
  855. }
  856. if (iNdEx + skippy) > l {
  857. return io.ErrUnexpectedEOF
  858. }
  859. m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
  860. iNdEx += skippy
  861. }
  862. }
  863. if iNdEx > l {
  864. return io.ErrUnexpectedEOF
  865. }
  866. return nil
  867. }
  868. func skipEtcdserver(data []byte) (n int, err error) {
  869. l := len(data)
  870. iNdEx := 0
  871. for iNdEx < l {
  872. var wire uint64
  873. for shift := uint(0); ; shift += 7 {
  874. if shift >= 64 {
  875. return 0, ErrIntOverflowEtcdserver
  876. }
  877. if iNdEx >= l {
  878. return 0, io.ErrUnexpectedEOF
  879. }
  880. b := data[iNdEx]
  881. iNdEx++
  882. wire |= (uint64(b) & 0x7F) << shift
  883. if b < 0x80 {
  884. break
  885. }
  886. }
  887. wireType := int(wire & 0x7)
  888. switch wireType {
  889. case 0:
  890. for shift := uint(0); ; shift += 7 {
  891. if shift >= 64 {
  892. return 0, ErrIntOverflowEtcdserver
  893. }
  894. if iNdEx >= l {
  895. return 0, io.ErrUnexpectedEOF
  896. }
  897. iNdEx++
  898. if data[iNdEx-1] < 0x80 {
  899. break
  900. }
  901. }
  902. return iNdEx, nil
  903. case 1:
  904. iNdEx += 8
  905. return iNdEx, nil
  906. case 2:
  907. var length int
  908. for shift := uint(0); ; shift += 7 {
  909. if shift >= 64 {
  910. return 0, ErrIntOverflowEtcdserver
  911. }
  912. if iNdEx >= l {
  913. return 0, io.ErrUnexpectedEOF
  914. }
  915. b := data[iNdEx]
  916. iNdEx++
  917. length |= (int(b) & 0x7F) << shift
  918. if b < 0x80 {
  919. break
  920. }
  921. }
  922. iNdEx += length
  923. if length < 0 {
  924. return 0, ErrInvalidLengthEtcdserver
  925. }
  926. return iNdEx, nil
  927. case 3:
  928. for {
  929. var innerWire uint64
  930. var start int = iNdEx
  931. for shift := uint(0); ; shift += 7 {
  932. if shift >= 64 {
  933. return 0, ErrIntOverflowEtcdserver
  934. }
  935. if iNdEx >= l {
  936. return 0, io.ErrUnexpectedEOF
  937. }
  938. b := data[iNdEx]
  939. iNdEx++
  940. innerWire |= (uint64(b) & 0x7F) << shift
  941. if b < 0x80 {
  942. break
  943. }
  944. }
  945. innerWireType := int(innerWire & 0x7)
  946. if innerWireType == 4 {
  947. break
  948. }
  949. next, err := skipEtcdserver(data[start:])
  950. if err != nil {
  951. return 0, err
  952. }
  953. iNdEx = start + next
  954. }
  955. return iNdEx, nil
  956. case 4:
  957. return iNdEx, nil
  958. case 5:
  959. iNdEx += 4
  960. return iNdEx, nil
  961. default:
  962. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  963. }
  964. }
  965. panic("unreachable")
  966. }
  967. var (
  968. ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
  969. ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow")
  970. )