raft_internal.pb.go 23 KB

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