raft_internal.pb.go 55 KB

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