raft_internal.pb.go 39 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540
  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. math "math"
  9. )
  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. type RequestHeader struct {
  16. ID uint64 `protobuf:"varint,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
  17. // username is a username that is associated with an auth token of gRPC connection
  18. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
  19. }
  20. func (m *RequestHeader) Reset() { *m = RequestHeader{} }
  21. func (m *RequestHeader) String() string { return proto.CompactTextString(m) }
  22. func (*RequestHeader) ProtoMessage() {}
  23. func (*RequestHeader) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{0} }
  24. // An InternalRaftRequest is the union of all requests which can be
  25. // sent via raft.
  26. type InternalRaftRequest struct {
  27. Header *RequestHeader `protobuf:"bytes,100,opt,name=header" json:"header,omitempty"`
  28. ID uint64 `protobuf:"varint,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
  29. V2 *Request `protobuf:"bytes,2,opt,name=v2" json:"v2,omitempty"`
  30. Range *RangeRequest `protobuf:"bytes,3,opt,name=range" json:"range,omitempty"`
  31. Put *PutRequest `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
  32. DeleteRange *DeleteRangeRequest `protobuf:"bytes,5,opt,name=delete_range,json=deleteRange" json:"delete_range,omitempty"`
  33. Txn *TxnRequest `protobuf:"bytes,6,opt,name=txn" json:"txn,omitempty"`
  34. Compaction *CompactionRequest `protobuf:"bytes,7,opt,name=compaction" json:"compaction,omitempty"`
  35. LeaseGrant *LeaseGrantRequest `protobuf:"bytes,8,opt,name=lease_grant,json=leaseGrant" json:"lease_grant,omitempty"`
  36. LeaseRevoke *LeaseRevokeRequest `protobuf:"bytes,9,opt,name=lease_revoke,json=leaseRevoke" json:"lease_revoke,omitempty"`
  37. Alarm *AlarmRequest `protobuf:"bytes,10,opt,name=alarm" json:"alarm,omitempty"`
  38. AuthEnable *AuthEnableRequest `protobuf:"bytes,1000,opt,name=auth_enable,json=authEnable" json:"auth_enable,omitempty"`
  39. AuthDisable *AuthDisableRequest `protobuf:"bytes,1011,opt,name=auth_disable,json=authDisable" json:"auth_disable,omitempty"`
  40. AuthUserAdd *AuthUserAddRequest `protobuf:"bytes,1012,opt,name=auth_user_add,json=authUserAdd" json:"auth_user_add,omitempty"`
  41. AuthUserDelete *AuthUserDeleteRequest `protobuf:"bytes,1013,opt,name=auth_user_delete,json=authUserDelete" json:"auth_user_delete,omitempty"`
  42. AuthUserChangePassword *AuthUserChangePasswordRequest `protobuf:"bytes,1014,opt,name=auth_user_change_password,json=authUserChangePassword" json:"auth_user_change_password,omitempty"`
  43. AuthUserGrant *AuthUserGrantRequest `protobuf:"bytes,1015,opt,name=auth_user_grant,json=authUserGrant" json:"auth_user_grant,omitempty"`
  44. AuthRoleAdd *AuthRoleAddRequest `protobuf:"bytes,1016,opt,name=auth_role_add,json=authRoleAdd" json:"auth_role_add,omitempty"`
  45. AuthRoleGrant *AuthRoleGrantRequest `protobuf:"bytes,1017,opt,name=auth_role_grant,json=authRoleGrant" json:"auth_role_grant,omitempty"`
  46. Authenticate *AuthenticateRequest `protobuf:"bytes,1018,opt,name=authenticate" json:"authenticate,omitempty"`
  47. AuthUserGet *AuthUserGetRequest `protobuf:"bytes,1019,opt,name=auth_user_get,json=authUserGet" json:"auth_user_get,omitempty"`
  48. }
  49. func (m *InternalRaftRequest) Reset() { *m = InternalRaftRequest{} }
  50. func (m *InternalRaftRequest) String() string { return proto.CompactTextString(m) }
  51. func (*InternalRaftRequest) ProtoMessage() {}
  52. func (*InternalRaftRequest) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{1} }
  53. type EmptyResponse struct {
  54. }
  55. func (m *EmptyResponse) Reset() { *m = EmptyResponse{} }
  56. func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
  57. func (*EmptyResponse) ProtoMessage() {}
  58. func (*EmptyResponse) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{2} }
  59. func init() {
  60. proto.RegisterType((*RequestHeader)(nil), "etcdserverpb.RequestHeader")
  61. proto.RegisterType((*InternalRaftRequest)(nil), "etcdserverpb.InternalRaftRequest")
  62. proto.RegisterType((*EmptyResponse)(nil), "etcdserverpb.EmptyResponse")
  63. }
  64. func (m *RequestHeader) Marshal() (data []byte, err error) {
  65. size := m.Size()
  66. data = make([]byte, size)
  67. n, err := m.MarshalTo(data)
  68. if err != nil {
  69. return nil, err
  70. }
  71. return data[:n], nil
  72. }
  73. func (m *RequestHeader) MarshalTo(data []byte) (int, error) {
  74. var i int
  75. _ = i
  76. var l int
  77. _ = l
  78. if m.ID != 0 {
  79. data[i] = 0x8
  80. i++
  81. i = encodeVarintRaftInternal(data, i, uint64(m.ID))
  82. }
  83. if len(m.Username) > 0 {
  84. data[i] = 0x12
  85. i++
  86. i = encodeVarintRaftInternal(data, i, uint64(len(m.Username)))
  87. i += copy(data[i:], m.Username)
  88. }
  89. return i, nil
  90. }
  91. func (m *InternalRaftRequest) Marshal() (data []byte, err error) {
  92. size := m.Size()
  93. data = make([]byte, size)
  94. n, err := m.MarshalTo(data)
  95. if err != nil {
  96. return nil, err
  97. }
  98. return data[:n], nil
  99. }
  100. func (m *InternalRaftRequest) MarshalTo(data []byte) (int, error) {
  101. var i int
  102. _ = i
  103. var l int
  104. _ = l
  105. if m.ID != 0 {
  106. data[i] = 0x8
  107. i++
  108. i = encodeVarintRaftInternal(data, i, uint64(m.ID))
  109. }
  110. if m.V2 != nil {
  111. data[i] = 0x12
  112. i++
  113. i = encodeVarintRaftInternal(data, i, uint64(m.V2.Size()))
  114. n1, err := m.V2.MarshalTo(data[i:])
  115. if err != nil {
  116. return 0, err
  117. }
  118. i += n1
  119. }
  120. if m.Range != nil {
  121. data[i] = 0x1a
  122. i++
  123. i = encodeVarintRaftInternal(data, i, uint64(m.Range.Size()))
  124. n2, err := m.Range.MarshalTo(data[i:])
  125. if err != nil {
  126. return 0, err
  127. }
  128. i += n2
  129. }
  130. if m.Put != nil {
  131. data[i] = 0x22
  132. i++
  133. i = encodeVarintRaftInternal(data, i, uint64(m.Put.Size()))
  134. n3, err := m.Put.MarshalTo(data[i:])
  135. if err != nil {
  136. return 0, err
  137. }
  138. i += n3
  139. }
  140. if m.DeleteRange != nil {
  141. data[i] = 0x2a
  142. i++
  143. i = encodeVarintRaftInternal(data, i, uint64(m.DeleteRange.Size()))
  144. n4, err := m.DeleteRange.MarshalTo(data[i:])
  145. if err != nil {
  146. return 0, err
  147. }
  148. i += n4
  149. }
  150. if m.Txn != nil {
  151. data[i] = 0x32
  152. i++
  153. i = encodeVarintRaftInternal(data, i, uint64(m.Txn.Size()))
  154. n5, err := m.Txn.MarshalTo(data[i:])
  155. if err != nil {
  156. return 0, err
  157. }
  158. i += n5
  159. }
  160. if m.Compaction != nil {
  161. data[i] = 0x3a
  162. i++
  163. i = encodeVarintRaftInternal(data, i, uint64(m.Compaction.Size()))
  164. n6, err := m.Compaction.MarshalTo(data[i:])
  165. if err != nil {
  166. return 0, err
  167. }
  168. i += n6
  169. }
  170. if m.LeaseGrant != nil {
  171. data[i] = 0x42
  172. i++
  173. i = encodeVarintRaftInternal(data, i, uint64(m.LeaseGrant.Size()))
  174. n7, err := m.LeaseGrant.MarshalTo(data[i:])
  175. if err != nil {
  176. return 0, err
  177. }
  178. i += n7
  179. }
  180. if m.LeaseRevoke != nil {
  181. data[i] = 0x4a
  182. i++
  183. i = encodeVarintRaftInternal(data, i, uint64(m.LeaseRevoke.Size()))
  184. n8, err := m.LeaseRevoke.MarshalTo(data[i:])
  185. if err != nil {
  186. return 0, err
  187. }
  188. i += n8
  189. }
  190. if m.Alarm != nil {
  191. data[i] = 0x52
  192. i++
  193. i = encodeVarintRaftInternal(data, i, uint64(m.Alarm.Size()))
  194. n9, err := m.Alarm.MarshalTo(data[i:])
  195. if err != nil {
  196. return 0, err
  197. }
  198. i += n9
  199. }
  200. if m.Header != nil {
  201. data[i] = 0xa2
  202. i++
  203. data[i] = 0x6
  204. i++
  205. i = encodeVarintRaftInternal(data, i, uint64(m.Header.Size()))
  206. n10, err := m.Header.MarshalTo(data[i:])
  207. if err != nil {
  208. return 0, err
  209. }
  210. i += n10
  211. }
  212. if m.AuthEnable != nil {
  213. data[i] = 0xc2
  214. i++
  215. data[i] = 0x3e
  216. i++
  217. i = encodeVarintRaftInternal(data, i, uint64(m.AuthEnable.Size()))
  218. n11, err := m.AuthEnable.MarshalTo(data[i:])
  219. if err != nil {
  220. return 0, err
  221. }
  222. i += n11
  223. }
  224. if m.AuthDisable != nil {
  225. data[i] = 0x9a
  226. i++
  227. data[i] = 0x3f
  228. i++
  229. i = encodeVarintRaftInternal(data, i, uint64(m.AuthDisable.Size()))
  230. n12, err := m.AuthDisable.MarshalTo(data[i:])
  231. if err != nil {
  232. return 0, err
  233. }
  234. i += n12
  235. }
  236. if m.AuthUserAdd != nil {
  237. data[i] = 0xa2
  238. i++
  239. data[i] = 0x3f
  240. i++
  241. i = encodeVarintRaftInternal(data, i, uint64(m.AuthUserAdd.Size()))
  242. n13, err := m.AuthUserAdd.MarshalTo(data[i:])
  243. if err != nil {
  244. return 0, err
  245. }
  246. i += n13
  247. }
  248. if m.AuthUserDelete != nil {
  249. data[i] = 0xaa
  250. i++
  251. data[i] = 0x3f
  252. i++
  253. i = encodeVarintRaftInternal(data, i, uint64(m.AuthUserDelete.Size()))
  254. n14, err := m.AuthUserDelete.MarshalTo(data[i:])
  255. if err != nil {
  256. return 0, err
  257. }
  258. i += n14
  259. }
  260. if m.AuthUserChangePassword != nil {
  261. data[i] = 0xb2
  262. i++
  263. data[i] = 0x3f
  264. i++
  265. i = encodeVarintRaftInternal(data, i, uint64(m.AuthUserChangePassword.Size()))
  266. n15, err := m.AuthUserChangePassword.MarshalTo(data[i:])
  267. if err != nil {
  268. return 0, err
  269. }
  270. i += n15
  271. }
  272. if m.AuthUserGrant != nil {
  273. data[i] = 0xba
  274. i++
  275. data[i] = 0x3f
  276. i++
  277. i = encodeVarintRaftInternal(data, i, uint64(m.AuthUserGrant.Size()))
  278. n16, err := m.AuthUserGrant.MarshalTo(data[i:])
  279. if err != nil {
  280. return 0, err
  281. }
  282. i += n16
  283. }
  284. if m.AuthRoleAdd != nil {
  285. data[i] = 0xc2
  286. i++
  287. data[i] = 0x3f
  288. i++
  289. i = encodeVarintRaftInternal(data, i, uint64(m.AuthRoleAdd.Size()))
  290. n17, err := m.AuthRoleAdd.MarshalTo(data[i:])
  291. if err != nil {
  292. return 0, err
  293. }
  294. i += n17
  295. }
  296. if m.AuthRoleGrant != nil {
  297. data[i] = 0xca
  298. i++
  299. data[i] = 0x3f
  300. i++
  301. i = encodeVarintRaftInternal(data, i, uint64(m.AuthRoleGrant.Size()))
  302. n18, err := m.AuthRoleGrant.MarshalTo(data[i:])
  303. if err != nil {
  304. return 0, err
  305. }
  306. i += n18
  307. }
  308. if m.Authenticate != nil {
  309. data[i] = 0xd2
  310. i++
  311. data[i] = 0x3f
  312. i++
  313. i = encodeVarintRaftInternal(data, i, uint64(m.Authenticate.Size()))
  314. n19, err := m.Authenticate.MarshalTo(data[i:])
  315. if err != nil {
  316. return 0, err
  317. }
  318. i += n19
  319. }
  320. if m.AuthUserGet != nil {
  321. data[i] = 0xda
  322. i++
  323. data[i] = 0x3f
  324. i++
  325. i = encodeVarintRaftInternal(data, i, uint64(m.AuthUserGet.Size()))
  326. n20, err := m.AuthUserGet.MarshalTo(data[i:])
  327. if err != nil {
  328. return 0, err
  329. }
  330. i += n20
  331. }
  332. return i, nil
  333. }
  334. func (m *EmptyResponse) Marshal() (data []byte, err error) {
  335. size := m.Size()
  336. data = make([]byte, size)
  337. n, err := m.MarshalTo(data)
  338. if err != nil {
  339. return nil, err
  340. }
  341. return data[:n], nil
  342. }
  343. func (m *EmptyResponse) MarshalTo(data []byte) (int, error) {
  344. var i int
  345. _ = i
  346. var l int
  347. _ = l
  348. return i, nil
  349. }
  350. func encodeFixed64RaftInternal(data []byte, offset int, v uint64) int {
  351. data[offset] = uint8(v)
  352. data[offset+1] = uint8(v >> 8)
  353. data[offset+2] = uint8(v >> 16)
  354. data[offset+3] = uint8(v >> 24)
  355. data[offset+4] = uint8(v >> 32)
  356. data[offset+5] = uint8(v >> 40)
  357. data[offset+6] = uint8(v >> 48)
  358. data[offset+7] = uint8(v >> 56)
  359. return offset + 8
  360. }
  361. func encodeFixed32RaftInternal(data []byte, offset int, v uint32) int {
  362. data[offset] = uint8(v)
  363. data[offset+1] = uint8(v >> 8)
  364. data[offset+2] = uint8(v >> 16)
  365. data[offset+3] = uint8(v >> 24)
  366. return offset + 4
  367. }
  368. func encodeVarintRaftInternal(data []byte, offset int, v uint64) int {
  369. for v >= 1<<7 {
  370. data[offset] = uint8(v&0x7f | 0x80)
  371. v >>= 7
  372. offset++
  373. }
  374. data[offset] = uint8(v)
  375. return offset + 1
  376. }
  377. func (m *RequestHeader) Size() (n int) {
  378. var l int
  379. _ = l
  380. if m.ID != 0 {
  381. n += 1 + sovRaftInternal(uint64(m.ID))
  382. }
  383. l = len(m.Username)
  384. if l > 0 {
  385. n += 1 + l + sovRaftInternal(uint64(l))
  386. }
  387. return n
  388. }
  389. func (m *InternalRaftRequest) Size() (n int) {
  390. var l int
  391. _ = l
  392. if m.ID != 0 {
  393. n += 1 + sovRaftInternal(uint64(m.ID))
  394. }
  395. if m.V2 != nil {
  396. l = m.V2.Size()
  397. n += 1 + l + sovRaftInternal(uint64(l))
  398. }
  399. if m.Range != nil {
  400. l = m.Range.Size()
  401. n += 1 + l + sovRaftInternal(uint64(l))
  402. }
  403. if m.Put != nil {
  404. l = m.Put.Size()
  405. n += 1 + l + sovRaftInternal(uint64(l))
  406. }
  407. if m.DeleteRange != nil {
  408. l = m.DeleteRange.Size()
  409. n += 1 + l + sovRaftInternal(uint64(l))
  410. }
  411. if m.Txn != nil {
  412. l = m.Txn.Size()
  413. n += 1 + l + sovRaftInternal(uint64(l))
  414. }
  415. if m.Compaction != nil {
  416. l = m.Compaction.Size()
  417. n += 1 + l + sovRaftInternal(uint64(l))
  418. }
  419. if m.LeaseGrant != nil {
  420. l = m.LeaseGrant.Size()
  421. n += 1 + l + sovRaftInternal(uint64(l))
  422. }
  423. if m.LeaseRevoke != nil {
  424. l = m.LeaseRevoke.Size()
  425. n += 1 + l + sovRaftInternal(uint64(l))
  426. }
  427. if m.Alarm != nil {
  428. l = m.Alarm.Size()
  429. n += 1 + l + sovRaftInternal(uint64(l))
  430. }
  431. if m.Header != nil {
  432. l = m.Header.Size()
  433. n += 2 + l + sovRaftInternal(uint64(l))
  434. }
  435. if m.AuthEnable != nil {
  436. l = m.AuthEnable.Size()
  437. n += 2 + l + sovRaftInternal(uint64(l))
  438. }
  439. if m.AuthDisable != nil {
  440. l = m.AuthDisable.Size()
  441. n += 2 + l + sovRaftInternal(uint64(l))
  442. }
  443. if m.AuthUserAdd != nil {
  444. l = m.AuthUserAdd.Size()
  445. n += 2 + l + sovRaftInternal(uint64(l))
  446. }
  447. if m.AuthUserDelete != nil {
  448. l = m.AuthUserDelete.Size()
  449. n += 2 + l + sovRaftInternal(uint64(l))
  450. }
  451. if m.AuthUserChangePassword != nil {
  452. l = m.AuthUserChangePassword.Size()
  453. n += 2 + l + sovRaftInternal(uint64(l))
  454. }
  455. if m.AuthUserGrant != nil {
  456. l = m.AuthUserGrant.Size()
  457. n += 2 + l + sovRaftInternal(uint64(l))
  458. }
  459. if m.AuthRoleAdd != nil {
  460. l = m.AuthRoleAdd.Size()
  461. n += 2 + l + sovRaftInternal(uint64(l))
  462. }
  463. if m.AuthRoleGrant != nil {
  464. l = m.AuthRoleGrant.Size()
  465. n += 2 + l + sovRaftInternal(uint64(l))
  466. }
  467. if m.Authenticate != nil {
  468. l = m.Authenticate.Size()
  469. n += 2 + l + sovRaftInternal(uint64(l))
  470. }
  471. if m.AuthUserGet != nil {
  472. l = m.AuthUserGet.Size()
  473. n += 2 + l + sovRaftInternal(uint64(l))
  474. }
  475. return n
  476. }
  477. func (m *EmptyResponse) Size() (n int) {
  478. var l int
  479. _ = l
  480. return n
  481. }
  482. func sovRaftInternal(x uint64) (n int) {
  483. for {
  484. n++
  485. x >>= 7
  486. if x == 0 {
  487. break
  488. }
  489. }
  490. return n
  491. }
  492. func sozRaftInternal(x uint64) (n int) {
  493. return sovRaftInternal(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  494. }
  495. func (m *RequestHeader) Unmarshal(data []byte) error {
  496. l := len(data)
  497. iNdEx := 0
  498. for iNdEx < l {
  499. preIndex := iNdEx
  500. var wire uint64
  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. wire |= (uint64(b) & 0x7F) << shift
  511. if b < 0x80 {
  512. break
  513. }
  514. }
  515. fieldNum := int32(wire >> 3)
  516. wireType := int(wire & 0x7)
  517. if wireType == 4 {
  518. return fmt.Errorf("proto: RequestHeader: wiretype end group for non-group")
  519. }
  520. if fieldNum <= 0 {
  521. return fmt.Errorf("proto: RequestHeader: illegal tag %d (wire type %d)", fieldNum, wire)
  522. }
  523. switch fieldNum {
  524. case 1:
  525. if wireType != 0 {
  526. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  527. }
  528. m.ID = 0
  529. for shift := uint(0); ; shift += 7 {
  530. if shift >= 64 {
  531. return ErrIntOverflowRaftInternal
  532. }
  533. if iNdEx >= l {
  534. return io.ErrUnexpectedEOF
  535. }
  536. b := data[iNdEx]
  537. iNdEx++
  538. m.ID |= (uint64(b) & 0x7F) << shift
  539. if b < 0x80 {
  540. break
  541. }
  542. }
  543. case 2:
  544. if wireType != 2 {
  545. return fmt.Errorf("proto: wrong wireType = %d for field Username", wireType)
  546. }
  547. var stringLen uint64
  548. for shift := uint(0); ; shift += 7 {
  549. if shift >= 64 {
  550. return ErrIntOverflowRaftInternal
  551. }
  552. if iNdEx >= l {
  553. return io.ErrUnexpectedEOF
  554. }
  555. b := data[iNdEx]
  556. iNdEx++
  557. stringLen |= (uint64(b) & 0x7F) << shift
  558. if b < 0x80 {
  559. break
  560. }
  561. }
  562. intStringLen := int(stringLen)
  563. if intStringLen < 0 {
  564. return ErrInvalidLengthRaftInternal
  565. }
  566. postIndex := iNdEx + intStringLen
  567. if postIndex > l {
  568. return io.ErrUnexpectedEOF
  569. }
  570. m.Username = string(data[iNdEx:postIndex])
  571. iNdEx = postIndex
  572. default:
  573. iNdEx = preIndex
  574. skippy, err := skipRaftInternal(data[iNdEx:])
  575. if err != nil {
  576. return err
  577. }
  578. if skippy < 0 {
  579. return ErrInvalidLengthRaftInternal
  580. }
  581. if (iNdEx + skippy) > l {
  582. return io.ErrUnexpectedEOF
  583. }
  584. iNdEx += skippy
  585. }
  586. }
  587. if iNdEx > l {
  588. return io.ErrUnexpectedEOF
  589. }
  590. return nil
  591. }
  592. func (m *InternalRaftRequest) Unmarshal(data []byte) error {
  593. l := len(data)
  594. iNdEx := 0
  595. for iNdEx < l {
  596. preIndex := iNdEx
  597. var wire uint64
  598. for shift := uint(0); ; shift += 7 {
  599. if shift >= 64 {
  600. return ErrIntOverflowRaftInternal
  601. }
  602. if iNdEx >= l {
  603. return io.ErrUnexpectedEOF
  604. }
  605. b := data[iNdEx]
  606. iNdEx++
  607. wire |= (uint64(b) & 0x7F) << shift
  608. if b < 0x80 {
  609. break
  610. }
  611. }
  612. fieldNum := int32(wire >> 3)
  613. wireType := int(wire & 0x7)
  614. if wireType == 4 {
  615. return fmt.Errorf("proto: InternalRaftRequest: wiretype end group for non-group")
  616. }
  617. if fieldNum <= 0 {
  618. return fmt.Errorf("proto: InternalRaftRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  619. }
  620. switch fieldNum {
  621. case 1:
  622. if wireType != 0 {
  623. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  624. }
  625. m.ID = 0
  626. for shift := uint(0); ; shift += 7 {
  627. if shift >= 64 {
  628. return ErrIntOverflowRaftInternal
  629. }
  630. if iNdEx >= l {
  631. return io.ErrUnexpectedEOF
  632. }
  633. b := data[iNdEx]
  634. iNdEx++
  635. m.ID |= (uint64(b) & 0x7F) << shift
  636. if b < 0x80 {
  637. break
  638. }
  639. }
  640. case 2:
  641. if wireType != 2 {
  642. return fmt.Errorf("proto: wrong wireType = %d for field V2", wireType)
  643. }
  644. var msglen int
  645. for shift := uint(0); ; shift += 7 {
  646. if shift >= 64 {
  647. return ErrIntOverflowRaftInternal
  648. }
  649. if iNdEx >= l {
  650. return io.ErrUnexpectedEOF
  651. }
  652. b := data[iNdEx]
  653. iNdEx++
  654. msglen |= (int(b) & 0x7F) << shift
  655. if b < 0x80 {
  656. break
  657. }
  658. }
  659. if msglen < 0 {
  660. return ErrInvalidLengthRaftInternal
  661. }
  662. postIndex := iNdEx + msglen
  663. if postIndex > l {
  664. return io.ErrUnexpectedEOF
  665. }
  666. if m.V2 == nil {
  667. m.V2 = &Request{}
  668. }
  669. if err := m.V2.Unmarshal(data[iNdEx:postIndex]); err != nil {
  670. return err
  671. }
  672. iNdEx = postIndex
  673. case 3:
  674. if wireType != 2 {
  675. return fmt.Errorf("proto: wrong wireType = %d for field Range", wireType)
  676. }
  677. var msglen int
  678. for shift := uint(0); ; shift += 7 {
  679. if shift >= 64 {
  680. return ErrIntOverflowRaftInternal
  681. }
  682. if iNdEx >= l {
  683. return io.ErrUnexpectedEOF
  684. }
  685. b := data[iNdEx]
  686. iNdEx++
  687. msglen |= (int(b) & 0x7F) << shift
  688. if b < 0x80 {
  689. break
  690. }
  691. }
  692. if msglen < 0 {
  693. return ErrInvalidLengthRaftInternal
  694. }
  695. postIndex := iNdEx + msglen
  696. if postIndex > l {
  697. return io.ErrUnexpectedEOF
  698. }
  699. if m.Range == nil {
  700. m.Range = &RangeRequest{}
  701. }
  702. if err := m.Range.Unmarshal(data[iNdEx:postIndex]); err != nil {
  703. return err
  704. }
  705. iNdEx = postIndex
  706. case 4:
  707. if wireType != 2 {
  708. return fmt.Errorf("proto: wrong wireType = %d for field Put", wireType)
  709. }
  710. var msglen int
  711. for shift := uint(0); ; shift += 7 {
  712. if shift >= 64 {
  713. return ErrIntOverflowRaftInternal
  714. }
  715. if iNdEx >= l {
  716. return io.ErrUnexpectedEOF
  717. }
  718. b := data[iNdEx]
  719. iNdEx++
  720. msglen |= (int(b) & 0x7F) << shift
  721. if b < 0x80 {
  722. break
  723. }
  724. }
  725. if msglen < 0 {
  726. return ErrInvalidLengthRaftInternal
  727. }
  728. postIndex := iNdEx + msglen
  729. if postIndex > l {
  730. return io.ErrUnexpectedEOF
  731. }
  732. if m.Put == nil {
  733. m.Put = &PutRequest{}
  734. }
  735. if err := m.Put.Unmarshal(data[iNdEx:postIndex]); err != nil {
  736. return err
  737. }
  738. iNdEx = postIndex
  739. case 5:
  740. if wireType != 2 {
  741. return fmt.Errorf("proto: wrong wireType = %d for field DeleteRange", wireType)
  742. }
  743. var msglen int
  744. for shift := uint(0); ; shift += 7 {
  745. if shift >= 64 {
  746. return ErrIntOverflowRaftInternal
  747. }
  748. if iNdEx >= l {
  749. return io.ErrUnexpectedEOF
  750. }
  751. b := data[iNdEx]
  752. iNdEx++
  753. msglen |= (int(b) & 0x7F) << shift
  754. if b < 0x80 {
  755. break
  756. }
  757. }
  758. if msglen < 0 {
  759. return ErrInvalidLengthRaftInternal
  760. }
  761. postIndex := iNdEx + msglen
  762. if postIndex > l {
  763. return io.ErrUnexpectedEOF
  764. }
  765. if m.DeleteRange == nil {
  766. m.DeleteRange = &DeleteRangeRequest{}
  767. }
  768. if err := m.DeleteRange.Unmarshal(data[iNdEx:postIndex]); err != nil {
  769. return err
  770. }
  771. iNdEx = postIndex
  772. case 6:
  773. if wireType != 2 {
  774. return fmt.Errorf("proto: wrong wireType = %d for field Txn", wireType)
  775. }
  776. var msglen int
  777. for shift := uint(0); ; shift += 7 {
  778. if shift >= 64 {
  779. return ErrIntOverflowRaftInternal
  780. }
  781. if iNdEx >= l {
  782. return io.ErrUnexpectedEOF
  783. }
  784. b := data[iNdEx]
  785. iNdEx++
  786. msglen |= (int(b) & 0x7F) << shift
  787. if b < 0x80 {
  788. break
  789. }
  790. }
  791. if msglen < 0 {
  792. return ErrInvalidLengthRaftInternal
  793. }
  794. postIndex := iNdEx + msglen
  795. if postIndex > l {
  796. return io.ErrUnexpectedEOF
  797. }
  798. if m.Txn == nil {
  799. m.Txn = &TxnRequest{}
  800. }
  801. if err := m.Txn.Unmarshal(data[iNdEx:postIndex]); err != nil {
  802. return err
  803. }
  804. iNdEx = postIndex
  805. case 7:
  806. if wireType != 2 {
  807. return fmt.Errorf("proto: wrong wireType = %d for field Compaction", wireType)
  808. }
  809. var msglen int
  810. for shift := uint(0); ; shift += 7 {
  811. if shift >= 64 {
  812. return ErrIntOverflowRaftInternal
  813. }
  814. if iNdEx >= l {
  815. return io.ErrUnexpectedEOF
  816. }
  817. b := data[iNdEx]
  818. iNdEx++
  819. msglen |= (int(b) & 0x7F) << shift
  820. if b < 0x80 {
  821. break
  822. }
  823. }
  824. if msglen < 0 {
  825. return ErrInvalidLengthRaftInternal
  826. }
  827. postIndex := iNdEx + msglen
  828. if postIndex > l {
  829. return io.ErrUnexpectedEOF
  830. }
  831. if m.Compaction == nil {
  832. m.Compaction = &CompactionRequest{}
  833. }
  834. if err := m.Compaction.Unmarshal(data[iNdEx:postIndex]); err != nil {
  835. return err
  836. }
  837. iNdEx = postIndex
  838. case 8:
  839. if wireType != 2 {
  840. return fmt.Errorf("proto: wrong wireType = %d for field LeaseGrant", wireType)
  841. }
  842. var msglen int
  843. for shift := uint(0); ; shift += 7 {
  844. if shift >= 64 {
  845. return ErrIntOverflowRaftInternal
  846. }
  847. if iNdEx >= l {
  848. return io.ErrUnexpectedEOF
  849. }
  850. b := data[iNdEx]
  851. iNdEx++
  852. msglen |= (int(b) & 0x7F) << shift
  853. if b < 0x80 {
  854. break
  855. }
  856. }
  857. if msglen < 0 {
  858. return ErrInvalidLengthRaftInternal
  859. }
  860. postIndex := iNdEx + msglen
  861. if postIndex > l {
  862. return io.ErrUnexpectedEOF
  863. }
  864. if m.LeaseGrant == nil {
  865. m.LeaseGrant = &LeaseGrantRequest{}
  866. }
  867. if err := m.LeaseGrant.Unmarshal(data[iNdEx:postIndex]); err != nil {
  868. return err
  869. }
  870. iNdEx = postIndex
  871. case 9:
  872. if wireType != 2 {
  873. return fmt.Errorf("proto: wrong wireType = %d for field LeaseRevoke", wireType)
  874. }
  875. var msglen int
  876. for shift := uint(0); ; shift += 7 {
  877. if shift >= 64 {
  878. return ErrIntOverflowRaftInternal
  879. }
  880. if iNdEx >= l {
  881. return io.ErrUnexpectedEOF
  882. }
  883. b := data[iNdEx]
  884. iNdEx++
  885. msglen |= (int(b) & 0x7F) << shift
  886. if b < 0x80 {
  887. break
  888. }
  889. }
  890. if msglen < 0 {
  891. return ErrInvalidLengthRaftInternal
  892. }
  893. postIndex := iNdEx + msglen
  894. if postIndex > l {
  895. return io.ErrUnexpectedEOF
  896. }
  897. if m.LeaseRevoke == nil {
  898. m.LeaseRevoke = &LeaseRevokeRequest{}
  899. }
  900. if err := m.LeaseRevoke.Unmarshal(data[iNdEx:postIndex]); err != nil {
  901. return err
  902. }
  903. iNdEx = postIndex
  904. case 10:
  905. if wireType != 2 {
  906. return fmt.Errorf("proto: wrong wireType = %d for field Alarm", wireType)
  907. }
  908. var msglen int
  909. for shift := uint(0); ; shift += 7 {
  910. if shift >= 64 {
  911. return ErrIntOverflowRaftInternal
  912. }
  913. if iNdEx >= l {
  914. return io.ErrUnexpectedEOF
  915. }
  916. b := data[iNdEx]
  917. iNdEx++
  918. msglen |= (int(b) & 0x7F) << shift
  919. if b < 0x80 {
  920. break
  921. }
  922. }
  923. if msglen < 0 {
  924. return ErrInvalidLengthRaftInternal
  925. }
  926. postIndex := iNdEx + msglen
  927. if postIndex > l {
  928. return io.ErrUnexpectedEOF
  929. }
  930. if m.Alarm == nil {
  931. m.Alarm = &AlarmRequest{}
  932. }
  933. if err := m.Alarm.Unmarshal(data[iNdEx:postIndex]); err != nil {
  934. return err
  935. }
  936. iNdEx = postIndex
  937. case 100:
  938. if wireType != 2 {
  939. return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
  940. }
  941. var msglen int
  942. for shift := uint(0); ; shift += 7 {
  943. if shift >= 64 {
  944. return ErrIntOverflowRaftInternal
  945. }
  946. if iNdEx >= l {
  947. return io.ErrUnexpectedEOF
  948. }
  949. b := data[iNdEx]
  950. iNdEx++
  951. msglen |= (int(b) & 0x7F) << shift
  952. if b < 0x80 {
  953. break
  954. }
  955. }
  956. if msglen < 0 {
  957. return ErrInvalidLengthRaftInternal
  958. }
  959. postIndex := iNdEx + msglen
  960. if postIndex > l {
  961. return io.ErrUnexpectedEOF
  962. }
  963. if m.Header == nil {
  964. m.Header = &RequestHeader{}
  965. }
  966. if err := m.Header.Unmarshal(data[iNdEx:postIndex]); err != nil {
  967. return err
  968. }
  969. iNdEx = postIndex
  970. case 1000:
  971. if wireType != 2 {
  972. return fmt.Errorf("proto: wrong wireType = %d for field AuthEnable", wireType)
  973. }
  974. var msglen int
  975. for shift := uint(0); ; shift += 7 {
  976. if shift >= 64 {
  977. return ErrIntOverflowRaftInternal
  978. }
  979. if iNdEx >= l {
  980. return io.ErrUnexpectedEOF
  981. }
  982. b := data[iNdEx]
  983. iNdEx++
  984. msglen |= (int(b) & 0x7F) << shift
  985. if b < 0x80 {
  986. break
  987. }
  988. }
  989. if msglen < 0 {
  990. return ErrInvalidLengthRaftInternal
  991. }
  992. postIndex := iNdEx + msglen
  993. if postIndex > l {
  994. return io.ErrUnexpectedEOF
  995. }
  996. if m.AuthEnable == nil {
  997. m.AuthEnable = &AuthEnableRequest{}
  998. }
  999. if err := m.AuthEnable.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1000. return err
  1001. }
  1002. iNdEx = postIndex
  1003. case 1011:
  1004. if wireType != 2 {
  1005. return fmt.Errorf("proto: wrong wireType = %d for field AuthDisable", wireType)
  1006. }
  1007. var msglen int
  1008. for shift := uint(0); ; shift += 7 {
  1009. if shift >= 64 {
  1010. return ErrIntOverflowRaftInternal
  1011. }
  1012. if iNdEx >= l {
  1013. return io.ErrUnexpectedEOF
  1014. }
  1015. b := data[iNdEx]
  1016. iNdEx++
  1017. msglen |= (int(b) & 0x7F) << shift
  1018. if b < 0x80 {
  1019. break
  1020. }
  1021. }
  1022. if msglen < 0 {
  1023. return ErrInvalidLengthRaftInternal
  1024. }
  1025. postIndex := iNdEx + msglen
  1026. if postIndex > l {
  1027. return io.ErrUnexpectedEOF
  1028. }
  1029. if m.AuthDisable == nil {
  1030. m.AuthDisable = &AuthDisableRequest{}
  1031. }
  1032. if err := m.AuthDisable.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1033. return err
  1034. }
  1035. iNdEx = postIndex
  1036. case 1012:
  1037. if wireType != 2 {
  1038. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserAdd", wireType)
  1039. }
  1040. var msglen int
  1041. for shift := uint(0); ; shift += 7 {
  1042. if shift >= 64 {
  1043. return ErrIntOverflowRaftInternal
  1044. }
  1045. if iNdEx >= l {
  1046. return io.ErrUnexpectedEOF
  1047. }
  1048. b := data[iNdEx]
  1049. iNdEx++
  1050. msglen |= (int(b) & 0x7F) << shift
  1051. if b < 0x80 {
  1052. break
  1053. }
  1054. }
  1055. if msglen < 0 {
  1056. return ErrInvalidLengthRaftInternal
  1057. }
  1058. postIndex := iNdEx + msglen
  1059. if postIndex > l {
  1060. return io.ErrUnexpectedEOF
  1061. }
  1062. if m.AuthUserAdd == nil {
  1063. m.AuthUserAdd = &AuthUserAddRequest{}
  1064. }
  1065. if err := m.AuthUserAdd.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1066. return err
  1067. }
  1068. iNdEx = postIndex
  1069. case 1013:
  1070. if wireType != 2 {
  1071. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserDelete", wireType)
  1072. }
  1073. var msglen int
  1074. for shift := uint(0); ; shift += 7 {
  1075. if shift >= 64 {
  1076. return ErrIntOverflowRaftInternal
  1077. }
  1078. if iNdEx >= l {
  1079. return io.ErrUnexpectedEOF
  1080. }
  1081. b := data[iNdEx]
  1082. iNdEx++
  1083. msglen |= (int(b) & 0x7F) << shift
  1084. if b < 0x80 {
  1085. break
  1086. }
  1087. }
  1088. if msglen < 0 {
  1089. return ErrInvalidLengthRaftInternal
  1090. }
  1091. postIndex := iNdEx + msglen
  1092. if postIndex > l {
  1093. return io.ErrUnexpectedEOF
  1094. }
  1095. if m.AuthUserDelete == nil {
  1096. m.AuthUserDelete = &AuthUserDeleteRequest{}
  1097. }
  1098. if err := m.AuthUserDelete.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1099. return err
  1100. }
  1101. iNdEx = postIndex
  1102. case 1014:
  1103. if wireType != 2 {
  1104. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserChangePassword", wireType)
  1105. }
  1106. var msglen int
  1107. for shift := uint(0); ; shift += 7 {
  1108. if shift >= 64 {
  1109. return ErrIntOverflowRaftInternal
  1110. }
  1111. if iNdEx >= l {
  1112. return io.ErrUnexpectedEOF
  1113. }
  1114. b := data[iNdEx]
  1115. iNdEx++
  1116. msglen |= (int(b) & 0x7F) << shift
  1117. if b < 0x80 {
  1118. break
  1119. }
  1120. }
  1121. if msglen < 0 {
  1122. return ErrInvalidLengthRaftInternal
  1123. }
  1124. postIndex := iNdEx + msglen
  1125. if postIndex > l {
  1126. return io.ErrUnexpectedEOF
  1127. }
  1128. if m.AuthUserChangePassword == nil {
  1129. m.AuthUserChangePassword = &AuthUserChangePasswordRequest{}
  1130. }
  1131. if err := m.AuthUserChangePassword.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1132. return err
  1133. }
  1134. iNdEx = postIndex
  1135. case 1015:
  1136. if wireType != 2 {
  1137. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGrant", wireType)
  1138. }
  1139. var msglen int
  1140. for shift := uint(0); ; shift += 7 {
  1141. if shift >= 64 {
  1142. return ErrIntOverflowRaftInternal
  1143. }
  1144. if iNdEx >= l {
  1145. return io.ErrUnexpectedEOF
  1146. }
  1147. b := data[iNdEx]
  1148. iNdEx++
  1149. msglen |= (int(b) & 0x7F) << shift
  1150. if b < 0x80 {
  1151. break
  1152. }
  1153. }
  1154. if msglen < 0 {
  1155. return ErrInvalidLengthRaftInternal
  1156. }
  1157. postIndex := iNdEx + msglen
  1158. if postIndex > l {
  1159. return io.ErrUnexpectedEOF
  1160. }
  1161. if m.AuthUserGrant == nil {
  1162. m.AuthUserGrant = &AuthUserGrantRequest{}
  1163. }
  1164. if err := m.AuthUserGrant.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1165. return err
  1166. }
  1167. iNdEx = postIndex
  1168. case 1016:
  1169. if wireType != 2 {
  1170. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleAdd", wireType)
  1171. }
  1172. var msglen int
  1173. for shift := uint(0); ; shift += 7 {
  1174. if shift >= 64 {
  1175. return ErrIntOverflowRaftInternal
  1176. }
  1177. if iNdEx >= l {
  1178. return io.ErrUnexpectedEOF
  1179. }
  1180. b := data[iNdEx]
  1181. iNdEx++
  1182. msglen |= (int(b) & 0x7F) << shift
  1183. if b < 0x80 {
  1184. break
  1185. }
  1186. }
  1187. if msglen < 0 {
  1188. return ErrInvalidLengthRaftInternal
  1189. }
  1190. postIndex := iNdEx + msglen
  1191. if postIndex > l {
  1192. return io.ErrUnexpectedEOF
  1193. }
  1194. if m.AuthRoleAdd == nil {
  1195. m.AuthRoleAdd = &AuthRoleAddRequest{}
  1196. }
  1197. if err := m.AuthRoleAdd.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1198. return err
  1199. }
  1200. iNdEx = postIndex
  1201. case 1017:
  1202. if wireType != 2 {
  1203. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleGrant", wireType)
  1204. }
  1205. var msglen int
  1206. for shift := uint(0); ; shift += 7 {
  1207. if shift >= 64 {
  1208. return ErrIntOverflowRaftInternal
  1209. }
  1210. if iNdEx >= l {
  1211. return io.ErrUnexpectedEOF
  1212. }
  1213. b := data[iNdEx]
  1214. iNdEx++
  1215. msglen |= (int(b) & 0x7F) << shift
  1216. if b < 0x80 {
  1217. break
  1218. }
  1219. }
  1220. if msglen < 0 {
  1221. return ErrInvalidLengthRaftInternal
  1222. }
  1223. postIndex := iNdEx + msglen
  1224. if postIndex > l {
  1225. return io.ErrUnexpectedEOF
  1226. }
  1227. if m.AuthRoleGrant == nil {
  1228. m.AuthRoleGrant = &AuthRoleGrantRequest{}
  1229. }
  1230. if err := m.AuthRoleGrant.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1231. return err
  1232. }
  1233. iNdEx = postIndex
  1234. case 1018:
  1235. if wireType != 2 {
  1236. return fmt.Errorf("proto: wrong wireType = %d for field Authenticate", wireType)
  1237. }
  1238. var msglen int
  1239. for shift := uint(0); ; shift += 7 {
  1240. if shift >= 64 {
  1241. return ErrIntOverflowRaftInternal
  1242. }
  1243. if iNdEx >= l {
  1244. return io.ErrUnexpectedEOF
  1245. }
  1246. b := data[iNdEx]
  1247. iNdEx++
  1248. msglen |= (int(b) & 0x7F) << shift
  1249. if b < 0x80 {
  1250. break
  1251. }
  1252. }
  1253. if msglen < 0 {
  1254. return ErrInvalidLengthRaftInternal
  1255. }
  1256. postIndex := iNdEx + msglen
  1257. if postIndex > l {
  1258. return io.ErrUnexpectedEOF
  1259. }
  1260. if m.Authenticate == nil {
  1261. m.Authenticate = &AuthenticateRequest{}
  1262. }
  1263. if err := m.Authenticate.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1264. return err
  1265. }
  1266. iNdEx = postIndex
  1267. case 1019:
  1268. if wireType != 2 {
  1269. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGet", wireType)
  1270. }
  1271. var msglen int
  1272. for shift := uint(0); ; shift += 7 {
  1273. if shift >= 64 {
  1274. return ErrIntOverflowRaftInternal
  1275. }
  1276. if iNdEx >= l {
  1277. return io.ErrUnexpectedEOF
  1278. }
  1279. b := data[iNdEx]
  1280. iNdEx++
  1281. msglen |= (int(b) & 0x7F) << shift
  1282. if b < 0x80 {
  1283. break
  1284. }
  1285. }
  1286. if msglen < 0 {
  1287. return ErrInvalidLengthRaftInternal
  1288. }
  1289. postIndex := iNdEx + msglen
  1290. if postIndex > l {
  1291. return io.ErrUnexpectedEOF
  1292. }
  1293. if m.AuthUserGet == nil {
  1294. m.AuthUserGet = &AuthUserGetRequest{}
  1295. }
  1296. if err := m.AuthUserGet.Unmarshal(data[iNdEx:postIndex]); err != nil {
  1297. return err
  1298. }
  1299. iNdEx = postIndex
  1300. default:
  1301. iNdEx = preIndex
  1302. skippy, err := skipRaftInternal(data[iNdEx:])
  1303. if err != nil {
  1304. return err
  1305. }
  1306. if skippy < 0 {
  1307. return ErrInvalidLengthRaftInternal
  1308. }
  1309. if (iNdEx + skippy) > l {
  1310. return io.ErrUnexpectedEOF
  1311. }
  1312. iNdEx += skippy
  1313. }
  1314. }
  1315. if iNdEx > l {
  1316. return io.ErrUnexpectedEOF
  1317. }
  1318. return nil
  1319. }
  1320. func (m *EmptyResponse) Unmarshal(data []byte) error {
  1321. l := len(data)
  1322. iNdEx := 0
  1323. for iNdEx < l {
  1324. preIndex := iNdEx
  1325. var wire uint64
  1326. for shift := uint(0); ; shift += 7 {
  1327. if shift >= 64 {
  1328. return ErrIntOverflowRaftInternal
  1329. }
  1330. if iNdEx >= l {
  1331. return io.ErrUnexpectedEOF
  1332. }
  1333. b := data[iNdEx]
  1334. iNdEx++
  1335. wire |= (uint64(b) & 0x7F) << shift
  1336. if b < 0x80 {
  1337. break
  1338. }
  1339. }
  1340. fieldNum := int32(wire >> 3)
  1341. wireType := int(wire & 0x7)
  1342. if wireType == 4 {
  1343. return fmt.Errorf("proto: EmptyResponse: wiretype end group for non-group")
  1344. }
  1345. if fieldNum <= 0 {
  1346. return fmt.Errorf("proto: EmptyResponse: illegal tag %d (wire type %d)", fieldNum, wire)
  1347. }
  1348. switch fieldNum {
  1349. default:
  1350. iNdEx = preIndex
  1351. skippy, err := skipRaftInternal(data[iNdEx:])
  1352. if err != nil {
  1353. return err
  1354. }
  1355. if skippy < 0 {
  1356. return ErrInvalidLengthRaftInternal
  1357. }
  1358. if (iNdEx + skippy) > l {
  1359. return io.ErrUnexpectedEOF
  1360. }
  1361. iNdEx += skippy
  1362. }
  1363. }
  1364. if iNdEx > l {
  1365. return io.ErrUnexpectedEOF
  1366. }
  1367. return nil
  1368. }
  1369. func skipRaftInternal(data []byte) (n int, err error) {
  1370. l := len(data)
  1371. iNdEx := 0
  1372. for iNdEx < l {
  1373. var wire uint64
  1374. for shift := uint(0); ; shift += 7 {
  1375. if shift >= 64 {
  1376. return 0, ErrIntOverflowRaftInternal
  1377. }
  1378. if iNdEx >= l {
  1379. return 0, io.ErrUnexpectedEOF
  1380. }
  1381. b := data[iNdEx]
  1382. iNdEx++
  1383. wire |= (uint64(b) & 0x7F) << shift
  1384. if b < 0x80 {
  1385. break
  1386. }
  1387. }
  1388. wireType := int(wire & 0x7)
  1389. switch wireType {
  1390. case 0:
  1391. for shift := uint(0); ; shift += 7 {
  1392. if shift >= 64 {
  1393. return 0, ErrIntOverflowRaftInternal
  1394. }
  1395. if iNdEx >= l {
  1396. return 0, io.ErrUnexpectedEOF
  1397. }
  1398. iNdEx++
  1399. if data[iNdEx-1] < 0x80 {
  1400. break
  1401. }
  1402. }
  1403. return iNdEx, nil
  1404. case 1:
  1405. iNdEx += 8
  1406. return iNdEx, nil
  1407. case 2:
  1408. var length int
  1409. for shift := uint(0); ; shift += 7 {
  1410. if shift >= 64 {
  1411. return 0, ErrIntOverflowRaftInternal
  1412. }
  1413. if iNdEx >= l {
  1414. return 0, io.ErrUnexpectedEOF
  1415. }
  1416. b := data[iNdEx]
  1417. iNdEx++
  1418. length |= (int(b) & 0x7F) << shift
  1419. if b < 0x80 {
  1420. break
  1421. }
  1422. }
  1423. iNdEx += length
  1424. if length < 0 {
  1425. return 0, ErrInvalidLengthRaftInternal
  1426. }
  1427. return iNdEx, nil
  1428. case 3:
  1429. for {
  1430. var innerWire uint64
  1431. var start int = iNdEx
  1432. for shift := uint(0); ; shift += 7 {
  1433. if shift >= 64 {
  1434. return 0, ErrIntOverflowRaftInternal
  1435. }
  1436. if iNdEx >= l {
  1437. return 0, io.ErrUnexpectedEOF
  1438. }
  1439. b := data[iNdEx]
  1440. iNdEx++
  1441. innerWire |= (uint64(b) & 0x7F) << shift
  1442. if b < 0x80 {
  1443. break
  1444. }
  1445. }
  1446. innerWireType := int(innerWire & 0x7)
  1447. if innerWireType == 4 {
  1448. break
  1449. }
  1450. next, err := skipRaftInternal(data[start:])
  1451. if err != nil {
  1452. return 0, err
  1453. }
  1454. iNdEx = start + next
  1455. }
  1456. return iNdEx, nil
  1457. case 4:
  1458. return iNdEx, nil
  1459. case 5:
  1460. iNdEx += 4
  1461. return iNdEx, nil
  1462. default:
  1463. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1464. }
  1465. }
  1466. panic("unreachable")
  1467. }
  1468. var (
  1469. ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling")
  1470. ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow")
  1471. )
  1472. var fileDescriptorRaftInternal = []byte{
  1473. // 617 bytes of a gzipped FileDescriptorProto
  1474. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x7c, 0x94, 0xcd, 0x6f, 0xd3, 0x30,
  1475. 0x18, 0xc6, 0x59, 0xf7, 0x59, 0xb7, 0xdd, 0x2a, 0x0f, 0x90, 0x29, 0xd2, 0x18, 0x45, 0x48, 0x08,
  1476. 0xa4, 0x82, 0xb6, 0x23, 0x07, 0x28, 0x6d, 0x19, 0x13, 0x08, 0x4d, 0x11, 0x9c, 0x23, 0x37, 0x79,
  1477. 0x49, 0x2b, 0xd2, 0x24, 0x38, 0x6e, 0x19, 0x7f, 0x1f, 0x97, 0x1d, 0xf9, 0x13, 0x80, 0x13, 0x77,
  1478. 0xbe, 0xe1, 0x82, 0x3f, 0x12, 0xa7, 0x59, 0x5d, 0x0e, 0x91, 0x92, 0xc7, 0xcf, 0xfb, 0x7b, 0x5f,
  1479. 0xdb, 0x8f, 0x82, 0x76, 0x19, 0x7d, 0xc5, 0xdd, 0x71, 0xc4, 0x81, 0x45, 0x34, 0xec, 0x24, 0x2c,
  1480. 0xe6, 0x31, 0xae, 0x03, 0xf7, 0xfc, 0x14, 0xd8, 0x0c, 0x58, 0x32, 0x6c, 0x5d, 0x0c, 0xe2, 0x20,
  1481. 0x56, 0x0b, 0x77, 0xe5, 0x9b, 0xf6, 0xb4, 0x9a, 0x85, 0x27, 0x53, 0xaa, 0x2c, 0xf1, 0xf4, 0x6b,
  1482. 0xfb, 0x3e, 0x6a, 0x38, 0xf0, 0x66, 0x0a, 0x29, 0x7f, 0x02, 0xd4, 0x07, 0x86, 0xb7, 0x51, 0xe5,
  1483. 0xb8, 0x4f, 0x56, 0xf6, 0x57, 0x6e, 0xad, 0x39, 0x95, 0x71, 0x1f, 0xb7, 0xd0, 0xd6, 0x34, 0x95,
  1484. 0x2d, 0x27, 0x40, 0x2a, 0x42, 0xad, 0x3a, 0xe6, 0xbb, 0xfd, 0x1e, 0xa1, 0xdd, 0xe3, 0x6c, 0x20,
  1485. 0x47, 0x4c, 0x97, 0x91, 0x16, 0x18, 0x37, 0x51, 0x65, 0x76, 0xa0, 0xaa, 0x6b, 0x07, 0x97, 0x3a,
  1486. 0xf3, 0x23, 0x77, 0xb2, 0x12, 0x47, 0x18, 0xf0, 0x3d, 0xb4, 0xce, 0x68, 0x14, 0x00, 0x59, 0x55,
  1487. 0xce, 0xd6, 0x39, 0xa7, 0x5c, 0xca, 0xed, 0xda, 0x88, 0x6f, 0xa3, 0xd5, 0x64, 0xca, 0xc9, 0x9a,
  1488. 0xf2, 0x93, 0xb2, 0xff, 0x64, 0x9a, 0xcf, 0xe3, 0x48, 0x13, 0xee, 0xa1, 0xba, 0x0f, 0x21, 0x70,
  1489. 0x70, 0x75, 0x93, 0x75, 0x55, 0xb4, 0x5f, 0x2e, 0xea, 0x2b, 0x47, 0xa9, 0x55, 0xcd, 0x2f, 0x34,
  1490. 0xd9, 0x90, 0x9f, 0x46, 0x64, 0xc3, 0xd6, 0xf0, 0xc5, 0x69, 0x64, 0x1a, 0x0a, 0x13, 0x7e, 0x80,
  1491. 0x90, 0x17, 0x4f, 0x12, 0xea, 0xf1, 0x71, 0x1c, 0x91, 0x4d, 0x55, 0x72, 0xad, 0x5c, 0xd2, 0x33,
  1492. 0xeb, 0x79, 0xe5, 0x5c, 0x09, 0x7e, 0x88, 0x6a, 0x21, 0xd0, 0x14, 0xdc, 0x40, 0x4c, 0xcc, 0xc9,
  1493. 0x96, 0x8d, 0xf0, 0x4c, 0x1a, 0x8e, 0xe4, 0xba, 0x21, 0x84, 0x46, 0x92, 0x7b, 0xd6, 0x04, 0x06,
  1494. 0xb3, 0xf8, 0x35, 0x90, 0xaa, 0x6d, 0xcf, 0x0a, 0xe1, 0x28, 0x83, 0xd9, 0x73, 0x58, 0x68, 0xf2,
  1495. 0x5a, 0x68, 0x48, 0xd9, 0x84, 0x20, 0xdb, 0xb5, 0x74, 0xe5, 0x92, 0xb9, 0x16, 0x65, 0xc4, 0x87,
  1496. 0x68, 0x63, 0xa4, 0xd2, 0x44, 0x7c, 0x55, 0x72, 0xd5, 0x7a, 0xe7, 0x3a, 0x70, 0x4e, 0x66, 0xc5,
  1497. 0x5d, 0x54, 0xa3, 0x53, 0x3e, 0x72, 0x21, 0xa2, 0xc3, 0x10, 0xc8, 0x17, 0xeb, 0x81, 0x75, 0x85,
  1498. 0x63, 0xa0, 0x0c, 0x66, 0xbb, 0xd4, 0x48, 0xb8, 0x8f, 0xea, 0x0a, 0xe1, 0x8f, 0x53, 0xc5, 0xf8,
  1499. 0xba, 0x69, 0xdb, 0xaf, 0x64, 0xf4, 0xb5, 0xc3, 0xec, 0x97, 0x16, 0x1a, 0x1e, 0xa0, 0x86, 0xa2,
  1500. 0xc8, 0x98, 0xbb, 0xd4, 0xf7, 0xc9, 0xb7, 0xa5, 0x98, 0x97, 0xe2, 0xab, 0xeb, 0xfb, 0x25, 0x4c,
  1501. 0xa6, 0xe1, 0xe7, 0xa8, 0x59, 0x60, 0x74, 0x86, 0xc8, 0x77, 0x4d, 0xba, 0x61, 0x27, 0x65, 0xe1,
  1502. 0xcb, 0x60, 0xdb, 0xb4, 0x24, 0xe3, 0x00, 0x5d, 0x29, 0x78, 0xde, 0x48, 0xc6, 0xd1, 0x4d, 0x68,
  1503. 0x9a, 0xbe, 0x8d, 0x99, 0x4f, 0x7e, 0x68, 0xf0, 0x1d, 0x3b, 0xb8, 0xa7, 0xdc, 0x27, 0x99, 0x39,
  1504. 0x6f, 0x70, 0x99, 0x5a, 0x97, 0xf1, 0x53, 0xb4, 0x53, 0x34, 0xd2, 0xd1, 0xfb, 0xa9, 0xf1, 0x6d,
  1505. 0x3b, 0xbe, 0x14, 0xbf, 0x06, 0x9d, 0x57, 0xcd, 0x61, 0xb2, 0x38, 0x04, 0x75, 0x98, 0xbf, 0x96,
  1506. 0x1e, 0xa6, 0x23, 0x2c, 0xe7, 0x0f, 0x33, 0xd3, 0xcc, 0x4c, 0x0a, 0xa3, 0x67, 0xfa, 0xbd, 0x74,
  1507. 0x26, 0x59, 0xb4, 0x38, 0x93, 0x51, 0xf1, 0x63, 0x1d, 0x13, 0x88, 0xf8, 0xd8, 0xa3, 0xe2, 0x56,
  1508. 0xfe, 0x68, 0xd2, 0xf5, 0x45, 0x52, 0x6e, 0xc9, 0x41, 0xa5, 0xba, 0x72, 0x50, 0x02, 0xe0, 0xe4,
  1509. 0xef, 0x7f, 0x83, 0x72, 0x04, 0x7c, 0x21, 0x28, 0x42, 0x6b, 0xef, 0xa0, 0xc6, 0x60, 0x92, 0xf0,
  1510. 0x77, 0x0e, 0xa4, 0x49, 0x1c, 0xa5, 0xf0, 0xa8, 0x79, 0xf6, 0x69, 0xef, 0xc2, 0xd9, 0xe7, 0xbd,
  1511. 0x95, 0x0f, 0xe2, 0xf9, 0x28, 0x9e, 0xe1, 0x86, 0xfa, 0x59, 0x1f, 0xfe, 0x0b, 0x00, 0x00, 0xff,
  1512. 0xff, 0x8a, 0x9d, 0xc9, 0xf9, 0x04, 0x06, 0x00, 0x00,
  1513. }