raft_internal.pb.go 25 KB

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