raft_internal.pb.go 26 KB

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