raft_internal.pb.go 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: raft_internal.proto
  3. package etcdserverpb
  4. import (
  5. "fmt"
  6. proto "github.com/golang/protobuf/proto"
  7. math "math"
  8. _ "github.com/gogo/protobuf/gogoproto"
  9. io "io"
  10. )
  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,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. // auth_revision is a revision number of auth.authStore. It is not related to mvcc
  20. AuthRevision uint64 `protobuf:"varint,3,opt,name=auth_revision,json=authRevision,proto3" json:"auth_revision,omitempty"`
  21. }
  22. func (m *RequestHeader) Reset() { *m = RequestHeader{} }
  23. func (m *RequestHeader) String() string { return proto.CompactTextString(m) }
  24. func (*RequestHeader) ProtoMessage() {}
  25. func (*RequestHeader) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{0} }
  26. // An InternalRaftRequest is the union of all requests which can be
  27. // sent via raft.
  28. type InternalRaftRequest struct {
  29. Header *RequestHeader `protobuf:"bytes,100,opt,name=header" json:"header,omitempty"`
  30. ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
  31. V2 *Request `protobuf:"bytes,2,opt,name=v2" json:"v2,omitempty"`
  32. Range *RangeRequest `protobuf:"bytes,3,opt,name=range" json:"range,omitempty"`
  33. Put *PutRequest `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
  34. DeleteRange *DeleteRangeRequest `protobuf:"bytes,5,opt,name=delete_range,json=deleteRange" json:"delete_range,omitempty"`
  35. Txn *TxnRequest `protobuf:"bytes,6,opt,name=txn" json:"txn,omitempty"`
  36. Compaction *CompactionRequest `protobuf:"bytes,7,opt,name=compaction" json:"compaction,omitempty"`
  37. LeaseGrant *LeaseGrantRequest `protobuf:"bytes,8,opt,name=lease_grant,json=leaseGrant" json:"lease_grant,omitempty"`
  38. LeaseRevoke *LeaseRevokeRequest `protobuf:"bytes,9,opt,name=lease_revoke,json=leaseRevoke" json:"lease_revoke,omitempty"`
  39. Alarm *AlarmRequest `protobuf:"bytes,10,opt,name=alarm" json:"alarm,omitempty"`
  40. AuthEnable *AuthEnableRequest `protobuf:"bytes,1000,opt,name=auth_enable,json=authEnable" json:"auth_enable,omitempty"`
  41. AuthDisable *AuthDisableRequest `protobuf:"bytes,1011,opt,name=auth_disable,json=authDisable" json:"auth_disable,omitempty"`
  42. Authenticate *InternalAuthenticateRequest `protobuf:"bytes,1012,opt,name=authenticate" json:"authenticate,omitempty"`
  43. AuthUserAdd *AuthUserAddRequest `protobuf:"bytes,1100,opt,name=auth_user_add,json=authUserAdd" json:"auth_user_add,omitempty"`
  44. AuthUserDelete *AuthUserDeleteRequest `protobuf:"bytes,1101,opt,name=auth_user_delete,json=authUserDelete" json:"auth_user_delete,omitempty"`
  45. AuthUserGet *AuthUserGetRequest `protobuf:"bytes,1102,opt,name=auth_user_get,json=authUserGet" json:"auth_user_get,omitempty"`
  46. AuthUserChangePassword *AuthUserChangePasswordRequest `protobuf:"bytes,1103,opt,name=auth_user_change_password,json=authUserChangePassword" json:"auth_user_change_password,omitempty"`
  47. AuthUserGrantRole *AuthUserGrantRoleRequest `protobuf:"bytes,1104,opt,name=auth_user_grant_role,json=authUserGrantRole" json:"auth_user_grant_role,omitempty"`
  48. AuthUserRevokeRole *AuthUserRevokeRoleRequest `protobuf:"bytes,1105,opt,name=auth_user_revoke_role,json=authUserRevokeRole" json:"auth_user_revoke_role,omitempty"`
  49. AuthUserList *AuthUserListRequest `protobuf:"bytes,1106,opt,name=auth_user_list,json=authUserList" json:"auth_user_list,omitempty"`
  50. AuthRoleList *AuthRoleListRequest `protobuf:"bytes,1107,opt,name=auth_role_list,json=authRoleList" json:"auth_role_list,omitempty"`
  51. AuthRoleAdd *AuthRoleAddRequest `protobuf:"bytes,1200,opt,name=auth_role_add,json=authRoleAdd" json:"auth_role_add,omitempty"`
  52. AuthRoleDelete *AuthRoleDeleteRequest `protobuf:"bytes,1201,opt,name=auth_role_delete,json=authRoleDelete" json:"auth_role_delete,omitempty"`
  53. AuthRoleGet *AuthRoleGetRequest `protobuf:"bytes,1202,opt,name=auth_role_get,json=authRoleGet" json:"auth_role_get,omitempty"`
  54. AuthRoleGrantPermission *AuthRoleGrantPermissionRequest `protobuf:"bytes,1203,opt,name=auth_role_grant_permission,json=authRoleGrantPermission" json:"auth_role_grant_permission,omitempty"`
  55. AuthRoleRevokePermission *AuthRoleRevokePermissionRequest `protobuf:"bytes,1204,opt,name=auth_role_revoke_permission,json=authRoleRevokePermission" json:"auth_role_revoke_permission,omitempty"`
  56. }
  57. func (m *InternalRaftRequest) Reset() { *m = InternalRaftRequest{} }
  58. func (m *InternalRaftRequest) String() string { return proto.CompactTextString(m) }
  59. func (*InternalRaftRequest) ProtoMessage() {}
  60. func (*InternalRaftRequest) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{1} }
  61. type EmptyResponse struct {
  62. }
  63. func (m *EmptyResponse) Reset() { *m = EmptyResponse{} }
  64. func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
  65. func (*EmptyResponse) ProtoMessage() {}
  66. func (*EmptyResponse) Descriptor() ([]byte, []int) { return fileDescriptorRaftInternal, []int{2} }
  67. // What is the difference between AuthenticateRequest (defined in rpc.proto) and InternalAuthenticateRequest?
  68. // InternalAuthenticateRequest has a member that is filled by etcdserver and shouldn't be user-facing.
  69. // For avoiding misusage the field, we have an internal version of AuthenticateRequest.
  70. type InternalAuthenticateRequest struct {
  71. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  72. Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
  73. // simple_token is generated in API layer (etcdserver/v3_server.go)
  74. SimpleToken string `protobuf:"bytes,3,opt,name=simple_token,json=simpleToken,proto3" json:"simple_token,omitempty"`
  75. }
  76. func (m *InternalAuthenticateRequest) Reset() { *m = InternalAuthenticateRequest{} }
  77. func (m *InternalAuthenticateRequest) String() string { return proto.CompactTextString(m) }
  78. func (*InternalAuthenticateRequest) ProtoMessage() {}
  79. func (*InternalAuthenticateRequest) Descriptor() ([]byte, []int) {
  80. return fileDescriptorRaftInternal, []int{3}
  81. }
  82. func init() {
  83. proto.RegisterType((*RequestHeader)(nil), "etcdserverpb.RequestHeader")
  84. proto.RegisterType((*InternalRaftRequest)(nil), "etcdserverpb.InternalRaftRequest")
  85. proto.RegisterType((*EmptyResponse)(nil), "etcdserverpb.EmptyResponse")
  86. proto.RegisterType((*InternalAuthenticateRequest)(nil), "etcdserverpb.InternalAuthenticateRequest")
  87. }
  88. func (m *RequestHeader) Marshal() (dAtA []byte, err error) {
  89. size := m.Size()
  90. dAtA = make([]byte, size)
  91. n, err := m.MarshalTo(dAtA)
  92. if err != nil {
  93. return nil, err
  94. }
  95. return dAtA[:n], nil
  96. }
  97. func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) {
  98. var i int
  99. _ = i
  100. var l int
  101. _ = l
  102. if m.ID != 0 {
  103. dAtA[i] = 0x8
  104. i++
  105. i = encodeVarintRaftInternal(dAtA, i, uint64(m.ID))
  106. }
  107. if len(m.Username) > 0 {
  108. dAtA[i] = 0x12
  109. i++
  110. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Username)))
  111. i += copy(dAtA[i:], m.Username)
  112. }
  113. if m.AuthRevision != 0 {
  114. dAtA[i] = 0x18
  115. i++
  116. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRevision))
  117. }
  118. return i, nil
  119. }
  120. func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error) {
  121. size := m.Size()
  122. dAtA = make([]byte, size)
  123. n, err := m.MarshalTo(dAtA)
  124. if err != nil {
  125. return nil, err
  126. }
  127. return dAtA[:n], nil
  128. }
  129. func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error) {
  130. var i int
  131. _ = i
  132. var l int
  133. _ = l
  134. if m.ID != 0 {
  135. dAtA[i] = 0x8
  136. i++
  137. i = encodeVarintRaftInternal(dAtA, i, uint64(m.ID))
  138. }
  139. if m.V2 != nil {
  140. dAtA[i] = 0x12
  141. i++
  142. i = encodeVarintRaftInternal(dAtA, i, uint64(m.V2.Size()))
  143. n1, err := m.V2.MarshalTo(dAtA[i:])
  144. if err != nil {
  145. return 0, err
  146. }
  147. i += n1
  148. }
  149. if m.Range != nil {
  150. dAtA[i] = 0x1a
  151. i++
  152. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Range.Size()))
  153. n2, err := m.Range.MarshalTo(dAtA[i:])
  154. if err != nil {
  155. return 0, err
  156. }
  157. i += n2
  158. }
  159. if m.Put != nil {
  160. dAtA[i] = 0x22
  161. i++
  162. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Put.Size()))
  163. n3, err := m.Put.MarshalTo(dAtA[i:])
  164. if err != nil {
  165. return 0, err
  166. }
  167. i += n3
  168. }
  169. if m.DeleteRange != nil {
  170. dAtA[i] = 0x2a
  171. i++
  172. i = encodeVarintRaftInternal(dAtA, i, uint64(m.DeleteRange.Size()))
  173. n4, err := m.DeleteRange.MarshalTo(dAtA[i:])
  174. if err != nil {
  175. return 0, err
  176. }
  177. i += n4
  178. }
  179. if m.Txn != nil {
  180. dAtA[i] = 0x32
  181. i++
  182. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Txn.Size()))
  183. n5, err := m.Txn.MarshalTo(dAtA[i:])
  184. if err != nil {
  185. return 0, err
  186. }
  187. i += n5
  188. }
  189. if m.Compaction != nil {
  190. dAtA[i] = 0x3a
  191. i++
  192. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Compaction.Size()))
  193. n6, err := m.Compaction.MarshalTo(dAtA[i:])
  194. if err != nil {
  195. return 0, err
  196. }
  197. i += n6
  198. }
  199. if m.LeaseGrant != nil {
  200. dAtA[i] = 0x42
  201. i++
  202. i = encodeVarintRaftInternal(dAtA, i, uint64(m.LeaseGrant.Size()))
  203. n7, err := m.LeaseGrant.MarshalTo(dAtA[i:])
  204. if err != nil {
  205. return 0, err
  206. }
  207. i += n7
  208. }
  209. if m.LeaseRevoke != nil {
  210. dAtA[i] = 0x4a
  211. i++
  212. i = encodeVarintRaftInternal(dAtA, i, uint64(m.LeaseRevoke.Size()))
  213. n8, err := m.LeaseRevoke.MarshalTo(dAtA[i:])
  214. if err != nil {
  215. return 0, err
  216. }
  217. i += n8
  218. }
  219. if m.Alarm != nil {
  220. dAtA[i] = 0x52
  221. i++
  222. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Alarm.Size()))
  223. n9, err := m.Alarm.MarshalTo(dAtA[i:])
  224. if err != nil {
  225. return 0, err
  226. }
  227. i += n9
  228. }
  229. if m.Header != nil {
  230. dAtA[i] = 0xa2
  231. i++
  232. dAtA[i] = 0x6
  233. i++
  234. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Header.Size()))
  235. n10, err := m.Header.MarshalTo(dAtA[i:])
  236. if err != nil {
  237. return 0, err
  238. }
  239. i += n10
  240. }
  241. if m.AuthEnable != nil {
  242. dAtA[i] = 0xc2
  243. i++
  244. dAtA[i] = 0x3e
  245. i++
  246. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthEnable.Size()))
  247. n11, err := m.AuthEnable.MarshalTo(dAtA[i:])
  248. if err != nil {
  249. return 0, err
  250. }
  251. i += n11
  252. }
  253. if m.AuthDisable != nil {
  254. dAtA[i] = 0x9a
  255. i++
  256. dAtA[i] = 0x3f
  257. i++
  258. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthDisable.Size()))
  259. n12, err := m.AuthDisable.MarshalTo(dAtA[i:])
  260. if err != nil {
  261. return 0, err
  262. }
  263. i += n12
  264. }
  265. if m.Authenticate != nil {
  266. dAtA[i] = 0xa2
  267. i++
  268. dAtA[i] = 0x3f
  269. i++
  270. i = encodeVarintRaftInternal(dAtA, i, uint64(m.Authenticate.Size()))
  271. n13, err := m.Authenticate.MarshalTo(dAtA[i:])
  272. if err != nil {
  273. return 0, err
  274. }
  275. i += n13
  276. }
  277. if m.AuthUserAdd != nil {
  278. dAtA[i] = 0xe2
  279. i++
  280. dAtA[i] = 0x44
  281. i++
  282. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserAdd.Size()))
  283. n14, err := m.AuthUserAdd.MarshalTo(dAtA[i:])
  284. if err != nil {
  285. return 0, err
  286. }
  287. i += n14
  288. }
  289. if m.AuthUserDelete != nil {
  290. dAtA[i] = 0xea
  291. i++
  292. dAtA[i] = 0x44
  293. i++
  294. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserDelete.Size()))
  295. n15, err := m.AuthUserDelete.MarshalTo(dAtA[i:])
  296. if err != nil {
  297. return 0, err
  298. }
  299. i += n15
  300. }
  301. if m.AuthUserGet != nil {
  302. dAtA[i] = 0xf2
  303. i++
  304. dAtA[i] = 0x44
  305. i++
  306. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserGet.Size()))
  307. n16, err := m.AuthUserGet.MarshalTo(dAtA[i:])
  308. if err != nil {
  309. return 0, err
  310. }
  311. i += n16
  312. }
  313. if m.AuthUserChangePassword != nil {
  314. dAtA[i] = 0xfa
  315. i++
  316. dAtA[i] = 0x44
  317. i++
  318. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserChangePassword.Size()))
  319. n17, err := m.AuthUserChangePassword.MarshalTo(dAtA[i:])
  320. if err != nil {
  321. return 0, err
  322. }
  323. i += n17
  324. }
  325. if m.AuthUserGrantRole != nil {
  326. dAtA[i] = 0x82
  327. i++
  328. dAtA[i] = 0x45
  329. i++
  330. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserGrantRole.Size()))
  331. n18, err := m.AuthUserGrantRole.MarshalTo(dAtA[i:])
  332. if err != nil {
  333. return 0, err
  334. }
  335. i += n18
  336. }
  337. if m.AuthUserRevokeRole != nil {
  338. dAtA[i] = 0x8a
  339. i++
  340. dAtA[i] = 0x45
  341. i++
  342. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserRevokeRole.Size()))
  343. n19, err := m.AuthUserRevokeRole.MarshalTo(dAtA[i:])
  344. if err != nil {
  345. return 0, err
  346. }
  347. i += n19
  348. }
  349. if m.AuthUserList != nil {
  350. dAtA[i] = 0x92
  351. i++
  352. dAtA[i] = 0x45
  353. i++
  354. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthUserList.Size()))
  355. n20, err := m.AuthUserList.MarshalTo(dAtA[i:])
  356. if err != nil {
  357. return 0, err
  358. }
  359. i += n20
  360. }
  361. if m.AuthRoleList != nil {
  362. dAtA[i] = 0x9a
  363. i++
  364. dAtA[i] = 0x45
  365. i++
  366. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleList.Size()))
  367. n21, err := m.AuthRoleList.MarshalTo(dAtA[i:])
  368. if err != nil {
  369. return 0, err
  370. }
  371. i += n21
  372. }
  373. if m.AuthRoleAdd != nil {
  374. dAtA[i] = 0x82
  375. i++
  376. dAtA[i] = 0x4b
  377. i++
  378. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleAdd.Size()))
  379. n22, err := m.AuthRoleAdd.MarshalTo(dAtA[i:])
  380. if err != nil {
  381. return 0, err
  382. }
  383. i += n22
  384. }
  385. if m.AuthRoleDelete != nil {
  386. dAtA[i] = 0x8a
  387. i++
  388. dAtA[i] = 0x4b
  389. i++
  390. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleDelete.Size()))
  391. n23, err := m.AuthRoleDelete.MarshalTo(dAtA[i:])
  392. if err != nil {
  393. return 0, err
  394. }
  395. i += n23
  396. }
  397. if m.AuthRoleGet != nil {
  398. dAtA[i] = 0x92
  399. i++
  400. dAtA[i] = 0x4b
  401. i++
  402. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleGet.Size()))
  403. n24, err := m.AuthRoleGet.MarshalTo(dAtA[i:])
  404. if err != nil {
  405. return 0, err
  406. }
  407. i += n24
  408. }
  409. if m.AuthRoleGrantPermission != nil {
  410. dAtA[i] = 0x9a
  411. i++
  412. dAtA[i] = 0x4b
  413. i++
  414. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleGrantPermission.Size()))
  415. n25, err := m.AuthRoleGrantPermission.MarshalTo(dAtA[i:])
  416. if err != nil {
  417. return 0, err
  418. }
  419. i += n25
  420. }
  421. if m.AuthRoleRevokePermission != nil {
  422. dAtA[i] = 0xa2
  423. i++
  424. dAtA[i] = 0x4b
  425. i++
  426. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRoleRevokePermission.Size()))
  427. n26, err := m.AuthRoleRevokePermission.MarshalTo(dAtA[i:])
  428. if err != nil {
  429. return 0, err
  430. }
  431. i += n26
  432. }
  433. return i, nil
  434. }
  435. func (m *EmptyResponse) Marshal() (dAtA []byte, err error) {
  436. size := m.Size()
  437. dAtA = make([]byte, size)
  438. n, err := m.MarshalTo(dAtA)
  439. if err != nil {
  440. return nil, err
  441. }
  442. return dAtA[:n], nil
  443. }
  444. func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error) {
  445. var i int
  446. _ = i
  447. var l int
  448. _ = l
  449. return i, nil
  450. }
  451. func (m *InternalAuthenticateRequest) Marshal() (dAtA []byte, err error) {
  452. size := m.Size()
  453. dAtA = make([]byte, size)
  454. n, err := m.MarshalTo(dAtA)
  455. if err != nil {
  456. return nil, err
  457. }
  458. return dAtA[:n], nil
  459. }
  460. func (m *InternalAuthenticateRequest) MarshalTo(dAtA []byte) (int, error) {
  461. var i int
  462. _ = i
  463. var l int
  464. _ = l
  465. if len(m.Name) > 0 {
  466. dAtA[i] = 0xa
  467. i++
  468. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Name)))
  469. i += copy(dAtA[i:], m.Name)
  470. }
  471. if len(m.Password) > 0 {
  472. dAtA[i] = 0x12
  473. i++
  474. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Password)))
  475. i += copy(dAtA[i:], m.Password)
  476. }
  477. if len(m.SimpleToken) > 0 {
  478. dAtA[i] = 0x1a
  479. i++
  480. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.SimpleToken)))
  481. i += copy(dAtA[i:], m.SimpleToken)
  482. }
  483. return i, nil
  484. }
  485. func encodeVarintRaftInternal(dAtA []byte, offset int, v uint64) int {
  486. for v >= 1<<7 {
  487. dAtA[offset] = uint8(v&0x7f | 0x80)
  488. v >>= 7
  489. offset++
  490. }
  491. dAtA[offset] = uint8(v)
  492. return offset + 1
  493. }
  494. func (m *RequestHeader) Size() (n int) {
  495. var l int
  496. _ = l
  497. if m.ID != 0 {
  498. n += 1 + sovRaftInternal(uint64(m.ID))
  499. }
  500. l = len(m.Username)
  501. if l > 0 {
  502. n += 1 + l + sovRaftInternal(uint64(l))
  503. }
  504. if m.AuthRevision != 0 {
  505. n += 1 + sovRaftInternal(uint64(m.AuthRevision))
  506. }
  507. return n
  508. }
  509. func (m *InternalRaftRequest) Size() (n int) {
  510. var l int
  511. _ = l
  512. if m.ID != 0 {
  513. n += 1 + sovRaftInternal(uint64(m.ID))
  514. }
  515. if m.V2 != nil {
  516. l = m.V2.Size()
  517. n += 1 + l + sovRaftInternal(uint64(l))
  518. }
  519. if m.Range != nil {
  520. l = m.Range.Size()
  521. n += 1 + l + sovRaftInternal(uint64(l))
  522. }
  523. if m.Put != nil {
  524. l = m.Put.Size()
  525. n += 1 + l + sovRaftInternal(uint64(l))
  526. }
  527. if m.DeleteRange != nil {
  528. l = m.DeleteRange.Size()
  529. n += 1 + l + sovRaftInternal(uint64(l))
  530. }
  531. if m.Txn != nil {
  532. l = m.Txn.Size()
  533. n += 1 + l + sovRaftInternal(uint64(l))
  534. }
  535. if m.Compaction != nil {
  536. l = m.Compaction.Size()
  537. n += 1 + l + sovRaftInternal(uint64(l))
  538. }
  539. if m.LeaseGrant != nil {
  540. l = m.LeaseGrant.Size()
  541. n += 1 + l + sovRaftInternal(uint64(l))
  542. }
  543. if m.LeaseRevoke != nil {
  544. l = m.LeaseRevoke.Size()
  545. n += 1 + l + sovRaftInternal(uint64(l))
  546. }
  547. if m.Alarm != nil {
  548. l = m.Alarm.Size()
  549. n += 1 + l + sovRaftInternal(uint64(l))
  550. }
  551. if m.Header != nil {
  552. l = m.Header.Size()
  553. n += 2 + l + sovRaftInternal(uint64(l))
  554. }
  555. if m.AuthEnable != nil {
  556. l = m.AuthEnable.Size()
  557. n += 2 + l + sovRaftInternal(uint64(l))
  558. }
  559. if m.AuthDisable != nil {
  560. l = m.AuthDisable.Size()
  561. n += 2 + l + sovRaftInternal(uint64(l))
  562. }
  563. if m.Authenticate != nil {
  564. l = m.Authenticate.Size()
  565. n += 2 + l + sovRaftInternal(uint64(l))
  566. }
  567. if m.AuthUserAdd != nil {
  568. l = m.AuthUserAdd.Size()
  569. n += 2 + l + sovRaftInternal(uint64(l))
  570. }
  571. if m.AuthUserDelete != nil {
  572. l = m.AuthUserDelete.Size()
  573. n += 2 + l + sovRaftInternal(uint64(l))
  574. }
  575. if m.AuthUserGet != nil {
  576. l = m.AuthUserGet.Size()
  577. n += 2 + l + sovRaftInternal(uint64(l))
  578. }
  579. if m.AuthUserChangePassword != nil {
  580. l = m.AuthUserChangePassword.Size()
  581. n += 2 + l + sovRaftInternal(uint64(l))
  582. }
  583. if m.AuthUserGrantRole != nil {
  584. l = m.AuthUserGrantRole.Size()
  585. n += 2 + l + sovRaftInternal(uint64(l))
  586. }
  587. if m.AuthUserRevokeRole != nil {
  588. l = m.AuthUserRevokeRole.Size()
  589. n += 2 + l + sovRaftInternal(uint64(l))
  590. }
  591. if m.AuthUserList != nil {
  592. l = m.AuthUserList.Size()
  593. n += 2 + l + sovRaftInternal(uint64(l))
  594. }
  595. if m.AuthRoleList != nil {
  596. l = m.AuthRoleList.Size()
  597. n += 2 + l + sovRaftInternal(uint64(l))
  598. }
  599. if m.AuthRoleAdd != nil {
  600. l = m.AuthRoleAdd.Size()
  601. n += 2 + l + sovRaftInternal(uint64(l))
  602. }
  603. if m.AuthRoleDelete != nil {
  604. l = m.AuthRoleDelete.Size()
  605. n += 2 + l + sovRaftInternal(uint64(l))
  606. }
  607. if m.AuthRoleGet != nil {
  608. l = m.AuthRoleGet.Size()
  609. n += 2 + l + sovRaftInternal(uint64(l))
  610. }
  611. if m.AuthRoleGrantPermission != nil {
  612. l = m.AuthRoleGrantPermission.Size()
  613. n += 2 + l + sovRaftInternal(uint64(l))
  614. }
  615. if m.AuthRoleRevokePermission != nil {
  616. l = m.AuthRoleRevokePermission.Size()
  617. n += 2 + l + sovRaftInternal(uint64(l))
  618. }
  619. return n
  620. }
  621. func (m *EmptyResponse) Size() (n int) {
  622. var l int
  623. _ = l
  624. return n
  625. }
  626. func (m *InternalAuthenticateRequest) Size() (n int) {
  627. var l int
  628. _ = l
  629. l = len(m.Name)
  630. if l > 0 {
  631. n += 1 + l + sovRaftInternal(uint64(l))
  632. }
  633. l = len(m.Password)
  634. if l > 0 {
  635. n += 1 + l + sovRaftInternal(uint64(l))
  636. }
  637. l = len(m.SimpleToken)
  638. if l > 0 {
  639. n += 1 + l + sovRaftInternal(uint64(l))
  640. }
  641. return n
  642. }
  643. func sovRaftInternal(x uint64) (n int) {
  644. for {
  645. n++
  646. x >>= 7
  647. if x == 0 {
  648. break
  649. }
  650. }
  651. return n
  652. }
  653. func sozRaftInternal(x uint64) (n int) {
  654. return sovRaftInternal(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  655. }
  656. func (m *RequestHeader) Unmarshal(dAtA []byte) error {
  657. l := len(dAtA)
  658. iNdEx := 0
  659. for iNdEx < l {
  660. preIndex := iNdEx
  661. var wire uint64
  662. for shift := uint(0); ; shift += 7 {
  663. if shift >= 64 {
  664. return ErrIntOverflowRaftInternal
  665. }
  666. if iNdEx >= l {
  667. return io.ErrUnexpectedEOF
  668. }
  669. b := dAtA[iNdEx]
  670. iNdEx++
  671. wire |= (uint64(b) & 0x7F) << shift
  672. if b < 0x80 {
  673. break
  674. }
  675. }
  676. fieldNum := int32(wire >> 3)
  677. wireType := int(wire & 0x7)
  678. if wireType == 4 {
  679. return fmt.Errorf("proto: RequestHeader: wiretype end group for non-group")
  680. }
  681. if fieldNum <= 0 {
  682. return fmt.Errorf("proto: RequestHeader: illegal tag %d (wire type %d)", fieldNum, wire)
  683. }
  684. switch fieldNum {
  685. case 1:
  686. if wireType != 0 {
  687. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  688. }
  689. m.ID = 0
  690. for shift := uint(0); ; shift += 7 {
  691. if shift >= 64 {
  692. return ErrIntOverflowRaftInternal
  693. }
  694. if iNdEx >= l {
  695. return io.ErrUnexpectedEOF
  696. }
  697. b := dAtA[iNdEx]
  698. iNdEx++
  699. m.ID |= (uint64(b) & 0x7F) << shift
  700. if b < 0x80 {
  701. break
  702. }
  703. }
  704. case 2:
  705. if wireType != 2 {
  706. return fmt.Errorf("proto: wrong wireType = %d for field Username", wireType)
  707. }
  708. var stringLen uint64
  709. for shift := uint(0); ; shift += 7 {
  710. if shift >= 64 {
  711. return ErrIntOverflowRaftInternal
  712. }
  713. if iNdEx >= l {
  714. return io.ErrUnexpectedEOF
  715. }
  716. b := dAtA[iNdEx]
  717. iNdEx++
  718. stringLen |= (uint64(b) & 0x7F) << shift
  719. if b < 0x80 {
  720. break
  721. }
  722. }
  723. intStringLen := int(stringLen)
  724. if intStringLen < 0 {
  725. return ErrInvalidLengthRaftInternal
  726. }
  727. postIndex := iNdEx + intStringLen
  728. if postIndex > l {
  729. return io.ErrUnexpectedEOF
  730. }
  731. m.Username = string(dAtA[iNdEx:postIndex])
  732. iNdEx = postIndex
  733. case 3:
  734. if wireType != 0 {
  735. return fmt.Errorf("proto: wrong wireType = %d for field AuthRevision", wireType)
  736. }
  737. m.AuthRevision = 0
  738. for shift := uint(0); ; shift += 7 {
  739. if shift >= 64 {
  740. return ErrIntOverflowRaftInternal
  741. }
  742. if iNdEx >= l {
  743. return io.ErrUnexpectedEOF
  744. }
  745. b := dAtA[iNdEx]
  746. iNdEx++
  747. m.AuthRevision |= (uint64(b) & 0x7F) << shift
  748. if b < 0x80 {
  749. break
  750. }
  751. }
  752. default:
  753. iNdEx = preIndex
  754. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  755. if err != nil {
  756. return err
  757. }
  758. if skippy < 0 {
  759. return ErrInvalidLengthRaftInternal
  760. }
  761. if (iNdEx + skippy) > l {
  762. return io.ErrUnexpectedEOF
  763. }
  764. iNdEx += skippy
  765. }
  766. }
  767. if iNdEx > l {
  768. return io.ErrUnexpectedEOF
  769. }
  770. return nil
  771. }
  772. func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error {
  773. l := len(dAtA)
  774. iNdEx := 0
  775. for iNdEx < l {
  776. preIndex := iNdEx
  777. var wire uint64
  778. for shift := uint(0); ; shift += 7 {
  779. if shift >= 64 {
  780. return ErrIntOverflowRaftInternal
  781. }
  782. if iNdEx >= l {
  783. return io.ErrUnexpectedEOF
  784. }
  785. b := dAtA[iNdEx]
  786. iNdEx++
  787. wire |= (uint64(b) & 0x7F) << shift
  788. if b < 0x80 {
  789. break
  790. }
  791. }
  792. fieldNum := int32(wire >> 3)
  793. wireType := int(wire & 0x7)
  794. if wireType == 4 {
  795. return fmt.Errorf("proto: InternalRaftRequest: wiretype end group for non-group")
  796. }
  797. if fieldNum <= 0 {
  798. return fmt.Errorf("proto: InternalRaftRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  799. }
  800. switch fieldNum {
  801. case 1:
  802. if wireType != 0 {
  803. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  804. }
  805. m.ID = 0
  806. for shift := uint(0); ; shift += 7 {
  807. if shift >= 64 {
  808. return ErrIntOverflowRaftInternal
  809. }
  810. if iNdEx >= l {
  811. return io.ErrUnexpectedEOF
  812. }
  813. b := dAtA[iNdEx]
  814. iNdEx++
  815. m.ID |= (uint64(b) & 0x7F) << shift
  816. if b < 0x80 {
  817. break
  818. }
  819. }
  820. case 2:
  821. if wireType != 2 {
  822. return fmt.Errorf("proto: wrong wireType = %d for field V2", wireType)
  823. }
  824. var msglen int
  825. for shift := uint(0); ; shift += 7 {
  826. if shift >= 64 {
  827. return ErrIntOverflowRaftInternal
  828. }
  829. if iNdEx >= l {
  830. return io.ErrUnexpectedEOF
  831. }
  832. b := dAtA[iNdEx]
  833. iNdEx++
  834. msglen |= (int(b) & 0x7F) << shift
  835. if b < 0x80 {
  836. break
  837. }
  838. }
  839. if msglen < 0 {
  840. return ErrInvalidLengthRaftInternal
  841. }
  842. postIndex := iNdEx + msglen
  843. if postIndex > l {
  844. return io.ErrUnexpectedEOF
  845. }
  846. if m.V2 == nil {
  847. m.V2 = &Request{}
  848. }
  849. if err := m.V2.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  850. return err
  851. }
  852. iNdEx = postIndex
  853. case 3:
  854. if wireType != 2 {
  855. return fmt.Errorf("proto: wrong wireType = %d for field Range", wireType)
  856. }
  857. var msglen int
  858. for shift := uint(0); ; shift += 7 {
  859. if shift >= 64 {
  860. return ErrIntOverflowRaftInternal
  861. }
  862. if iNdEx >= l {
  863. return io.ErrUnexpectedEOF
  864. }
  865. b := dAtA[iNdEx]
  866. iNdEx++
  867. msglen |= (int(b) & 0x7F) << shift
  868. if b < 0x80 {
  869. break
  870. }
  871. }
  872. if msglen < 0 {
  873. return ErrInvalidLengthRaftInternal
  874. }
  875. postIndex := iNdEx + msglen
  876. if postIndex > l {
  877. return io.ErrUnexpectedEOF
  878. }
  879. if m.Range == nil {
  880. m.Range = &RangeRequest{}
  881. }
  882. if err := m.Range.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  883. return err
  884. }
  885. iNdEx = postIndex
  886. case 4:
  887. if wireType != 2 {
  888. return fmt.Errorf("proto: wrong wireType = %d for field Put", wireType)
  889. }
  890. var msglen int
  891. for shift := uint(0); ; shift += 7 {
  892. if shift >= 64 {
  893. return ErrIntOverflowRaftInternal
  894. }
  895. if iNdEx >= l {
  896. return io.ErrUnexpectedEOF
  897. }
  898. b := dAtA[iNdEx]
  899. iNdEx++
  900. msglen |= (int(b) & 0x7F) << shift
  901. if b < 0x80 {
  902. break
  903. }
  904. }
  905. if msglen < 0 {
  906. return ErrInvalidLengthRaftInternal
  907. }
  908. postIndex := iNdEx + msglen
  909. if postIndex > l {
  910. return io.ErrUnexpectedEOF
  911. }
  912. if m.Put == nil {
  913. m.Put = &PutRequest{}
  914. }
  915. if err := m.Put.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  916. return err
  917. }
  918. iNdEx = postIndex
  919. case 5:
  920. if wireType != 2 {
  921. return fmt.Errorf("proto: wrong wireType = %d for field DeleteRange", wireType)
  922. }
  923. var msglen int
  924. for shift := uint(0); ; shift += 7 {
  925. if shift >= 64 {
  926. return ErrIntOverflowRaftInternal
  927. }
  928. if iNdEx >= l {
  929. return io.ErrUnexpectedEOF
  930. }
  931. b := dAtA[iNdEx]
  932. iNdEx++
  933. msglen |= (int(b) & 0x7F) << shift
  934. if b < 0x80 {
  935. break
  936. }
  937. }
  938. if msglen < 0 {
  939. return ErrInvalidLengthRaftInternal
  940. }
  941. postIndex := iNdEx + msglen
  942. if postIndex > l {
  943. return io.ErrUnexpectedEOF
  944. }
  945. if m.DeleteRange == nil {
  946. m.DeleteRange = &DeleteRangeRequest{}
  947. }
  948. if err := m.DeleteRange.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  949. return err
  950. }
  951. iNdEx = postIndex
  952. case 6:
  953. if wireType != 2 {
  954. return fmt.Errorf("proto: wrong wireType = %d for field Txn", wireType)
  955. }
  956. var msglen int
  957. for shift := uint(0); ; shift += 7 {
  958. if shift >= 64 {
  959. return ErrIntOverflowRaftInternal
  960. }
  961. if iNdEx >= l {
  962. return io.ErrUnexpectedEOF
  963. }
  964. b := dAtA[iNdEx]
  965. iNdEx++
  966. msglen |= (int(b) & 0x7F) << shift
  967. if b < 0x80 {
  968. break
  969. }
  970. }
  971. if msglen < 0 {
  972. return ErrInvalidLengthRaftInternal
  973. }
  974. postIndex := iNdEx + msglen
  975. if postIndex > l {
  976. return io.ErrUnexpectedEOF
  977. }
  978. if m.Txn == nil {
  979. m.Txn = &TxnRequest{}
  980. }
  981. if err := m.Txn.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  982. return err
  983. }
  984. iNdEx = postIndex
  985. case 7:
  986. if wireType != 2 {
  987. return fmt.Errorf("proto: wrong wireType = %d for field Compaction", wireType)
  988. }
  989. var msglen int
  990. for shift := uint(0); ; shift += 7 {
  991. if shift >= 64 {
  992. return ErrIntOverflowRaftInternal
  993. }
  994. if iNdEx >= l {
  995. return io.ErrUnexpectedEOF
  996. }
  997. b := dAtA[iNdEx]
  998. iNdEx++
  999. msglen |= (int(b) & 0x7F) << shift
  1000. if b < 0x80 {
  1001. break
  1002. }
  1003. }
  1004. if msglen < 0 {
  1005. return ErrInvalidLengthRaftInternal
  1006. }
  1007. postIndex := iNdEx + msglen
  1008. if postIndex > l {
  1009. return io.ErrUnexpectedEOF
  1010. }
  1011. if m.Compaction == nil {
  1012. m.Compaction = &CompactionRequest{}
  1013. }
  1014. if err := m.Compaction.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1015. return err
  1016. }
  1017. iNdEx = postIndex
  1018. case 8:
  1019. if wireType != 2 {
  1020. return fmt.Errorf("proto: wrong wireType = %d for field LeaseGrant", wireType)
  1021. }
  1022. var msglen int
  1023. for shift := uint(0); ; shift += 7 {
  1024. if shift >= 64 {
  1025. return ErrIntOverflowRaftInternal
  1026. }
  1027. if iNdEx >= l {
  1028. return io.ErrUnexpectedEOF
  1029. }
  1030. b := dAtA[iNdEx]
  1031. iNdEx++
  1032. msglen |= (int(b) & 0x7F) << shift
  1033. if b < 0x80 {
  1034. break
  1035. }
  1036. }
  1037. if msglen < 0 {
  1038. return ErrInvalidLengthRaftInternal
  1039. }
  1040. postIndex := iNdEx + msglen
  1041. if postIndex > l {
  1042. return io.ErrUnexpectedEOF
  1043. }
  1044. if m.LeaseGrant == nil {
  1045. m.LeaseGrant = &LeaseGrantRequest{}
  1046. }
  1047. if err := m.LeaseGrant.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1048. return err
  1049. }
  1050. iNdEx = postIndex
  1051. case 9:
  1052. if wireType != 2 {
  1053. return fmt.Errorf("proto: wrong wireType = %d for field LeaseRevoke", wireType)
  1054. }
  1055. var msglen int
  1056. for shift := uint(0); ; shift += 7 {
  1057. if shift >= 64 {
  1058. return ErrIntOverflowRaftInternal
  1059. }
  1060. if iNdEx >= l {
  1061. return io.ErrUnexpectedEOF
  1062. }
  1063. b := dAtA[iNdEx]
  1064. iNdEx++
  1065. msglen |= (int(b) & 0x7F) << shift
  1066. if b < 0x80 {
  1067. break
  1068. }
  1069. }
  1070. if msglen < 0 {
  1071. return ErrInvalidLengthRaftInternal
  1072. }
  1073. postIndex := iNdEx + msglen
  1074. if postIndex > l {
  1075. return io.ErrUnexpectedEOF
  1076. }
  1077. if m.LeaseRevoke == nil {
  1078. m.LeaseRevoke = &LeaseRevokeRequest{}
  1079. }
  1080. if err := m.LeaseRevoke.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1081. return err
  1082. }
  1083. iNdEx = postIndex
  1084. case 10:
  1085. if wireType != 2 {
  1086. return fmt.Errorf("proto: wrong wireType = %d for field Alarm", wireType)
  1087. }
  1088. var msglen int
  1089. for shift := uint(0); ; shift += 7 {
  1090. if shift >= 64 {
  1091. return ErrIntOverflowRaftInternal
  1092. }
  1093. if iNdEx >= l {
  1094. return io.ErrUnexpectedEOF
  1095. }
  1096. b := dAtA[iNdEx]
  1097. iNdEx++
  1098. msglen |= (int(b) & 0x7F) << shift
  1099. if b < 0x80 {
  1100. break
  1101. }
  1102. }
  1103. if msglen < 0 {
  1104. return ErrInvalidLengthRaftInternal
  1105. }
  1106. postIndex := iNdEx + msglen
  1107. if postIndex > l {
  1108. return io.ErrUnexpectedEOF
  1109. }
  1110. if m.Alarm == nil {
  1111. m.Alarm = &AlarmRequest{}
  1112. }
  1113. if err := m.Alarm.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1114. return err
  1115. }
  1116. iNdEx = postIndex
  1117. case 100:
  1118. if wireType != 2 {
  1119. return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
  1120. }
  1121. var msglen int
  1122. for shift := uint(0); ; shift += 7 {
  1123. if shift >= 64 {
  1124. return ErrIntOverflowRaftInternal
  1125. }
  1126. if iNdEx >= l {
  1127. return io.ErrUnexpectedEOF
  1128. }
  1129. b := dAtA[iNdEx]
  1130. iNdEx++
  1131. msglen |= (int(b) & 0x7F) << shift
  1132. if b < 0x80 {
  1133. break
  1134. }
  1135. }
  1136. if msglen < 0 {
  1137. return ErrInvalidLengthRaftInternal
  1138. }
  1139. postIndex := iNdEx + msglen
  1140. if postIndex > l {
  1141. return io.ErrUnexpectedEOF
  1142. }
  1143. if m.Header == nil {
  1144. m.Header = &RequestHeader{}
  1145. }
  1146. if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1147. return err
  1148. }
  1149. iNdEx = postIndex
  1150. case 1000:
  1151. if wireType != 2 {
  1152. return fmt.Errorf("proto: wrong wireType = %d for field AuthEnable", wireType)
  1153. }
  1154. var msglen int
  1155. for shift := uint(0); ; shift += 7 {
  1156. if shift >= 64 {
  1157. return ErrIntOverflowRaftInternal
  1158. }
  1159. if iNdEx >= l {
  1160. return io.ErrUnexpectedEOF
  1161. }
  1162. b := dAtA[iNdEx]
  1163. iNdEx++
  1164. msglen |= (int(b) & 0x7F) << shift
  1165. if b < 0x80 {
  1166. break
  1167. }
  1168. }
  1169. if msglen < 0 {
  1170. return ErrInvalidLengthRaftInternal
  1171. }
  1172. postIndex := iNdEx + msglen
  1173. if postIndex > l {
  1174. return io.ErrUnexpectedEOF
  1175. }
  1176. if m.AuthEnable == nil {
  1177. m.AuthEnable = &AuthEnableRequest{}
  1178. }
  1179. if err := m.AuthEnable.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1180. return err
  1181. }
  1182. iNdEx = postIndex
  1183. case 1011:
  1184. if wireType != 2 {
  1185. return fmt.Errorf("proto: wrong wireType = %d for field AuthDisable", wireType)
  1186. }
  1187. var msglen int
  1188. for shift := uint(0); ; shift += 7 {
  1189. if shift >= 64 {
  1190. return ErrIntOverflowRaftInternal
  1191. }
  1192. if iNdEx >= l {
  1193. return io.ErrUnexpectedEOF
  1194. }
  1195. b := dAtA[iNdEx]
  1196. iNdEx++
  1197. msglen |= (int(b) & 0x7F) << shift
  1198. if b < 0x80 {
  1199. break
  1200. }
  1201. }
  1202. if msglen < 0 {
  1203. return ErrInvalidLengthRaftInternal
  1204. }
  1205. postIndex := iNdEx + msglen
  1206. if postIndex > l {
  1207. return io.ErrUnexpectedEOF
  1208. }
  1209. if m.AuthDisable == nil {
  1210. m.AuthDisable = &AuthDisableRequest{}
  1211. }
  1212. if err := m.AuthDisable.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1213. return err
  1214. }
  1215. iNdEx = postIndex
  1216. case 1012:
  1217. if wireType != 2 {
  1218. return fmt.Errorf("proto: wrong wireType = %d for field Authenticate", wireType)
  1219. }
  1220. var msglen int
  1221. for shift := uint(0); ; shift += 7 {
  1222. if shift >= 64 {
  1223. return ErrIntOverflowRaftInternal
  1224. }
  1225. if iNdEx >= l {
  1226. return io.ErrUnexpectedEOF
  1227. }
  1228. b := dAtA[iNdEx]
  1229. iNdEx++
  1230. msglen |= (int(b) & 0x7F) << shift
  1231. if b < 0x80 {
  1232. break
  1233. }
  1234. }
  1235. if msglen < 0 {
  1236. return ErrInvalidLengthRaftInternal
  1237. }
  1238. postIndex := iNdEx + msglen
  1239. if postIndex > l {
  1240. return io.ErrUnexpectedEOF
  1241. }
  1242. if m.Authenticate == nil {
  1243. m.Authenticate = &InternalAuthenticateRequest{}
  1244. }
  1245. if err := m.Authenticate.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1246. return err
  1247. }
  1248. iNdEx = postIndex
  1249. case 1100:
  1250. if wireType != 2 {
  1251. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserAdd", wireType)
  1252. }
  1253. var msglen int
  1254. for shift := uint(0); ; shift += 7 {
  1255. if shift >= 64 {
  1256. return ErrIntOverflowRaftInternal
  1257. }
  1258. if iNdEx >= l {
  1259. return io.ErrUnexpectedEOF
  1260. }
  1261. b := dAtA[iNdEx]
  1262. iNdEx++
  1263. msglen |= (int(b) & 0x7F) << shift
  1264. if b < 0x80 {
  1265. break
  1266. }
  1267. }
  1268. if msglen < 0 {
  1269. return ErrInvalidLengthRaftInternal
  1270. }
  1271. postIndex := iNdEx + msglen
  1272. if postIndex > l {
  1273. return io.ErrUnexpectedEOF
  1274. }
  1275. if m.AuthUserAdd == nil {
  1276. m.AuthUserAdd = &AuthUserAddRequest{}
  1277. }
  1278. if err := m.AuthUserAdd.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1279. return err
  1280. }
  1281. iNdEx = postIndex
  1282. case 1101:
  1283. if wireType != 2 {
  1284. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserDelete", wireType)
  1285. }
  1286. var msglen int
  1287. for shift := uint(0); ; shift += 7 {
  1288. if shift >= 64 {
  1289. return ErrIntOverflowRaftInternal
  1290. }
  1291. if iNdEx >= l {
  1292. return io.ErrUnexpectedEOF
  1293. }
  1294. b := dAtA[iNdEx]
  1295. iNdEx++
  1296. msglen |= (int(b) & 0x7F) << shift
  1297. if b < 0x80 {
  1298. break
  1299. }
  1300. }
  1301. if msglen < 0 {
  1302. return ErrInvalidLengthRaftInternal
  1303. }
  1304. postIndex := iNdEx + msglen
  1305. if postIndex > l {
  1306. return io.ErrUnexpectedEOF
  1307. }
  1308. if m.AuthUserDelete == nil {
  1309. m.AuthUserDelete = &AuthUserDeleteRequest{}
  1310. }
  1311. if err := m.AuthUserDelete.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1312. return err
  1313. }
  1314. iNdEx = postIndex
  1315. case 1102:
  1316. if wireType != 2 {
  1317. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGet", wireType)
  1318. }
  1319. var msglen int
  1320. for shift := uint(0); ; shift += 7 {
  1321. if shift >= 64 {
  1322. return ErrIntOverflowRaftInternal
  1323. }
  1324. if iNdEx >= l {
  1325. return io.ErrUnexpectedEOF
  1326. }
  1327. b := dAtA[iNdEx]
  1328. iNdEx++
  1329. msglen |= (int(b) & 0x7F) << shift
  1330. if b < 0x80 {
  1331. break
  1332. }
  1333. }
  1334. if msglen < 0 {
  1335. return ErrInvalidLengthRaftInternal
  1336. }
  1337. postIndex := iNdEx + msglen
  1338. if postIndex > l {
  1339. return io.ErrUnexpectedEOF
  1340. }
  1341. if m.AuthUserGet == nil {
  1342. m.AuthUserGet = &AuthUserGetRequest{}
  1343. }
  1344. if err := m.AuthUserGet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1345. return err
  1346. }
  1347. iNdEx = postIndex
  1348. case 1103:
  1349. if wireType != 2 {
  1350. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserChangePassword", wireType)
  1351. }
  1352. var msglen int
  1353. for shift := uint(0); ; shift += 7 {
  1354. if shift >= 64 {
  1355. return ErrIntOverflowRaftInternal
  1356. }
  1357. if iNdEx >= l {
  1358. return io.ErrUnexpectedEOF
  1359. }
  1360. b := dAtA[iNdEx]
  1361. iNdEx++
  1362. msglen |= (int(b) & 0x7F) << shift
  1363. if b < 0x80 {
  1364. break
  1365. }
  1366. }
  1367. if msglen < 0 {
  1368. return ErrInvalidLengthRaftInternal
  1369. }
  1370. postIndex := iNdEx + msglen
  1371. if postIndex > l {
  1372. return io.ErrUnexpectedEOF
  1373. }
  1374. if m.AuthUserChangePassword == nil {
  1375. m.AuthUserChangePassword = &AuthUserChangePasswordRequest{}
  1376. }
  1377. if err := m.AuthUserChangePassword.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1378. return err
  1379. }
  1380. iNdEx = postIndex
  1381. case 1104:
  1382. if wireType != 2 {
  1383. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGrantRole", wireType)
  1384. }
  1385. var msglen int
  1386. for shift := uint(0); ; shift += 7 {
  1387. if shift >= 64 {
  1388. return ErrIntOverflowRaftInternal
  1389. }
  1390. if iNdEx >= l {
  1391. return io.ErrUnexpectedEOF
  1392. }
  1393. b := dAtA[iNdEx]
  1394. iNdEx++
  1395. msglen |= (int(b) & 0x7F) << shift
  1396. if b < 0x80 {
  1397. break
  1398. }
  1399. }
  1400. if msglen < 0 {
  1401. return ErrInvalidLengthRaftInternal
  1402. }
  1403. postIndex := iNdEx + msglen
  1404. if postIndex > l {
  1405. return io.ErrUnexpectedEOF
  1406. }
  1407. if m.AuthUserGrantRole == nil {
  1408. m.AuthUserGrantRole = &AuthUserGrantRoleRequest{}
  1409. }
  1410. if err := m.AuthUserGrantRole.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1411. return err
  1412. }
  1413. iNdEx = postIndex
  1414. case 1105:
  1415. if wireType != 2 {
  1416. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserRevokeRole", wireType)
  1417. }
  1418. var msglen int
  1419. for shift := uint(0); ; shift += 7 {
  1420. if shift >= 64 {
  1421. return ErrIntOverflowRaftInternal
  1422. }
  1423. if iNdEx >= l {
  1424. return io.ErrUnexpectedEOF
  1425. }
  1426. b := dAtA[iNdEx]
  1427. iNdEx++
  1428. msglen |= (int(b) & 0x7F) << shift
  1429. if b < 0x80 {
  1430. break
  1431. }
  1432. }
  1433. if msglen < 0 {
  1434. return ErrInvalidLengthRaftInternal
  1435. }
  1436. postIndex := iNdEx + msglen
  1437. if postIndex > l {
  1438. return io.ErrUnexpectedEOF
  1439. }
  1440. if m.AuthUserRevokeRole == nil {
  1441. m.AuthUserRevokeRole = &AuthUserRevokeRoleRequest{}
  1442. }
  1443. if err := m.AuthUserRevokeRole.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1444. return err
  1445. }
  1446. iNdEx = postIndex
  1447. case 1106:
  1448. if wireType != 2 {
  1449. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserList", wireType)
  1450. }
  1451. var msglen int
  1452. for shift := uint(0); ; shift += 7 {
  1453. if shift >= 64 {
  1454. return ErrIntOverflowRaftInternal
  1455. }
  1456. if iNdEx >= l {
  1457. return io.ErrUnexpectedEOF
  1458. }
  1459. b := dAtA[iNdEx]
  1460. iNdEx++
  1461. msglen |= (int(b) & 0x7F) << shift
  1462. if b < 0x80 {
  1463. break
  1464. }
  1465. }
  1466. if msglen < 0 {
  1467. return ErrInvalidLengthRaftInternal
  1468. }
  1469. postIndex := iNdEx + msglen
  1470. if postIndex > l {
  1471. return io.ErrUnexpectedEOF
  1472. }
  1473. if m.AuthUserList == nil {
  1474. m.AuthUserList = &AuthUserListRequest{}
  1475. }
  1476. if err := m.AuthUserList.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1477. return err
  1478. }
  1479. iNdEx = postIndex
  1480. case 1107:
  1481. if wireType != 2 {
  1482. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleList", wireType)
  1483. }
  1484. var msglen int
  1485. for shift := uint(0); ; shift += 7 {
  1486. if shift >= 64 {
  1487. return ErrIntOverflowRaftInternal
  1488. }
  1489. if iNdEx >= l {
  1490. return io.ErrUnexpectedEOF
  1491. }
  1492. b := dAtA[iNdEx]
  1493. iNdEx++
  1494. msglen |= (int(b) & 0x7F) << shift
  1495. if b < 0x80 {
  1496. break
  1497. }
  1498. }
  1499. if msglen < 0 {
  1500. return ErrInvalidLengthRaftInternal
  1501. }
  1502. postIndex := iNdEx + msglen
  1503. if postIndex > l {
  1504. return io.ErrUnexpectedEOF
  1505. }
  1506. if m.AuthRoleList == nil {
  1507. m.AuthRoleList = &AuthRoleListRequest{}
  1508. }
  1509. if err := m.AuthRoleList.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1510. return err
  1511. }
  1512. iNdEx = postIndex
  1513. case 1200:
  1514. if wireType != 2 {
  1515. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleAdd", wireType)
  1516. }
  1517. var msglen int
  1518. for shift := uint(0); ; shift += 7 {
  1519. if shift >= 64 {
  1520. return ErrIntOverflowRaftInternal
  1521. }
  1522. if iNdEx >= l {
  1523. return io.ErrUnexpectedEOF
  1524. }
  1525. b := dAtA[iNdEx]
  1526. iNdEx++
  1527. msglen |= (int(b) & 0x7F) << shift
  1528. if b < 0x80 {
  1529. break
  1530. }
  1531. }
  1532. if msglen < 0 {
  1533. return ErrInvalidLengthRaftInternal
  1534. }
  1535. postIndex := iNdEx + msglen
  1536. if postIndex > l {
  1537. return io.ErrUnexpectedEOF
  1538. }
  1539. if m.AuthRoleAdd == nil {
  1540. m.AuthRoleAdd = &AuthRoleAddRequest{}
  1541. }
  1542. if err := m.AuthRoleAdd.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1543. return err
  1544. }
  1545. iNdEx = postIndex
  1546. case 1201:
  1547. if wireType != 2 {
  1548. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleDelete", wireType)
  1549. }
  1550. var msglen int
  1551. for shift := uint(0); ; shift += 7 {
  1552. if shift >= 64 {
  1553. return ErrIntOverflowRaftInternal
  1554. }
  1555. if iNdEx >= l {
  1556. return io.ErrUnexpectedEOF
  1557. }
  1558. b := dAtA[iNdEx]
  1559. iNdEx++
  1560. msglen |= (int(b) & 0x7F) << shift
  1561. if b < 0x80 {
  1562. break
  1563. }
  1564. }
  1565. if msglen < 0 {
  1566. return ErrInvalidLengthRaftInternal
  1567. }
  1568. postIndex := iNdEx + msglen
  1569. if postIndex > l {
  1570. return io.ErrUnexpectedEOF
  1571. }
  1572. if m.AuthRoleDelete == nil {
  1573. m.AuthRoleDelete = &AuthRoleDeleteRequest{}
  1574. }
  1575. if err := m.AuthRoleDelete.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1576. return err
  1577. }
  1578. iNdEx = postIndex
  1579. case 1202:
  1580. if wireType != 2 {
  1581. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleGet", wireType)
  1582. }
  1583. var msglen int
  1584. for shift := uint(0); ; shift += 7 {
  1585. if shift >= 64 {
  1586. return ErrIntOverflowRaftInternal
  1587. }
  1588. if iNdEx >= l {
  1589. return io.ErrUnexpectedEOF
  1590. }
  1591. b := dAtA[iNdEx]
  1592. iNdEx++
  1593. msglen |= (int(b) & 0x7F) << shift
  1594. if b < 0x80 {
  1595. break
  1596. }
  1597. }
  1598. if msglen < 0 {
  1599. return ErrInvalidLengthRaftInternal
  1600. }
  1601. postIndex := iNdEx + msglen
  1602. if postIndex > l {
  1603. return io.ErrUnexpectedEOF
  1604. }
  1605. if m.AuthRoleGet == nil {
  1606. m.AuthRoleGet = &AuthRoleGetRequest{}
  1607. }
  1608. if err := m.AuthRoleGet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1609. return err
  1610. }
  1611. iNdEx = postIndex
  1612. case 1203:
  1613. if wireType != 2 {
  1614. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleGrantPermission", wireType)
  1615. }
  1616. var msglen int
  1617. for shift := uint(0); ; shift += 7 {
  1618. if shift >= 64 {
  1619. return ErrIntOverflowRaftInternal
  1620. }
  1621. if iNdEx >= l {
  1622. return io.ErrUnexpectedEOF
  1623. }
  1624. b := dAtA[iNdEx]
  1625. iNdEx++
  1626. msglen |= (int(b) & 0x7F) << shift
  1627. if b < 0x80 {
  1628. break
  1629. }
  1630. }
  1631. if msglen < 0 {
  1632. return ErrInvalidLengthRaftInternal
  1633. }
  1634. postIndex := iNdEx + msglen
  1635. if postIndex > l {
  1636. return io.ErrUnexpectedEOF
  1637. }
  1638. if m.AuthRoleGrantPermission == nil {
  1639. m.AuthRoleGrantPermission = &AuthRoleGrantPermissionRequest{}
  1640. }
  1641. if err := m.AuthRoleGrantPermission.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1642. return err
  1643. }
  1644. iNdEx = postIndex
  1645. case 1204:
  1646. if wireType != 2 {
  1647. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleRevokePermission", wireType)
  1648. }
  1649. var msglen int
  1650. for shift := uint(0); ; shift += 7 {
  1651. if shift >= 64 {
  1652. return ErrIntOverflowRaftInternal
  1653. }
  1654. if iNdEx >= l {
  1655. return io.ErrUnexpectedEOF
  1656. }
  1657. b := dAtA[iNdEx]
  1658. iNdEx++
  1659. msglen |= (int(b) & 0x7F) << shift
  1660. if b < 0x80 {
  1661. break
  1662. }
  1663. }
  1664. if msglen < 0 {
  1665. return ErrInvalidLengthRaftInternal
  1666. }
  1667. postIndex := iNdEx + msglen
  1668. if postIndex > l {
  1669. return io.ErrUnexpectedEOF
  1670. }
  1671. if m.AuthRoleRevokePermission == nil {
  1672. m.AuthRoleRevokePermission = &AuthRoleRevokePermissionRequest{}
  1673. }
  1674. if err := m.AuthRoleRevokePermission.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1675. return err
  1676. }
  1677. iNdEx = postIndex
  1678. default:
  1679. iNdEx = preIndex
  1680. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  1681. if err != nil {
  1682. return err
  1683. }
  1684. if skippy < 0 {
  1685. return ErrInvalidLengthRaftInternal
  1686. }
  1687. if (iNdEx + skippy) > l {
  1688. return io.ErrUnexpectedEOF
  1689. }
  1690. iNdEx += skippy
  1691. }
  1692. }
  1693. if iNdEx > l {
  1694. return io.ErrUnexpectedEOF
  1695. }
  1696. return nil
  1697. }
  1698. func (m *EmptyResponse) Unmarshal(dAtA []byte) error {
  1699. l := len(dAtA)
  1700. iNdEx := 0
  1701. for iNdEx < l {
  1702. preIndex := iNdEx
  1703. var wire uint64
  1704. for shift := uint(0); ; shift += 7 {
  1705. if shift >= 64 {
  1706. return ErrIntOverflowRaftInternal
  1707. }
  1708. if iNdEx >= l {
  1709. return io.ErrUnexpectedEOF
  1710. }
  1711. b := dAtA[iNdEx]
  1712. iNdEx++
  1713. wire |= (uint64(b) & 0x7F) << shift
  1714. if b < 0x80 {
  1715. break
  1716. }
  1717. }
  1718. fieldNum := int32(wire >> 3)
  1719. wireType := int(wire & 0x7)
  1720. if wireType == 4 {
  1721. return fmt.Errorf("proto: EmptyResponse: wiretype end group for non-group")
  1722. }
  1723. if fieldNum <= 0 {
  1724. return fmt.Errorf("proto: EmptyResponse: illegal tag %d (wire type %d)", fieldNum, wire)
  1725. }
  1726. switch fieldNum {
  1727. default:
  1728. iNdEx = preIndex
  1729. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  1730. if err != nil {
  1731. return err
  1732. }
  1733. if skippy < 0 {
  1734. return ErrInvalidLengthRaftInternal
  1735. }
  1736. if (iNdEx + skippy) > l {
  1737. return io.ErrUnexpectedEOF
  1738. }
  1739. iNdEx += skippy
  1740. }
  1741. }
  1742. if iNdEx > l {
  1743. return io.ErrUnexpectedEOF
  1744. }
  1745. return nil
  1746. }
  1747. func (m *InternalAuthenticateRequest) Unmarshal(dAtA []byte) error {
  1748. l := len(dAtA)
  1749. iNdEx := 0
  1750. for iNdEx < l {
  1751. preIndex := iNdEx
  1752. var wire uint64
  1753. for shift := uint(0); ; shift += 7 {
  1754. if shift >= 64 {
  1755. return ErrIntOverflowRaftInternal
  1756. }
  1757. if iNdEx >= l {
  1758. return io.ErrUnexpectedEOF
  1759. }
  1760. b := dAtA[iNdEx]
  1761. iNdEx++
  1762. wire |= (uint64(b) & 0x7F) << shift
  1763. if b < 0x80 {
  1764. break
  1765. }
  1766. }
  1767. fieldNum := int32(wire >> 3)
  1768. wireType := int(wire & 0x7)
  1769. if wireType == 4 {
  1770. return fmt.Errorf("proto: InternalAuthenticateRequest: wiretype end group for non-group")
  1771. }
  1772. if fieldNum <= 0 {
  1773. return fmt.Errorf("proto: InternalAuthenticateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  1774. }
  1775. switch fieldNum {
  1776. case 1:
  1777. if wireType != 2 {
  1778. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  1779. }
  1780. var stringLen uint64
  1781. for shift := uint(0); ; shift += 7 {
  1782. if shift >= 64 {
  1783. return ErrIntOverflowRaftInternal
  1784. }
  1785. if iNdEx >= l {
  1786. return io.ErrUnexpectedEOF
  1787. }
  1788. b := dAtA[iNdEx]
  1789. iNdEx++
  1790. stringLen |= (uint64(b) & 0x7F) << shift
  1791. if b < 0x80 {
  1792. break
  1793. }
  1794. }
  1795. intStringLen := int(stringLen)
  1796. if intStringLen < 0 {
  1797. return ErrInvalidLengthRaftInternal
  1798. }
  1799. postIndex := iNdEx + intStringLen
  1800. if postIndex > l {
  1801. return io.ErrUnexpectedEOF
  1802. }
  1803. m.Name = string(dAtA[iNdEx:postIndex])
  1804. iNdEx = postIndex
  1805. case 2:
  1806. if wireType != 2 {
  1807. return fmt.Errorf("proto: wrong wireType = %d for field Password", wireType)
  1808. }
  1809. var stringLen uint64
  1810. for shift := uint(0); ; shift += 7 {
  1811. if shift >= 64 {
  1812. return ErrIntOverflowRaftInternal
  1813. }
  1814. if iNdEx >= l {
  1815. return io.ErrUnexpectedEOF
  1816. }
  1817. b := dAtA[iNdEx]
  1818. iNdEx++
  1819. stringLen |= (uint64(b) & 0x7F) << shift
  1820. if b < 0x80 {
  1821. break
  1822. }
  1823. }
  1824. intStringLen := int(stringLen)
  1825. if intStringLen < 0 {
  1826. return ErrInvalidLengthRaftInternal
  1827. }
  1828. postIndex := iNdEx + intStringLen
  1829. if postIndex > l {
  1830. return io.ErrUnexpectedEOF
  1831. }
  1832. m.Password = string(dAtA[iNdEx:postIndex])
  1833. iNdEx = postIndex
  1834. case 3:
  1835. if wireType != 2 {
  1836. return fmt.Errorf("proto: wrong wireType = %d for field SimpleToken", wireType)
  1837. }
  1838. var stringLen uint64
  1839. for shift := uint(0); ; shift += 7 {
  1840. if shift >= 64 {
  1841. return ErrIntOverflowRaftInternal
  1842. }
  1843. if iNdEx >= l {
  1844. return io.ErrUnexpectedEOF
  1845. }
  1846. b := dAtA[iNdEx]
  1847. iNdEx++
  1848. stringLen |= (uint64(b) & 0x7F) << shift
  1849. if b < 0x80 {
  1850. break
  1851. }
  1852. }
  1853. intStringLen := int(stringLen)
  1854. if intStringLen < 0 {
  1855. return ErrInvalidLengthRaftInternal
  1856. }
  1857. postIndex := iNdEx + intStringLen
  1858. if postIndex > l {
  1859. return io.ErrUnexpectedEOF
  1860. }
  1861. m.SimpleToken = string(dAtA[iNdEx:postIndex])
  1862. iNdEx = postIndex
  1863. default:
  1864. iNdEx = preIndex
  1865. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  1866. if err != nil {
  1867. return err
  1868. }
  1869. if skippy < 0 {
  1870. return ErrInvalidLengthRaftInternal
  1871. }
  1872. if (iNdEx + skippy) > l {
  1873. return io.ErrUnexpectedEOF
  1874. }
  1875. iNdEx += skippy
  1876. }
  1877. }
  1878. if iNdEx > l {
  1879. return io.ErrUnexpectedEOF
  1880. }
  1881. return nil
  1882. }
  1883. func skipRaftInternal(dAtA []byte) (n int, err error) {
  1884. l := len(dAtA)
  1885. iNdEx := 0
  1886. for iNdEx < l {
  1887. var wire uint64
  1888. for shift := uint(0); ; shift += 7 {
  1889. if shift >= 64 {
  1890. return 0, ErrIntOverflowRaftInternal
  1891. }
  1892. if iNdEx >= l {
  1893. return 0, io.ErrUnexpectedEOF
  1894. }
  1895. b := dAtA[iNdEx]
  1896. iNdEx++
  1897. wire |= (uint64(b) & 0x7F) << shift
  1898. if b < 0x80 {
  1899. break
  1900. }
  1901. }
  1902. wireType := int(wire & 0x7)
  1903. switch wireType {
  1904. case 0:
  1905. for shift := uint(0); ; shift += 7 {
  1906. if shift >= 64 {
  1907. return 0, ErrIntOverflowRaftInternal
  1908. }
  1909. if iNdEx >= l {
  1910. return 0, io.ErrUnexpectedEOF
  1911. }
  1912. iNdEx++
  1913. if dAtA[iNdEx-1] < 0x80 {
  1914. break
  1915. }
  1916. }
  1917. return iNdEx, nil
  1918. case 1:
  1919. iNdEx += 8
  1920. return iNdEx, nil
  1921. case 2:
  1922. var length int
  1923. for shift := uint(0); ; shift += 7 {
  1924. if shift >= 64 {
  1925. return 0, ErrIntOverflowRaftInternal
  1926. }
  1927. if iNdEx >= l {
  1928. return 0, io.ErrUnexpectedEOF
  1929. }
  1930. b := dAtA[iNdEx]
  1931. iNdEx++
  1932. length |= (int(b) & 0x7F) << shift
  1933. if b < 0x80 {
  1934. break
  1935. }
  1936. }
  1937. iNdEx += length
  1938. if length < 0 {
  1939. return 0, ErrInvalidLengthRaftInternal
  1940. }
  1941. return iNdEx, nil
  1942. case 3:
  1943. for {
  1944. var innerWire uint64
  1945. var start int = iNdEx
  1946. for shift := uint(0); ; shift += 7 {
  1947. if shift >= 64 {
  1948. return 0, ErrIntOverflowRaftInternal
  1949. }
  1950. if iNdEx >= l {
  1951. return 0, io.ErrUnexpectedEOF
  1952. }
  1953. b := dAtA[iNdEx]
  1954. iNdEx++
  1955. innerWire |= (uint64(b) & 0x7F) << shift
  1956. if b < 0x80 {
  1957. break
  1958. }
  1959. }
  1960. innerWireType := int(innerWire & 0x7)
  1961. if innerWireType == 4 {
  1962. break
  1963. }
  1964. next, err := skipRaftInternal(dAtA[start:])
  1965. if err != nil {
  1966. return 0, err
  1967. }
  1968. iNdEx = start + next
  1969. }
  1970. return iNdEx, nil
  1971. case 4:
  1972. return iNdEx, nil
  1973. case 5:
  1974. iNdEx += 4
  1975. return iNdEx, nil
  1976. default:
  1977. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1978. }
  1979. }
  1980. panic("unreachable")
  1981. }
  1982. var (
  1983. ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling")
  1984. ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow")
  1985. )
  1986. func init() { proto.RegisterFile("raft_internal.proto", fileDescriptorRaftInternal) }
  1987. var fileDescriptorRaftInternal = []byte{
  1988. // 837 bytes of a gzipped FileDescriptorProto
  1989. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x96, 0xdd, 0x52, 0xd3, 0x40,
  1990. 0x14, 0xc7, 0x69, 0xf9, 0xec, 0xb6, 0x54, 0x5c, 0x40, 0xd7, 0x32, 0x53, 0xa1, 0x8c, 0x8a, 0x5f,
  1991. 0xe8, 0x94, 0x07, 0xd0, 0x4a, 0x19, 0x60, 0x86, 0x61, 0x98, 0x0c, 0xce, 0x38, 0xe3, 0x45, 0x5c,
  1992. 0x9a, 0x43, 0x1b, 0x49, 0x93, 0xb8, 0xd9, 0x56, 0x7c, 0x13, 0x1f, 0xc3, 0xaf, 0x87, 0xe0, 0xc2,
  1993. 0x0f, 0xd4, 0x17, 0x50, 0xbc, 0xf1, 0xca, 0x1b, 0x7d, 0x00, 0x67, 0x3f, 0x92, 0x34, 0x6d, 0xca,
  1994. 0x5d, 0x72, 0xce, 0xff, 0xfc, 0xce, 0xd9, 0xec, 0x7f, 0xbb, 0x45, 0xb3, 0x8c, 0x1e, 0x72, 0xd3,
  1995. 0x76, 0x39, 0x30, 0x97, 0x3a, 0xab, 0x3e, 0xf3, 0xb8, 0x87, 0x0b, 0xc0, 0x1b, 0x56, 0x00, 0xac,
  1996. 0x0b, 0xcc, 0x3f, 0x28, 0xcd, 0x35, 0xbd, 0xa6, 0x27, 0x13, 0xf7, 0xc4, 0x93, 0xd2, 0x94, 0x66,
  1997. 0x62, 0x8d, 0x8e, 0xe4, 0x98, 0xdf, 0x50, 0x8f, 0x95, 0x67, 0x68, 0xda, 0x80, 0x17, 0x1d, 0x08,
  1998. 0xf8, 0x16, 0x50, 0x0b, 0x18, 0x2e, 0xa2, 0xec, 0x76, 0x9d, 0x64, 0x16, 0x33, 0x2b, 0x63, 0x46,
  1999. 0x76, 0xbb, 0x8e, 0x4b, 0x68, 0xaa, 0x13, 0x88, 0x96, 0x6d, 0x20, 0xd9, 0xc5, 0xcc, 0x4a, 0xce,
  2000. 0x88, 0xde, 0xf1, 0x32, 0x9a, 0xa6, 0x1d, 0xde, 0x32, 0x19, 0x74, 0xed, 0xc0, 0xf6, 0x5c, 0x32,
  2001. 0x2a, 0xcb, 0x0a, 0x22, 0x68, 0xe8, 0x58, 0xe5, 0x4f, 0x11, 0xcd, 0x6e, 0xeb, 0xa9, 0x0d, 0x7a,
  2002. 0xc8, 0x75, 0xbb, 0x81, 0x46, 0xd7, 0x50, 0xb6, 0x5b, 0x95, 0x2d, 0xf2, 0xd5, 0xf9, 0xd5, 0xde,
  2003. 0x75, 0xad, 0xea, 0x12, 0x23, 0xdb, 0xad, 0xe2, 0xfb, 0x68, 0x9c, 0x51, 0xb7, 0x09, 0xb2, 0x57,
  2004. 0xbe, 0x5a, 0xea, 0x53, 0x8a, 0x54, 0x28, 0x57, 0x42, 0x7c, 0x0b, 0x8d, 0xfa, 0x1d, 0x4e, 0xc6,
  2005. 0xa4, 0x9e, 0x24, 0xf5, 0x7b, 0x9d, 0x70, 0x1e, 0x43, 0x88, 0xf0, 0x3a, 0x2a, 0x58, 0xe0, 0x00,
  2006. 0x07, 0x53, 0x35, 0x19, 0x97, 0x45, 0x8b, 0xc9, 0xa2, 0xba, 0x54, 0x24, 0x5a, 0xe5, 0xad, 0x38,
  2007. 0x26, 0x1a, 0xf2, 0x63, 0x97, 0x4c, 0xa4, 0x35, 0xdc, 0x3f, 0x76, 0xa3, 0x86, 0xfc, 0xd8, 0xc5,
  2008. 0x0f, 0x10, 0x6a, 0x78, 0x6d, 0x9f, 0x36, 0xb8, 0xf8, 0x7e, 0x93, 0xb2, 0xe4, 0x6a, 0xb2, 0x64,
  2009. 0x3d, 0xca, 0x87, 0x95, 0x3d, 0x25, 0xf8, 0x21, 0xca, 0x3b, 0x40, 0x03, 0x30, 0x9b, 0x8c, 0xba,
  2010. 0x9c, 0x4c, 0xa5, 0x11, 0x76, 0x84, 0x60, 0x53, 0xe4, 0x23, 0x82, 0x13, 0x85, 0xc4, 0x9a, 0x15,
  2011. 0x81, 0x41, 0xd7, 0x3b, 0x02, 0x92, 0x4b, 0x5b, 0xb3, 0x44, 0x18, 0x52, 0x10, 0xad, 0xd9, 0x89,
  2012. 0x63, 0x62, 0x5b, 0xa8, 0x43, 0x59, 0x9b, 0xa0, 0xb4, 0x6d, 0xa9, 0x89, 0x54, 0xb4, 0x2d, 0x52,
  2013. 0x88, 0xd7, 0xd0, 0x44, 0x4b, 0x5a, 0x8e, 0x58, 0xb2, 0x64, 0x21, 0x75, 0xcf, 0x95, 0x2b, 0x0d,
  2014. 0x2d, 0xc5, 0x35, 0x94, 0x97, 0x8e, 0x03, 0x97, 0x1e, 0x38, 0x40, 0x7e, 0xa7, 0x7e, 0xb0, 0x5a,
  2015. 0x87, 0xb7, 0x36, 0xa4, 0x20, 0x5a, 0x2e, 0x8d, 0x42, 0xb8, 0x8e, 0xa4, 0x3f, 0x4d, 0xcb, 0x0e,
  2016. 0x24, 0xe3, 0xef, 0x64, 0xda, 0x7a, 0x05, 0xa3, 0xae, 0x14, 0xd1, 0x7a, 0x69, 0x1c, 0xc3, 0xbb,
  2017. 0x8a, 0x02, 0x2e, 0xb7, 0x1b, 0x94, 0x03, 0xf9, 0xa7, 0x28, 0x37, 0x93, 0x94, 0xd0, 0xf7, 0xb5,
  2018. 0x1e, 0x69, 0x88, 0x4b, 0xd4, 0xe3, 0x0d, 0x7d, 0x94, 0xc4, 0xd9, 0x32, 0xa9, 0x65, 0x91, 0x8f,
  2019. 0x53, 0xc3, 0xc6, 0x7a, 0x1c, 0x00, 0xab, 0x59, 0x56, 0x62, 0x2c, 0x1d, 0xc3, 0xbb, 0x68, 0x26,
  2020. 0xc6, 0x28, 0x4f, 0x92, 0x4f, 0x8a, 0xb4, 0x9c, 0x4e, 0xd2, 0x66, 0xd6, 0xb0, 0x22, 0x4d, 0x84,
  2021. 0x93, 0x63, 0x35, 0x81, 0x93, 0xcf, 0xe7, 0x8e, 0xb5, 0x09, 0x7c, 0x60, 0xac, 0x4d, 0xe0, 0xb8,
  2022. 0x89, 0xae, 0xc4, 0x98, 0x46, 0x4b, 0x9c, 0x12, 0xd3, 0xa7, 0x41, 0xf0, 0xd2, 0x63, 0x16, 0xf9,
  2023. 0xa2, 0x90, 0xb7, 0xd3, 0x91, 0xeb, 0x52, 0xbd, 0xa7, 0xc5, 0x21, 0xfd, 0x12, 0x4d, 0x4d, 0xe3,
  2024. 0x27, 0x68, 0xae, 0x67, 0x5e, 0x61, 0x6f, 0x93, 0x79, 0x0e, 0x90, 0x53, 0xd5, 0xe3, 0xfa, 0x90,
  2025. 0xb1, 0xe5, 0xd1, 0xf0, 0xe2, 0xad, 0xbe, 0x48, 0xfb, 0x33, 0xf8, 0x29, 0x9a, 0x8f, 0xc9, 0xea,
  2026. 0xa4, 0x28, 0xf4, 0x57, 0x85, 0xbe, 0x91, 0x8e, 0xd6, 0x47, 0xa6, 0x87, 0x8d, 0xe9, 0x40, 0x0a,
  2027. 0x6f, 0xa1, 0x62, 0x0c, 0x77, 0xec, 0x80, 0x93, 0x6f, 0x8a, 0xba, 0x94, 0x4e, 0xdd, 0xb1, 0x03,
  2028. 0x9e, 0xf0, 0x51, 0x18, 0x8c, 0x48, 0x62, 0x34, 0x45, 0xfa, 0x3e, 0x94, 0x24, 0x5a, 0x0f, 0x90,
  2029. 0xc2, 0x60, 0xb4, 0xf5, 0x92, 0x24, 0x1c, 0xf9, 0x26, 0x37, 0x6c, 0xeb, 0x45, 0x4d, 0xbf, 0x23,
  2030. 0x75, 0x2c, 0x72, 0xa4, 0xc4, 0x68, 0x47, 0xbe, 0xcd, 0x0d, 0x73, 0xa4, 0xa8, 0x4a, 0x71, 0x64,
  2031. 0x1c, 0x4e, 0x8e, 0x25, 0x1c, 0xf9, 0xee, 0xdc, 0xb1, 0xfa, 0x1d, 0xa9, 0x63, 0xf8, 0x39, 0x2a,
  2032. 0xf5, 0x60, 0xa4, 0x51, 0x7c, 0x60, 0x6d, 0x3b, 0x90, 0xf7, 0xd8, 0x7b, 0xc5, 0xbc, 0x33, 0x84,
  2033. 0x29, 0xe4, 0x7b, 0x91, 0x3a, 0xe4, 0x5f, 0xa6, 0xe9, 0x79, 0xdc, 0x46, 0x0b, 0x71, 0x2f, 0x6d,
  2034. 0x9d, 0x9e, 0x66, 0x1f, 0x54, 0xb3, 0xbb, 0xe9, 0xcd, 0x94, 0x4b, 0x06, 0xbb, 0x11, 0x3a, 0x44,
  2035. 0x50, 0xb9, 0x80, 0xa6, 0x37, 0xda, 0x3e, 0x7f, 0x65, 0x40, 0xe0, 0x7b, 0x6e, 0x00, 0x15, 0x1f,
  2036. 0x2d, 0x9c, 0xf3, 0x43, 0x84, 0x31, 0x1a, 0x93, 0xb7, 0x7b, 0x46, 0xde, 0xee, 0xf2, 0x59, 0xdc,
  2037. 0xfa, 0xd1, 0xf9, 0xd4, 0xb7, 0x7e, 0xf8, 0x8e, 0x97, 0x50, 0x21, 0xb0, 0xdb, 0xbe, 0x03, 0x26,
  2038. 0xf7, 0x8e, 0x40, 0x5d, 0xfa, 0x39, 0x23, 0xaf, 0x62, 0xfb, 0x22, 0xf4, 0x68, 0xee, 0xe4, 0x67,
  2039. 0x79, 0xe4, 0xe4, 0xac, 0x9c, 0x39, 0x3d, 0x2b, 0x67, 0x7e, 0x9c, 0x95, 0x33, 0xaf, 0x7f, 0x95,
  2040. 0x47, 0x0e, 0x26, 0xe4, 0x5f, 0x8e, 0xb5, 0xff, 0x01, 0x00, 0x00, 0xff, 0xff, 0xff, 0xc9, 0xfc,
  2041. 0x0e, 0xca, 0x08, 0x00, 0x00,
  2042. }