etcdserver.pb.go 20 KB

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