raft_internal.pb.go 24 KB

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