etcdserver.pb.go 20 KB

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