raft_internal.pb.go 70 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: raft_internal.proto
  3. package etcdserverpb
  4. import (
  5. fmt "fmt"
  6. io "io"
  7. math "math"
  8. math_bits "math/bits"
  9. _ "github.com/gogo/protobuf/gogoproto"
  10. proto "github.com/golang/protobuf/proto"
  11. membershippb "go.etcd.io/etcd/api/v3/membershippb"
  12. )
  13. // Reference imports to suppress errors if they are not otherwise used.
  14. var _ = proto.Marshal
  15. var _ = fmt.Errorf
  16. var _ = math.Inf
  17. // This is a compile-time assertion to ensure that this generated file
  18. // is compatible with the proto package it is being compiled against.
  19. // A compilation error at this line likely means your copy of the
  20. // proto package needs to be updated.
  21. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  22. type RequestHeader struct {
  23. ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
  24. // username is a username that is associated with an auth token of gRPC connection
  25. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
  26. // auth_revision is a revision number of auth.authStore. It is not related to mvcc
  27. AuthRevision uint64 `protobuf:"varint,3,opt,name=auth_revision,json=authRevision,proto3" json:"auth_revision,omitempty"`
  28. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  29. XXX_unrecognized []byte `json:"-"`
  30. XXX_sizecache int32 `json:"-"`
  31. }
  32. func (m *RequestHeader) Reset() { *m = RequestHeader{} }
  33. func (m *RequestHeader) String() string { return proto.CompactTextString(m) }
  34. func (*RequestHeader) ProtoMessage() {}
  35. func (*RequestHeader) Descriptor() ([]byte, []int) {
  36. return fileDescriptor_b4c9a9be0cfca103, []int{0}
  37. }
  38. func (m *RequestHeader) XXX_Unmarshal(b []byte) error {
  39. return m.Unmarshal(b)
  40. }
  41. func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  42. if deterministic {
  43. return xxx_messageInfo_RequestHeader.Marshal(b, m, deterministic)
  44. } else {
  45. b = b[:cap(b)]
  46. n, err := m.MarshalToSizedBuffer(b)
  47. if err != nil {
  48. return nil, err
  49. }
  50. return b[:n], nil
  51. }
  52. }
  53. func (m *RequestHeader) XXX_Merge(src proto.Message) {
  54. xxx_messageInfo_RequestHeader.Merge(m, src)
  55. }
  56. func (m *RequestHeader) XXX_Size() int {
  57. return m.Size()
  58. }
  59. func (m *RequestHeader) XXX_DiscardUnknown() {
  60. xxx_messageInfo_RequestHeader.DiscardUnknown(m)
  61. }
  62. var xxx_messageInfo_RequestHeader proto.InternalMessageInfo
  63. // An InternalRaftRequest is the union of all requests which can be
  64. // sent via raft.
  65. type InternalRaftRequest struct {
  66. Header *RequestHeader `protobuf:"bytes,100,opt,name=header,proto3" json:"header,omitempty"`
  67. ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
  68. V2 *Request `protobuf:"bytes,2,opt,name=v2,proto3" json:"v2,omitempty"`
  69. Range *RangeRequest `protobuf:"bytes,3,opt,name=range,proto3" json:"range,omitempty"`
  70. Put *PutRequest `protobuf:"bytes,4,opt,name=put,proto3" json:"put,omitempty"`
  71. DeleteRange *DeleteRangeRequest `protobuf:"bytes,5,opt,name=delete_range,json=deleteRange,proto3" json:"delete_range,omitempty"`
  72. Txn *TxnRequest `protobuf:"bytes,6,opt,name=txn,proto3" json:"txn,omitempty"`
  73. Compaction *CompactionRequest `protobuf:"bytes,7,opt,name=compaction,proto3" json:"compaction,omitempty"`
  74. LeaseGrant *LeaseGrantRequest `protobuf:"bytes,8,opt,name=lease_grant,json=leaseGrant,proto3" json:"lease_grant,omitempty"`
  75. LeaseRevoke *LeaseRevokeRequest `protobuf:"bytes,9,opt,name=lease_revoke,json=leaseRevoke,proto3" json:"lease_revoke,omitempty"`
  76. Alarm *AlarmRequest `protobuf:"bytes,10,opt,name=alarm,proto3" json:"alarm,omitempty"`
  77. LeaseCheckpoint *LeaseCheckpointRequest `protobuf:"bytes,11,opt,name=lease_checkpoint,json=leaseCheckpoint,proto3" json:"lease_checkpoint,omitempty"`
  78. AuthEnable *AuthEnableRequest `protobuf:"bytes,1000,opt,name=auth_enable,json=authEnable,proto3" json:"auth_enable,omitempty"`
  79. AuthDisable *AuthDisableRequest `protobuf:"bytes,1011,opt,name=auth_disable,json=authDisable,proto3" json:"auth_disable,omitempty"`
  80. AuthStatus *AuthStatusRequest `protobuf:"bytes,1013,opt,name=auth_status,json=authStatus,proto3" json:"auth_status,omitempty"`
  81. Authenticate *InternalAuthenticateRequest `protobuf:"bytes,1012,opt,name=authenticate,proto3" json:"authenticate,omitempty"`
  82. AuthUserAdd *AuthUserAddRequest `protobuf:"bytes,1100,opt,name=auth_user_add,json=authUserAdd,proto3" json:"auth_user_add,omitempty"`
  83. AuthUserDelete *AuthUserDeleteRequest `protobuf:"bytes,1101,opt,name=auth_user_delete,json=authUserDelete,proto3" json:"auth_user_delete,omitempty"`
  84. AuthUserGet *AuthUserGetRequest `protobuf:"bytes,1102,opt,name=auth_user_get,json=authUserGet,proto3" json:"auth_user_get,omitempty"`
  85. AuthUserChangePassword *AuthUserChangePasswordRequest `protobuf:"bytes,1103,opt,name=auth_user_change_password,json=authUserChangePassword,proto3" json:"auth_user_change_password,omitempty"`
  86. AuthUserGrantRole *AuthUserGrantRoleRequest `protobuf:"bytes,1104,opt,name=auth_user_grant_role,json=authUserGrantRole,proto3" json:"auth_user_grant_role,omitempty"`
  87. AuthUserRevokeRole *AuthUserRevokeRoleRequest `protobuf:"bytes,1105,opt,name=auth_user_revoke_role,json=authUserRevokeRole,proto3" json:"auth_user_revoke_role,omitempty"`
  88. AuthUserList *AuthUserListRequest `protobuf:"bytes,1106,opt,name=auth_user_list,json=authUserList,proto3" json:"auth_user_list,omitempty"`
  89. AuthRoleList *AuthRoleListRequest `protobuf:"bytes,1107,opt,name=auth_role_list,json=authRoleList,proto3" json:"auth_role_list,omitempty"`
  90. AuthRoleAdd *AuthRoleAddRequest `protobuf:"bytes,1200,opt,name=auth_role_add,json=authRoleAdd,proto3" json:"auth_role_add,omitempty"`
  91. AuthRoleDelete *AuthRoleDeleteRequest `protobuf:"bytes,1201,opt,name=auth_role_delete,json=authRoleDelete,proto3" json:"auth_role_delete,omitempty"`
  92. AuthRoleGet *AuthRoleGetRequest `protobuf:"bytes,1202,opt,name=auth_role_get,json=authRoleGet,proto3" json:"auth_role_get,omitempty"`
  93. AuthRoleGrantPermission *AuthRoleGrantPermissionRequest `protobuf:"bytes,1203,opt,name=auth_role_grant_permission,json=authRoleGrantPermission,proto3" json:"auth_role_grant_permission,omitempty"`
  94. AuthRoleRevokePermission *AuthRoleRevokePermissionRequest `protobuf:"bytes,1204,opt,name=auth_role_revoke_permission,json=authRoleRevokePermission,proto3" json:"auth_role_revoke_permission,omitempty"`
  95. ClusterVersionSet *membershippb.ClusterVersionSetRequest `protobuf:"bytes,1300,opt,name=cluster_version_set,json=clusterVersionSet,proto3" json:"cluster_version_set,omitempty"`
  96. ClusterMemberAttrSet *membershippb.ClusterMemberAttrSetRequest `protobuf:"bytes,1301,opt,name=cluster_member_attr_set,json=clusterMemberAttrSet,proto3" json:"cluster_member_attr_set,omitempty"`
  97. DowngradeInfoSet *membershippb.DowngradeInfoSetRequest `protobuf:"bytes,1302,opt,name=downgrade_info_set,json=downgradeInfoSet,proto3" json:"downgrade_info_set,omitempty"`
  98. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  99. XXX_unrecognized []byte `json:"-"`
  100. XXX_sizecache int32 `json:"-"`
  101. }
  102. func (m *InternalRaftRequest) Reset() { *m = InternalRaftRequest{} }
  103. func (m *InternalRaftRequest) String() string { return proto.CompactTextString(m) }
  104. func (*InternalRaftRequest) ProtoMessage() {}
  105. func (*InternalRaftRequest) Descriptor() ([]byte, []int) {
  106. return fileDescriptor_b4c9a9be0cfca103, []int{1}
  107. }
  108. func (m *InternalRaftRequest) XXX_Unmarshal(b []byte) error {
  109. return m.Unmarshal(b)
  110. }
  111. func (m *InternalRaftRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  112. if deterministic {
  113. return xxx_messageInfo_InternalRaftRequest.Marshal(b, m, deterministic)
  114. } else {
  115. b = b[:cap(b)]
  116. n, err := m.MarshalToSizedBuffer(b)
  117. if err != nil {
  118. return nil, err
  119. }
  120. return b[:n], nil
  121. }
  122. }
  123. func (m *InternalRaftRequest) XXX_Merge(src proto.Message) {
  124. xxx_messageInfo_InternalRaftRequest.Merge(m, src)
  125. }
  126. func (m *InternalRaftRequest) XXX_Size() int {
  127. return m.Size()
  128. }
  129. func (m *InternalRaftRequest) XXX_DiscardUnknown() {
  130. xxx_messageInfo_InternalRaftRequest.DiscardUnknown(m)
  131. }
  132. var xxx_messageInfo_InternalRaftRequest proto.InternalMessageInfo
  133. type EmptyResponse struct {
  134. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  135. XXX_unrecognized []byte `json:"-"`
  136. XXX_sizecache int32 `json:"-"`
  137. }
  138. func (m *EmptyResponse) Reset() { *m = EmptyResponse{} }
  139. func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
  140. func (*EmptyResponse) ProtoMessage() {}
  141. func (*EmptyResponse) Descriptor() ([]byte, []int) {
  142. return fileDescriptor_b4c9a9be0cfca103, []int{2}
  143. }
  144. func (m *EmptyResponse) XXX_Unmarshal(b []byte) error {
  145. return m.Unmarshal(b)
  146. }
  147. func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  148. if deterministic {
  149. return xxx_messageInfo_EmptyResponse.Marshal(b, m, deterministic)
  150. } else {
  151. b = b[:cap(b)]
  152. n, err := m.MarshalToSizedBuffer(b)
  153. if err != nil {
  154. return nil, err
  155. }
  156. return b[:n], nil
  157. }
  158. }
  159. func (m *EmptyResponse) XXX_Merge(src proto.Message) {
  160. xxx_messageInfo_EmptyResponse.Merge(m, src)
  161. }
  162. func (m *EmptyResponse) XXX_Size() int {
  163. return m.Size()
  164. }
  165. func (m *EmptyResponse) XXX_DiscardUnknown() {
  166. xxx_messageInfo_EmptyResponse.DiscardUnknown(m)
  167. }
  168. var xxx_messageInfo_EmptyResponse proto.InternalMessageInfo
  169. // What is the difference between AuthenticateRequest (defined in rpc.proto) and InternalAuthenticateRequest?
  170. // InternalAuthenticateRequest has a member that is filled by etcdserver and shouldn't be user-facing.
  171. // For avoiding misusage the field, we have an internal version of AuthenticateRequest.
  172. type InternalAuthenticateRequest struct {
  173. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  174. Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
  175. // simple_token is generated in API layer (etcdserver/v3_server.go)
  176. SimpleToken string `protobuf:"bytes,3,opt,name=simple_token,json=simpleToken,proto3" json:"simple_token,omitempty"`
  177. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  178. XXX_unrecognized []byte `json:"-"`
  179. XXX_sizecache int32 `json:"-"`
  180. }
  181. func (m *InternalAuthenticateRequest) Reset() { *m = InternalAuthenticateRequest{} }
  182. func (m *InternalAuthenticateRequest) String() string { return proto.CompactTextString(m) }
  183. func (*InternalAuthenticateRequest) ProtoMessage() {}
  184. func (*InternalAuthenticateRequest) Descriptor() ([]byte, []int) {
  185. return fileDescriptor_b4c9a9be0cfca103, []int{3}
  186. }
  187. func (m *InternalAuthenticateRequest) XXX_Unmarshal(b []byte) error {
  188. return m.Unmarshal(b)
  189. }
  190. func (m *InternalAuthenticateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  191. if deterministic {
  192. return xxx_messageInfo_InternalAuthenticateRequest.Marshal(b, m, deterministic)
  193. } else {
  194. b = b[:cap(b)]
  195. n, err := m.MarshalToSizedBuffer(b)
  196. if err != nil {
  197. return nil, err
  198. }
  199. return b[:n], nil
  200. }
  201. }
  202. func (m *InternalAuthenticateRequest) XXX_Merge(src proto.Message) {
  203. xxx_messageInfo_InternalAuthenticateRequest.Merge(m, src)
  204. }
  205. func (m *InternalAuthenticateRequest) XXX_Size() int {
  206. return m.Size()
  207. }
  208. func (m *InternalAuthenticateRequest) XXX_DiscardUnknown() {
  209. xxx_messageInfo_InternalAuthenticateRequest.DiscardUnknown(m)
  210. }
  211. var xxx_messageInfo_InternalAuthenticateRequest proto.InternalMessageInfo
  212. func init() {
  213. proto.RegisterType((*RequestHeader)(nil), "etcdserverpb.RequestHeader")
  214. proto.RegisterType((*InternalRaftRequest)(nil), "etcdserverpb.InternalRaftRequest")
  215. proto.RegisterType((*EmptyResponse)(nil), "etcdserverpb.EmptyResponse")
  216. proto.RegisterType((*InternalAuthenticateRequest)(nil), "etcdserverpb.InternalAuthenticateRequest")
  217. }
  218. func init() { proto.RegisterFile("raft_internal.proto", fileDescriptor_b4c9a9be0cfca103) }
  219. var fileDescriptor_b4c9a9be0cfca103 = []byte{
  220. // 1003 bytes of a gzipped FileDescriptorProto
  221. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x96, 0xd9, 0x72, 0x1b, 0x45,
  222. 0x14, 0x86, 0x23, 0xc5, 0x71, 0xac, 0x96, 0xed, 0x38, 0x6d, 0x87, 0x34, 0x72, 0x95, 0x70, 0x1c,
  223. 0x12, 0xcc, 0x66, 0x53, 0xca, 0x03, 0x80, 0x90, 0x5c, 0x8e, 0xab, 0x42, 0x70, 0x4d, 0xcc, 0x52,
  224. 0xc5, 0xc5, 0xd0, 0x9a, 0x39, 0x96, 0x06, 0xcf, 0x46, 0x77, 0x4b, 0x31, 0xef, 0x11, 0x28, 0x1e,
  225. 0x83, 0xed, 0x21, 0x72, 0xc1, 0x62, 0xe0, 0x05, 0xc0, 0xdc, 0x70, 0x0f, 0xdc, 0x53, 0xbd, 0xcc,
  226. 0x26, 0xb5, 0x7c, 0xa7, 0xf9, 0xcf, 0x7f, 0xbe, 0x73, 0xba, 0xe7, 0xf4, 0xa8, 0xd1, 0x3a, 0xa3,
  227. 0x27, 0xc2, 0x0d, 0x62, 0x01, 0x2c, 0xa6, 0xe1, 0x6e, 0xca, 0x12, 0x91, 0xe0, 0x65, 0x10, 0x9e,
  228. 0xcf, 0x81, 0x4d, 0x80, 0xa5, 0x83, 0xd6, 0xc6, 0x30, 0x19, 0x26, 0x2a, 0xb0, 0x27, 0x7f, 0x69,
  229. 0x4f, 0x6b, 0xad, 0xf0, 0x18, 0xa5, 0xc1, 0x52, 0xcf, 0xfc, 0xbc, 0x2f, 0x83, 0x7b, 0x34, 0x0d,
  230. 0xf6, 0x22, 0x88, 0x06, 0xc0, 0xf8, 0x28, 0x48, 0xd3, 0x41, 0xe9, 0x41, 0xfb, 0xb6, 0x3f, 0x45,
  231. 0x2b, 0x0e, 0x7c, 0x3e, 0x06, 0x2e, 0x1e, 0x02, 0xf5, 0x81, 0xe1, 0x55, 0x54, 0x3f, 0xec, 0x93,
  232. 0xda, 0x56, 0x6d, 0x67, 0xc1, 0xa9, 0x1f, 0xf6, 0x71, 0x0b, 0x2d, 0x8d, 0xb9, 0x6c, 0x2d, 0x02,
  233. 0x52, 0xdf, 0xaa, 0xed, 0x34, 0x9c, 0xfc, 0x19, 0xdf, 0x45, 0x2b, 0x74, 0x2c, 0x46, 0x2e, 0x83,
  234. 0x49, 0xc0, 0x83, 0x24, 0x26, 0x57, 0x55, 0xda, 0xb2, 0x14, 0x1d, 0xa3, 0x6d, 0x3f, 0xc3, 0x68,
  235. 0xfd, 0xd0, 0xac, 0xce, 0xa1, 0x27, 0xc2, 0x94, 0xc3, 0x0f, 0xd0, 0xe2, 0x48, 0x95, 0x24, 0xfe,
  236. 0x56, 0x6d, 0xa7, 0xd9, 0xd9, 0xdc, 0x2d, 0xaf, 0x79, 0xb7, 0xd2, 0x95, 0x63, 0xac, 0x33, 0xdd,
  237. 0xdd, 0x43, 0xf5, 0x49, 0x47, 0xf5, 0xd5, 0xec, 0xdc, 0xb2, 0x02, 0x9c, 0xfa, 0xa4, 0x83, 0xdf,
  238. 0x42, 0xd7, 0x18, 0x8d, 0x87, 0xa0, 0x1a, 0x6c, 0x76, 0x5a, 0x53, 0x4e, 0x19, 0xca, 0xec, 0xda,
  239. 0x88, 0x5f, 0x43, 0x57, 0xd3, 0xb1, 0x20, 0x0b, 0xca, 0x4f, 0xaa, 0xfe, 0xa3, 0x71, 0xb6, 0x08,
  240. 0x47, 0x9a, 0x70, 0x0f, 0x2d, 0xfb, 0x10, 0x82, 0x00, 0x57, 0x17, 0xb9, 0xa6, 0x92, 0xb6, 0xaa,
  241. 0x49, 0x7d, 0xe5, 0xa8, 0x94, 0x6a, 0xfa, 0x85, 0x26, 0x0b, 0x8a, 0xb3, 0x98, 0x2c, 0xda, 0x0a,
  242. 0x1e, 0x9f, 0xc5, 0x79, 0x41, 0x71, 0x16, 0xe3, 0xb7, 0x11, 0xf2, 0x92, 0x28, 0xa5, 0x9e, 0x90,
  243. 0x9b, 0x7e, 0x5d, 0xa5, 0xbc, 0x54, 0x4d, 0xe9, 0xe5, 0xf1, 0x2c, 0xb3, 0x94, 0x82, 0xdf, 0x41,
  244. 0xcd, 0x10, 0x28, 0x07, 0x77, 0xc8, 0x68, 0x2c, 0xc8, 0x92, 0x8d, 0xf0, 0x48, 0x1a, 0x0e, 0x64,
  245. 0x3c, 0x27, 0x84, 0xb9, 0x24, 0xd7, 0xac, 0x09, 0x0c, 0x26, 0xc9, 0x29, 0x90, 0x86, 0x6d, 0xcd,
  246. 0x0a, 0xe1, 0x28, 0x43, 0xbe, 0xe6, 0xb0, 0xd0, 0xe4, 0x6b, 0xa1, 0x21, 0x65, 0x11, 0x41, 0xb6,
  247. 0xd7, 0xd2, 0x95, 0xa1, 0xfc, 0xb5, 0x28, 0x23, 0x7e, 0x1f, 0xad, 0xe9, 0xb2, 0xde, 0x08, 0xbc,
  248. 0xd3, 0x34, 0x09, 0x62, 0x41, 0x9a, 0x2a, 0xf9, 0x65, 0x4b, 0xe9, 0x5e, 0x6e, 0xca, 0x30, 0x37,
  249. 0xc2, 0xaa, 0x8e, 0xbb, 0xa8, 0xa9, 0x46, 0x18, 0x62, 0x3a, 0x08, 0x81, 0xfc, 0x6d, 0xdd, 0xcc,
  250. 0xee, 0x58, 0x8c, 0xf6, 0x95, 0x21, 0xdf, 0x0a, 0x9a, 0x4b, 0xb8, 0x8f, 0xd4, 0xc0, 0xbb, 0x7e,
  251. 0xc0, 0x15, 0xe3, 0x9f, 0xeb, 0xb6, 0xbd, 0x90, 0x8c, 0xbe, 0x76, 0xe4, 0x7b, 0x41, 0x0b, 0x2d,
  252. 0x6f, 0x84, 0x0b, 0x2a, 0xc6, 0x9c, 0xfc, 0x37, 0xb7, 0x91, 0x27, 0xca, 0x50, 0x69, 0x44, 0x4b,
  253. 0xf8, 0xb1, 0x6e, 0x04, 0x62, 0x11, 0x78, 0x54, 0x00, 0xf9, 0x57, 0x33, 0x5e, 0xad, 0x32, 0xb2,
  254. 0xb3, 0xd8, 0x2d, 0x59, 0x33, 0x5a, 0x25, 0x1f, 0xef, 0x9b, 0xe3, 0x2d, 0xcf, 0xbb, 0x4b, 0x7d,
  255. 0x9f, 0xfc, 0xb8, 0x34, 0x6f, 0x65, 0x1f, 0x70, 0x60, 0x5d, 0xdf, 0xaf, 0xac, 0xcc, 0x68, 0xf8,
  256. 0x31, 0x5a, 0x2b, 0x30, 0x7a, 0xe4, 0xc9, 0x4f, 0x9a, 0x74, 0xd7, 0x4e, 0x32, 0x67, 0xc5, 0xc0,
  257. 0x56, 0x69, 0x45, 0xae, 0xb6, 0x35, 0x04, 0x41, 0x7e, 0xbe, 0xb4, 0xad, 0x03, 0x10, 0x33, 0x6d,
  258. 0x1d, 0x80, 0xc0, 0x43, 0xf4, 0x62, 0x81, 0xf1, 0x46, 0xf2, 0x10, 0xba, 0x29, 0xe5, 0xfc, 0x69,
  259. 0xc2, 0x7c, 0xf2, 0x8b, 0x46, 0xbe, 0x6e, 0x47, 0xf6, 0x94, 0xfb, 0xc8, 0x98, 0x33, 0xfa, 0x0b,
  260. 0xd4, 0x1a, 0xc6, 0x1f, 0xa3, 0x8d, 0x52, 0xbf, 0xf2, 0xf4, 0xb8, 0x2c, 0x09, 0x81, 0x9c, 0xeb,
  261. 0x1a, 0xf7, 0xe7, 0xb4, 0xad, 0x4e, 0x5e, 0x52, 0x4c, 0xcb, 0x4d, 0x3a, 0x1d, 0xc1, 0x9f, 0xa0,
  262. 0x5b, 0x05, 0x59, 0x1f, 0x44, 0x8d, 0xfe, 0x55, 0xa3, 0x5f, 0xb1, 0xa3, 0xcd, 0x89, 0x2c, 0xb1,
  263. 0x31, 0x9d, 0x09, 0xe1, 0x87, 0x68, 0xb5, 0x80, 0x87, 0x01, 0x17, 0xe4, 0x37, 0x4d, 0xbd, 0x63,
  264. 0xa7, 0x3e, 0x0a, 0xb8, 0xa8, 0xcc, 0x51, 0x26, 0xe6, 0x24, 0xd9, 0x9a, 0x26, 0xfd, 0x3e, 0x97,
  265. 0x24, 0x4b, 0xcf, 0x90, 0x32, 0x31, 0x7f, 0xf5, 0x8a, 0x24, 0x27, 0xf2, 0x9b, 0xc6, 0xbc, 0x57,
  266. 0x2f, 0x73, 0xa6, 0x27, 0xd2, 0x68, 0xf9, 0x44, 0x2a, 0x8c, 0x99, 0xc8, 0x6f, 0x1b, 0xf3, 0x26,
  267. 0x52, 0x66, 0x59, 0x26, 0xb2, 0x90, 0xab, 0x6d, 0xc9, 0x89, 0xfc, 0xee, 0xd2, 0xb6, 0xa6, 0x27,
  268. 0xd2, 0x68, 0xf8, 0x33, 0xd4, 0x2a, 0x61, 0xd4, 0xa0, 0xa4, 0xc0, 0xa2, 0x80, 0xab, 0xff, 0xd6,
  269. 0xef, 0x35, 0xf3, 0x8d, 0x39, 0x4c, 0x69, 0x3f, 0xca, 0xdd, 0x19, 0xff, 0x36, 0xb5, 0xc7, 0x71,
  270. 0x84, 0x36, 0x8b, 0x5a, 0x66, 0x74, 0x4a, 0xc5, 0x7e, 0xd0, 0xc5, 0xde, 0xb4, 0x17, 0xd3, 0x53,
  271. 0x32, 0x5b, 0x8d, 0xd0, 0x39, 0x06, 0xfc, 0x11, 0x5a, 0xf7, 0xc2, 0x31, 0x17, 0xc0, 0xdc, 0x09,
  272. 0x30, 0x29, 0xb9, 0x1c, 0x04, 0x79, 0x86, 0xcc, 0x11, 0x28, 0x5f, 0x52, 0x76, 0x7b, 0xda, 0xf9,
  273. 0xa1, 0x36, 0x3e, 0x29, 0x76, 0xeb, 0xa6, 0x37, 0x1d, 0xc1, 0x14, 0xdd, 0xce, 0xc0, 0x9a, 0xe1,
  274. 0x52, 0x21, 0x98, 0x82, 0x7f, 0x89, 0xcc, 0xe7, 0xcf, 0x06, 0x7f, 0x4f, 0x69, 0x5d, 0x21, 0x58,
  275. 0x89, 0xbf, 0xe1, 0x59, 0x82, 0xf8, 0x18, 0x61, 0x3f, 0x79, 0x1a, 0x0f, 0x19, 0xf5, 0xc1, 0x0d,
  276. 0xe2, 0x93, 0x44, 0xd1, 0xbf, 0xd2, 0xf4, 0x7b, 0x55, 0x7a, 0x3f, 0x33, 0x1e, 0xc6, 0x27, 0x49,
  277. 0x89, 0xbc, 0xe6, 0x4f, 0x05, 0xb6, 0x6f, 0xa0, 0x95, 0xfd, 0x28, 0x15, 0x5f, 0x38, 0xc0, 0xd3,
  278. 0x24, 0xe6, 0xb0, 0x9d, 0xa2, 0xcd, 0x4b, 0x3e, 0xcd, 0x18, 0xa3, 0x05, 0x75, 0x07, 0xab, 0xa9,
  279. 0x3b, 0x98, 0xfa, 0x2d, 0xef, 0x66, 0xf9, 0x17, 0xcb, 0xdc, 0xcd, 0xb2, 0x67, 0x7c, 0x07, 0x2d,
  280. 0xf3, 0x20, 0x4a, 0x43, 0x70, 0x45, 0x72, 0x0a, 0xfa, 0x6a, 0xd6, 0x70, 0x9a, 0x5a, 0x3b, 0x96,
  281. 0xd2, 0xbb, 0x1b, 0xcf, 0xff, 0x6c, 0x5f, 0x79, 0x7e, 0xd1, 0xae, 0x9d, 0x5f, 0xb4, 0x6b, 0x7f,
  282. 0x5c, 0xb4, 0x6b, 0x5f, 0xff, 0xd5, 0xbe, 0x32, 0x58, 0x54, 0x17, 0xc3, 0x07, 0xff, 0x07, 0x00,
  283. 0x00, 0xff, 0xff, 0x94, 0x6f, 0x64, 0x0a, 0x98, 0x0a, 0x00, 0x00,
  284. }
  285. func (m *RequestHeader) Marshal() (dAtA []byte, err error) {
  286. size := m.Size()
  287. dAtA = make([]byte, size)
  288. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  289. if err != nil {
  290. return nil, err
  291. }
  292. return dAtA[:n], nil
  293. }
  294. func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) {
  295. size := m.Size()
  296. return m.MarshalToSizedBuffer(dAtA[:size])
  297. }
  298. func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  299. i := len(dAtA)
  300. _ = i
  301. var l int
  302. _ = l
  303. if m.XXX_unrecognized != nil {
  304. i -= len(m.XXX_unrecognized)
  305. copy(dAtA[i:], m.XXX_unrecognized)
  306. }
  307. if m.AuthRevision != 0 {
  308. i = encodeVarintRaftInternal(dAtA, i, uint64(m.AuthRevision))
  309. i--
  310. dAtA[i] = 0x18
  311. }
  312. if len(m.Username) > 0 {
  313. i -= len(m.Username)
  314. copy(dAtA[i:], m.Username)
  315. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Username)))
  316. i--
  317. dAtA[i] = 0x12
  318. }
  319. if m.ID != 0 {
  320. i = encodeVarintRaftInternal(dAtA, i, uint64(m.ID))
  321. i--
  322. dAtA[i] = 0x8
  323. }
  324. return len(dAtA) - i, nil
  325. }
  326. func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error) {
  327. size := m.Size()
  328. dAtA = make([]byte, size)
  329. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  330. if err != nil {
  331. return nil, err
  332. }
  333. return dAtA[:n], nil
  334. }
  335. func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error) {
  336. size := m.Size()
  337. return m.MarshalToSizedBuffer(dAtA[:size])
  338. }
  339. func (m *InternalRaftRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  340. i := len(dAtA)
  341. _ = i
  342. var l int
  343. _ = l
  344. if m.XXX_unrecognized != nil {
  345. i -= len(m.XXX_unrecognized)
  346. copy(dAtA[i:], m.XXX_unrecognized)
  347. }
  348. if m.DowngradeInfoSet != nil {
  349. {
  350. size, err := m.DowngradeInfoSet.MarshalToSizedBuffer(dAtA[:i])
  351. if err != nil {
  352. return 0, err
  353. }
  354. i -= size
  355. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  356. }
  357. i--
  358. dAtA[i] = 0x51
  359. i--
  360. dAtA[i] = 0xb2
  361. }
  362. if m.ClusterMemberAttrSet != nil {
  363. {
  364. size, err := m.ClusterMemberAttrSet.MarshalToSizedBuffer(dAtA[:i])
  365. if err != nil {
  366. return 0, err
  367. }
  368. i -= size
  369. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  370. }
  371. i--
  372. dAtA[i] = 0x51
  373. i--
  374. dAtA[i] = 0xaa
  375. }
  376. if m.ClusterVersionSet != nil {
  377. {
  378. size, err := m.ClusterVersionSet.MarshalToSizedBuffer(dAtA[:i])
  379. if err != nil {
  380. return 0, err
  381. }
  382. i -= size
  383. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  384. }
  385. i--
  386. dAtA[i] = 0x51
  387. i--
  388. dAtA[i] = 0xa2
  389. }
  390. if m.AuthRoleRevokePermission != nil {
  391. {
  392. size, err := m.AuthRoleRevokePermission.MarshalToSizedBuffer(dAtA[:i])
  393. if err != nil {
  394. return 0, err
  395. }
  396. i -= size
  397. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  398. }
  399. i--
  400. dAtA[i] = 0x4b
  401. i--
  402. dAtA[i] = 0xa2
  403. }
  404. if m.AuthRoleGrantPermission != nil {
  405. {
  406. size, err := m.AuthRoleGrantPermission.MarshalToSizedBuffer(dAtA[:i])
  407. if err != nil {
  408. return 0, err
  409. }
  410. i -= size
  411. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  412. }
  413. i--
  414. dAtA[i] = 0x4b
  415. i--
  416. dAtA[i] = 0x9a
  417. }
  418. if m.AuthRoleGet != nil {
  419. {
  420. size, err := m.AuthRoleGet.MarshalToSizedBuffer(dAtA[:i])
  421. if err != nil {
  422. return 0, err
  423. }
  424. i -= size
  425. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  426. }
  427. i--
  428. dAtA[i] = 0x4b
  429. i--
  430. dAtA[i] = 0x92
  431. }
  432. if m.AuthRoleDelete != nil {
  433. {
  434. size, err := m.AuthRoleDelete.MarshalToSizedBuffer(dAtA[:i])
  435. if err != nil {
  436. return 0, err
  437. }
  438. i -= size
  439. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  440. }
  441. i--
  442. dAtA[i] = 0x4b
  443. i--
  444. dAtA[i] = 0x8a
  445. }
  446. if m.AuthRoleAdd != nil {
  447. {
  448. size, err := m.AuthRoleAdd.MarshalToSizedBuffer(dAtA[:i])
  449. if err != nil {
  450. return 0, err
  451. }
  452. i -= size
  453. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  454. }
  455. i--
  456. dAtA[i] = 0x4b
  457. i--
  458. dAtA[i] = 0x82
  459. }
  460. if m.AuthRoleList != nil {
  461. {
  462. size, err := m.AuthRoleList.MarshalToSizedBuffer(dAtA[:i])
  463. if err != nil {
  464. return 0, err
  465. }
  466. i -= size
  467. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  468. }
  469. i--
  470. dAtA[i] = 0x45
  471. i--
  472. dAtA[i] = 0x9a
  473. }
  474. if m.AuthUserList != nil {
  475. {
  476. size, err := m.AuthUserList.MarshalToSizedBuffer(dAtA[:i])
  477. if err != nil {
  478. return 0, err
  479. }
  480. i -= size
  481. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  482. }
  483. i--
  484. dAtA[i] = 0x45
  485. i--
  486. dAtA[i] = 0x92
  487. }
  488. if m.AuthUserRevokeRole != nil {
  489. {
  490. size, err := m.AuthUserRevokeRole.MarshalToSizedBuffer(dAtA[:i])
  491. if err != nil {
  492. return 0, err
  493. }
  494. i -= size
  495. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  496. }
  497. i--
  498. dAtA[i] = 0x45
  499. i--
  500. dAtA[i] = 0x8a
  501. }
  502. if m.AuthUserGrantRole != nil {
  503. {
  504. size, err := m.AuthUserGrantRole.MarshalToSizedBuffer(dAtA[:i])
  505. if err != nil {
  506. return 0, err
  507. }
  508. i -= size
  509. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  510. }
  511. i--
  512. dAtA[i] = 0x45
  513. i--
  514. dAtA[i] = 0x82
  515. }
  516. if m.AuthUserChangePassword != nil {
  517. {
  518. size, err := m.AuthUserChangePassword.MarshalToSizedBuffer(dAtA[:i])
  519. if err != nil {
  520. return 0, err
  521. }
  522. i -= size
  523. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  524. }
  525. i--
  526. dAtA[i] = 0x44
  527. i--
  528. dAtA[i] = 0xfa
  529. }
  530. if m.AuthUserGet != nil {
  531. {
  532. size, err := m.AuthUserGet.MarshalToSizedBuffer(dAtA[:i])
  533. if err != nil {
  534. return 0, err
  535. }
  536. i -= size
  537. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  538. }
  539. i--
  540. dAtA[i] = 0x44
  541. i--
  542. dAtA[i] = 0xf2
  543. }
  544. if m.AuthUserDelete != nil {
  545. {
  546. size, err := m.AuthUserDelete.MarshalToSizedBuffer(dAtA[:i])
  547. if err != nil {
  548. return 0, err
  549. }
  550. i -= size
  551. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  552. }
  553. i--
  554. dAtA[i] = 0x44
  555. i--
  556. dAtA[i] = 0xea
  557. }
  558. if m.AuthUserAdd != nil {
  559. {
  560. size, err := m.AuthUserAdd.MarshalToSizedBuffer(dAtA[:i])
  561. if err != nil {
  562. return 0, err
  563. }
  564. i -= size
  565. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  566. }
  567. i--
  568. dAtA[i] = 0x44
  569. i--
  570. dAtA[i] = 0xe2
  571. }
  572. if m.AuthStatus != nil {
  573. {
  574. size, err := m.AuthStatus.MarshalToSizedBuffer(dAtA[:i])
  575. if err != nil {
  576. return 0, err
  577. }
  578. i -= size
  579. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  580. }
  581. i--
  582. dAtA[i] = 0x3f
  583. i--
  584. dAtA[i] = 0xaa
  585. }
  586. if m.Authenticate != nil {
  587. {
  588. size, err := m.Authenticate.MarshalToSizedBuffer(dAtA[:i])
  589. if err != nil {
  590. return 0, err
  591. }
  592. i -= size
  593. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  594. }
  595. i--
  596. dAtA[i] = 0x3f
  597. i--
  598. dAtA[i] = 0xa2
  599. }
  600. if m.AuthDisable != nil {
  601. {
  602. size, err := m.AuthDisable.MarshalToSizedBuffer(dAtA[:i])
  603. if err != nil {
  604. return 0, err
  605. }
  606. i -= size
  607. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  608. }
  609. i--
  610. dAtA[i] = 0x3f
  611. i--
  612. dAtA[i] = 0x9a
  613. }
  614. if m.AuthEnable != nil {
  615. {
  616. size, err := m.AuthEnable.MarshalToSizedBuffer(dAtA[:i])
  617. if err != nil {
  618. return 0, err
  619. }
  620. i -= size
  621. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  622. }
  623. i--
  624. dAtA[i] = 0x3e
  625. i--
  626. dAtA[i] = 0xc2
  627. }
  628. if m.Header != nil {
  629. {
  630. size, err := m.Header.MarshalToSizedBuffer(dAtA[:i])
  631. if err != nil {
  632. return 0, err
  633. }
  634. i -= size
  635. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  636. }
  637. i--
  638. dAtA[i] = 0x6
  639. i--
  640. dAtA[i] = 0xa2
  641. }
  642. if m.LeaseCheckpoint != nil {
  643. {
  644. size, err := m.LeaseCheckpoint.MarshalToSizedBuffer(dAtA[:i])
  645. if err != nil {
  646. return 0, err
  647. }
  648. i -= size
  649. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  650. }
  651. i--
  652. dAtA[i] = 0x5a
  653. }
  654. if m.Alarm != nil {
  655. {
  656. size, err := m.Alarm.MarshalToSizedBuffer(dAtA[:i])
  657. if err != nil {
  658. return 0, err
  659. }
  660. i -= size
  661. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  662. }
  663. i--
  664. dAtA[i] = 0x52
  665. }
  666. if m.LeaseRevoke != nil {
  667. {
  668. size, err := m.LeaseRevoke.MarshalToSizedBuffer(dAtA[:i])
  669. if err != nil {
  670. return 0, err
  671. }
  672. i -= size
  673. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  674. }
  675. i--
  676. dAtA[i] = 0x4a
  677. }
  678. if m.LeaseGrant != nil {
  679. {
  680. size, err := m.LeaseGrant.MarshalToSizedBuffer(dAtA[:i])
  681. if err != nil {
  682. return 0, err
  683. }
  684. i -= size
  685. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  686. }
  687. i--
  688. dAtA[i] = 0x42
  689. }
  690. if m.Compaction != nil {
  691. {
  692. size, err := m.Compaction.MarshalToSizedBuffer(dAtA[:i])
  693. if err != nil {
  694. return 0, err
  695. }
  696. i -= size
  697. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  698. }
  699. i--
  700. dAtA[i] = 0x3a
  701. }
  702. if m.Txn != nil {
  703. {
  704. size, err := m.Txn.MarshalToSizedBuffer(dAtA[:i])
  705. if err != nil {
  706. return 0, err
  707. }
  708. i -= size
  709. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  710. }
  711. i--
  712. dAtA[i] = 0x32
  713. }
  714. if m.DeleteRange != nil {
  715. {
  716. size, err := m.DeleteRange.MarshalToSizedBuffer(dAtA[:i])
  717. if err != nil {
  718. return 0, err
  719. }
  720. i -= size
  721. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  722. }
  723. i--
  724. dAtA[i] = 0x2a
  725. }
  726. if m.Put != nil {
  727. {
  728. size, err := m.Put.MarshalToSizedBuffer(dAtA[:i])
  729. if err != nil {
  730. return 0, err
  731. }
  732. i -= size
  733. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  734. }
  735. i--
  736. dAtA[i] = 0x22
  737. }
  738. if m.Range != nil {
  739. {
  740. size, err := m.Range.MarshalToSizedBuffer(dAtA[:i])
  741. if err != nil {
  742. return 0, err
  743. }
  744. i -= size
  745. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  746. }
  747. i--
  748. dAtA[i] = 0x1a
  749. }
  750. if m.V2 != nil {
  751. {
  752. size, err := m.V2.MarshalToSizedBuffer(dAtA[:i])
  753. if err != nil {
  754. return 0, err
  755. }
  756. i -= size
  757. i = encodeVarintRaftInternal(dAtA, i, uint64(size))
  758. }
  759. i--
  760. dAtA[i] = 0x12
  761. }
  762. if m.ID != 0 {
  763. i = encodeVarintRaftInternal(dAtA, i, uint64(m.ID))
  764. i--
  765. dAtA[i] = 0x8
  766. }
  767. return len(dAtA) - i, nil
  768. }
  769. func (m *EmptyResponse) Marshal() (dAtA []byte, err error) {
  770. size := m.Size()
  771. dAtA = make([]byte, size)
  772. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  773. if err != nil {
  774. return nil, err
  775. }
  776. return dAtA[:n], nil
  777. }
  778. func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error) {
  779. size := m.Size()
  780. return m.MarshalToSizedBuffer(dAtA[:size])
  781. }
  782. func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  783. i := len(dAtA)
  784. _ = i
  785. var l int
  786. _ = l
  787. if m.XXX_unrecognized != nil {
  788. i -= len(m.XXX_unrecognized)
  789. copy(dAtA[i:], m.XXX_unrecognized)
  790. }
  791. return len(dAtA) - i, nil
  792. }
  793. func (m *InternalAuthenticateRequest) Marshal() (dAtA []byte, err error) {
  794. size := m.Size()
  795. dAtA = make([]byte, size)
  796. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  797. if err != nil {
  798. return nil, err
  799. }
  800. return dAtA[:n], nil
  801. }
  802. func (m *InternalAuthenticateRequest) MarshalTo(dAtA []byte) (int, error) {
  803. size := m.Size()
  804. return m.MarshalToSizedBuffer(dAtA[:size])
  805. }
  806. func (m *InternalAuthenticateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  807. i := len(dAtA)
  808. _ = i
  809. var l int
  810. _ = l
  811. if m.XXX_unrecognized != nil {
  812. i -= len(m.XXX_unrecognized)
  813. copy(dAtA[i:], m.XXX_unrecognized)
  814. }
  815. if len(m.SimpleToken) > 0 {
  816. i -= len(m.SimpleToken)
  817. copy(dAtA[i:], m.SimpleToken)
  818. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.SimpleToken)))
  819. i--
  820. dAtA[i] = 0x1a
  821. }
  822. if len(m.Password) > 0 {
  823. i -= len(m.Password)
  824. copy(dAtA[i:], m.Password)
  825. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Password)))
  826. i--
  827. dAtA[i] = 0x12
  828. }
  829. if len(m.Name) > 0 {
  830. i -= len(m.Name)
  831. copy(dAtA[i:], m.Name)
  832. i = encodeVarintRaftInternal(dAtA, i, uint64(len(m.Name)))
  833. i--
  834. dAtA[i] = 0xa
  835. }
  836. return len(dAtA) - i, nil
  837. }
  838. func encodeVarintRaftInternal(dAtA []byte, offset int, v uint64) int {
  839. offset -= sovRaftInternal(v)
  840. base := offset
  841. for v >= 1<<7 {
  842. dAtA[offset] = uint8(v&0x7f | 0x80)
  843. v >>= 7
  844. offset++
  845. }
  846. dAtA[offset] = uint8(v)
  847. return base
  848. }
  849. func (m *RequestHeader) Size() (n int) {
  850. if m == nil {
  851. return 0
  852. }
  853. var l int
  854. _ = l
  855. if m.ID != 0 {
  856. n += 1 + sovRaftInternal(uint64(m.ID))
  857. }
  858. l = len(m.Username)
  859. if l > 0 {
  860. n += 1 + l + sovRaftInternal(uint64(l))
  861. }
  862. if m.AuthRevision != 0 {
  863. n += 1 + sovRaftInternal(uint64(m.AuthRevision))
  864. }
  865. if m.XXX_unrecognized != nil {
  866. n += len(m.XXX_unrecognized)
  867. }
  868. return n
  869. }
  870. func (m *InternalRaftRequest) Size() (n int) {
  871. if m == nil {
  872. return 0
  873. }
  874. var l int
  875. _ = l
  876. if m.ID != 0 {
  877. n += 1 + sovRaftInternal(uint64(m.ID))
  878. }
  879. if m.V2 != nil {
  880. l = m.V2.Size()
  881. n += 1 + l + sovRaftInternal(uint64(l))
  882. }
  883. if m.Range != nil {
  884. l = m.Range.Size()
  885. n += 1 + l + sovRaftInternal(uint64(l))
  886. }
  887. if m.Put != nil {
  888. l = m.Put.Size()
  889. n += 1 + l + sovRaftInternal(uint64(l))
  890. }
  891. if m.DeleteRange != nil {
  892. l = m.DeleteRange.Size()
  893. n += 1 + l + sovRaftInternal(uint64(l))
  894. }
  895. if m.Txn != nil {
  896. l = m.Txn.Size()
  897. n += 1 + l + sovRaftInternal(uint64(l))
  898. }
  899. if m.Compaction != nil {
  900. l = m.Compaction.Size()
  901. n += 1 + l + sovRaftInternal(uint64(l))
  902. }
  903. if m.LeaseGrant != nil {
  904. l = m.LeaseGrant.Size()
  905. n += 1 + l + sovRaftInternal(uint64(l))
  906. }
  907. if m.LeaseRevoke != nil {
  908. l = m.LeaseRevoke.Size()
  909. n += 1 + l + sovRaftInternal(uint64(l))
  910. }
  911. if m.Alarm != nil {
  912. l = m.Alarm.Size()
  913. n += 1 + l + sovRaftInternal(uint64(l))
  914. }
  915. if m.LeaseCheckpoint != nil {
  916. l = m.LeaseCheckpoint.Size()
  917. n += 1 + l + sovRaftInternal(uint64(l))
  918. }
  919. if m.Header != nil {
  920. l = m.Header.Size()
  921. n += 2 + l + sovRaftInternal(uint64(l))
  922. }
  923. if m.AuthEnable != nil {
  924. l = m.AuthEnable.Size()
  925. n += 2 + l + sovRaftInternal(uint64(l))
  926. }
  927. if m.AuthDisable != nil {
  928. l = m.AuthDisable.Size()
  929. n += 2 + l + sovRaftInternal(uint64(l))
  930. }
  931. if m.Authenticate != nil {
  932. l = m.Authenticate.Size()
  933. n += 2 + l + sovRaftInternal(uint64(l))
  934. }
  935. if m.AuthStatus != nil {
  936. l = m.AuthStatus.Size()
  937. n += 2 + l + sovRaftInternal(uint64(l))
  938. }
  939. if m.AuthUserAdd != nil {
  940. l = m.AuthUserAdd.Size()
  941. n += 2 + l + sovRaftInternal(uint64(l))
  942. }
  943. if m.AuthUserDelete != nil {
  944. l = m.AuthUserDelete.Size()
  945. n += 2 + l + sovRaftInternal(uint64(l))
  946. }
  947. if m.AuthUserGet != nil {
  948. l = m.AuthUserGet.Size()
  949. n += 2 + l + sovRaftInternal(uint64(l))
  950. }
  951. if m.AuthUserChangePassword != nil {
  952. l = m.AuthUserChangePassword.Size()
  953. n += 2 + l + sovRaftInternal(uint64(l))
  954. }
  955. if m.AuthUserGrantRole != nil {
  956. l = m.AuthUserGrantRole.Size()
  957. n += 2 + l + sovRaftInternal(uint64(l))
  958. }
  959. if m.AuthUserRevokeRole != nil {
  960. l = m.AuthUserRevokeRole.Size()
  961. n += 2 + l + sovRaftInternal(uint64(l))
  962. }
  963. if m.AuthUserList != nil {
  964. l = m.AuthUserList.Size()
  965. n += 2 + l + sovRaftInternal(uint64(l))
  966. }
  967. if m.AuthRoleList != nil {
  968. l = m.AuthRoleList.Size()
  969. n += 2 + l + sovRaftInternal(uint64(l))
  970. }
  971. if m.AuthRoleAdd != nil {
  972. l = m.AuthRoleAdd.Size()
  973. n += 2 + l + sovRaftInternal(uint64(l))
  974. }
  975. if m.AuthRoleDelete != nil {
  976. l = m.AuthRoleDelete.Size()
  977. n += 2 + l + sovRaftInternal(uint64(l))
  978. }
  979. if m.AuthRoleGet != nil {
  980. l = m.AuthRoleGet.Size()
  981. n += 2 + l + sovRaftInternal(uint64(l))
  982. }
  983. if m.AuthRoleGrantPermission != nil {
  984. l = m.AuthRoleGrantPermission.Size()
  985. n += 2 + l + sovRaftInternal(uint64(l))
  986. }
  987. if m.AuthRoleRevokePermission != nil {
  988. l = m.AuthRoleRevokePermission.Size()
  989. n += 2 + l + sovRaftInternal(uint64(l))
  990. }
  991. if m.ClusterVersionSet != nil {
  992. l = m.ClusterVersionSet.Size()
  993. n += 2 + l + sovRaftInternal(uint64(l))
  994. }
  995. if m.ClusterMemberAttrSet != nil {
  996. l = m.ClusterMemberAttrSet.Size()
  997. n += 2 + l + sovRaftInternal(uint64(l))
  998. }
  999. if m.DowngradeInfoSet != nil {
  1000. l = m.DowngradeInfoSet.Size()
  1001. n += 2 + l + sovRaftInternal(uint64(l))
  1002. }
  1003. if m.XXX_unrecognized != nil {
  1004. n += len(m.XXX_unrecognized)
  1005. }
  1006. return n
  1007. }
  1008. func (m *EmptyResponse) Size() (n int) {
  1009. if m == nil {
  1010. return 0
  1011. }
  1012. var l int
  1013. _ = l
  1014. if m.XXX_unrecognized != nil {
  1015. n += len(m.XXX_unrecognized)
  1016. }
  1017. return n
  1018. }
  1019. func (m *InternalAuthenticateRequest) Size() (n int) {
  1020. if m == nil {
  1021. return 0
  1022. }
  1023. var l int
  1024. _ = l
  1025. l = len(m.Name)
  1026. if l > 0 {
  1027. n += 1 + l + sovRaftInternal(uint64(l))
  1028. }
  1029. l = len(m.Password)
  1030. if l > 0 {
  1031. n += 1 + l + sovRaftInternal(uint64(l))
  1032. }
  1033. l = len(m.SimpleToken)
  1034. if l > 0 {
  1035. n += 1 + l + sovRaftInternal(uint64(l))
  1036. }
  1037. if m.XXX_unrecognized != nil {
  1038. n += len(m.XXX_unrecognized)
  1039. }
  1040. return n
  1041. }
  1042. func sovRaftInternal(x uint64) (n int) {
  1043. return (math_bits.Len64(x|1) + 6) / 7
  1044. }
  1045. func sozRaftInternal(x uint64) (n int) {
  1046. return sovRaftInternal(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  1047. }
  1048. func (m *RequestHeader) Unmarshal(dAtA []byte) error {
  1049. l := len(dAtA)
  1050. iNdEx := 0
  1051. for iNdEx < l {
  1052. preIndex := iNdEx
  1053. var wire uint64
  1054. for shift := uint(0); ; shift += 7 {
  1055. if shift >= 64 {
  1056. return ErrIntOverflowRaftInternal
  1057. }
  1058. if iNdEx >= l {
  1059. return io.ErrUnexpectedEOF
  1060. }
  1061. b := dAtA[iNdEx]
  1062. iNdEx++
  1063. wire |= uint64(b&0x7F) << shift
  1064. if b < 0x80 {
  1065. break
  1066. }
  1067. }
  1068. fieldNum := int32(wire >> 3)
  1069. wireType := int(wire & 0x7)
  1070. if wireType == 4 {
  1071. return fmt.Errorf("proto: RequestHeader: wiretype end group for non-group")
  1072. }
  1073. if fieldNum <= 0 {
  1074. return fmt.Errorf("proto: RequestHeader: illegal tag %d (wire type %d)", fieldNum, wire)
  1075. }
  1076. switch fieldNum {
  1077. case 1:
  1078. if wireType != 0 {
  1079. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  1080. }
  1081. m.ID = 0
  1082. for shift := uint(0); ; shift += 7 {
  1083. if shift >= 64 {
  1084. return ErrIntOverflowRaftInternal
  1085. }
  1086. if iNdEx >= l {
  1087. return io.ErrUnexpectedEOF
  1088. }
  1089. b := dAtA[iNdEx]
  1090. iNdEx++
  1091. m.ID |= uint64(b&0x7F) << shift
  1092. if b < 0x80 {
  1093. break
  1094. }
  1095. }
  1096. case 2:
  1097. if wireType != 2 {
  1098. return fmt.Errorf("proto: wrong wireType = %d for field Username", wireType)
  1099. }
  1100. var stringLen uint64
  1101. for shift := uint(0); ; shift += 7 {
  1102. if shift >= 64 {
  1103. return ErrIntOverflowRaftInternal
  1104. }
  1105. if iNdEx >= l {
  1106. return io.ErrUnexpectedEOF
  1107. }
  1108. b := dAtA[iNdEx]
  1109. iNdEx++
  1110. stringLen |= uint64(b&0x7F) << shift
  1111. if b < 0x80 {
  1112. break
  1113. }
  1114. }
  1115. intStringLen := int(stringLen)
  1116. if intStringLen < 0 {
  1117. return ErrInvalidLengthRaftInternal
  1118. }
  1119. postIndex := iNdEx + intStringLen
  1120. if postIndex < 0 {
  1121. return ErrInvalidLengthRaftInternal
  1122. }
  1123. if postIndex > l {
  1124. return io.ErrUnexpectedEOF
  1125. }
  1126. m.Username = string(dAtA[iNdEx:postIndex])
  1127. iNdEx = postIndex
  1128. case 3:
  1129. if wireType != 0 {
  1130. return fmt.Errorf("proto: wrong wireType = %d for field AuthRevision", wireType)
  1131. }
  1132. m.AuthRevision = 0
  1133. for shift := uint(0); ; shift += 7 {
  1134. if shift >= 64 {
  1135. return ErrIntOverflowRaftInternal
  1136. }
  1137. if iNdEx >= l {
  1138. return io.ErrUnexpectedEOF
  1139. }
  1140. b := dAtA[iNdEx]
  1141. iNdEx++
  1142. m.AuthRevision |= uint64(b&0x7F) << shift
  1143. if b < 0x80 {
  1144. break
  1145. }
  1146. }
  1147. default:
  1148. iNdEx = preIndex
  1149. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  1150. if err != nil {
  1151. return err
  1152. }
  1153. if (skippy < 0) || (iNdEx+skippy) < 0 {
  1154. return ErrInvalidLengthRaftInternal
  1155. }
  1156. if (iNdEx + skippy) > l {
  1157. return io.ErrUnexpectedEOF
  1158. }
  1159. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1160. iNdEx += skippy
  1161. }
  1162. }
  1163. if iNdEx > l {
  1164. return io.ErrUnexpectedEOF
  1165. }
  1166. return nil
  1167. }
  1168. func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error {
  1169. l := len(dAtA)
  1170. iNdEx := 0
  1171. for iNdEx < l {
  1172. preIndex := iNdEx
  1173. var wire uint64
  1174. for shift := uint(0); ; shift += 7 {
  1175. if shift >= 64 {
  1176. return ErrIntOverflowRaftInternal
  1177. }
  1178. if iNdEx >= l {
  1179. return io.ErrUnexpectedEOF
  1180. }
  1181. b := dAtA[iNdEx]
  1182. iNdEx++
  1183. wire |= uint64(b&0x7F) << shift
  1184. if b < 0x80 {
  1185. break
  1186. }
  1187. }
  1188. fieldNum := int32(wire >> 3)
  1189. wireType := int(wire & 0x7)
  1190. if wireType == 4 {
  1191. return fmt.Errorf("proto: InternalRaftRequest: wiretype end group for non-group")
  1192. }
  1193. if fieldNum <= 0 {
  1194. return fmt.Errorf("proto: InternalRaftRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  1195. }
  1196. switch fieldNum {
  1197. case 1:
  1198. if wireType != 0 {
  1199. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  1200. }
  1201. m.ID = 0
  1202. for shift := uint(0); ; shift += 7 {
  1203. if shift >= 64 {
  1204. return ErrIntOverflowRaftInternal
  1205. }
  1206. if iNdEx >= l {
  1207. return io.ErrUnexpectedEOF
  1208. }
  1209. b := dAtA[iNdEx]
  1210. iNdEx++
  1211. m.ID |= uint64(b&0x7F) << shift
  1212. if b < 0x80 {
  1213. break
  1214. }
  1215. }
  1216. case 2:
  1217. if wireType != 2 {
  1218. return fmt.Errorf("proto: wrong wireType = %d for field V2", 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 < 0 {
  1240. return ErrInvalidLengthRaftInternal
  1241. }
  1242. if postIndex > l {
  1243. return io.ErrUnexpectedEOF
  1244. }
  1245. if m.V2 == nil {
  1246. m.V2 = &Request{}
  1247. }
  1248. if err := m.V2.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1249. return err
  1250. }
  1251. iNdEx = postIndex
  1252. case 3:
  1253. if wireType != 2 {
  1254. return fmt.Errorf("proto: wrong wireType = %d for field Range", wireType)
  1255. }
  1256. var msglen int
  1257. for shift := uint(0); ; shift += 7 {
  1258. if shift >= 64 {
  1259. return ErrIntOverflowRaftInternal
  1260. }
  1261. if iNdEx >= l {
  1262. return io.ErrUnexpectedEOF
  1263. }
  1264. b := dAtA[iNdEx]
  1265. iNdEx++
  1266. msglen |= int(b&0x7F) << shift
  1267. if b < 0x80 {
  1268. break
  1269. }
  1270. }
  1271. if msglen < 0 {
  1272. return ErrInvalidLengthRaftInternal
  1273. }
  1274. postIndex := iNdEx + msglen
  1275. if postIndex < 0 {
  1276. return ErrInvalidLengthRaftInternal
  1277. }
  1278. if postIndex > l {
  1279. return io.ErrUnexpectedEOF
  1280. }
  1281. if m.Range == nil {
  1282. m.Range = &RangeRequest{}
  1283. }
  1284. if err := m.Range.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1285. return err
  1286. }
  1287. iNdEx = postIndex
  1288. case 4:
  1289. if wireType != 2 {
  1290. return fmt.Errorf("proto: wrong wireType = %d for field Put", wireType)
  1291. }
  1292. var msglen int
  1293. for shift := uint(0); ; shift += 7 {
  1294. if shift >= 64 {
  1295. return ErrIntOverflowRaftInternal
  1296. }
  1297. if iNdEx >= l {
  1298. return io.ErrUnexpectedEOF
  1299. }
  1300. b := dAtA[iNdEx]
  1301. iNdEx++
  1302. msglen |= int(b&0x7F) << shift
  1303. if b < 0x80 {
  1304. break
  1305. }
  1306. }
  1307. if msglen < 0 {
  1308. return ErrInvalidLengthRaftInternal
  1309. }
  1310. postIndex := iNdEx + msglen
  1311. if postIndex < 0 {
  1312. return ErrInvalidLengthRaftInternal
  1313. }
  1314. if postIndex > l {
  1315. return io.ErrUnexpectedEOF
  1316. }
  1317. if m.Put == nil {
  1318. m.Put = &PutRequest{}
  1319. }
  1320. if err := m.Put.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1321. return err
  1322. }
  1323. iNdEx = postIndex
  1324. case 5:
  1325. if wireType != 2 {
  1326. return fmt.Errorf("proto: wrong wireType = %d for field DeleteRange", wireType)
  1327. }
  1328. var msglen int
  1329. for shift := uint(0); ; shift += 7 {
  1330. if shift >= 64 {
  1331. return ErrIntOverflowRaftInternal
  1332. }
  1333. if iNdEx >= l {
  1334. return io.ErrUnexpectedEOF
  1335. }
  1336. b := dAtA[iNdEx]
  1337. iNdEx++
  1338. msglen |= int(b&0x7F) << shift
  1339. if b < 0x80 {
  1340. break
  1341. }
  1342. }
  1343. if msglen < 0 {
  1344. return ErrInvalidLengthRaftInternal
  1345. }
  1346. postIndex := iNdEx + msglen
  1347. if postIndex < 0 {
  1348. return ErrInvalidLengthRaftInternal
  1349. }
  1350. if postIndex > l {
  1351. return io.ErrUnexpectedEOF
  1352. }
  1353. if m.DeleteRange == nil {
  1354. m.DeleteRange = &DeleteRangeRequest{}
  1355. }
  1356. if err := m.DeleteRange.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1357. return err
  1358. }
  1359. iNdEx = postIndex
  1360. case 6:
  1361. if wireType != 2 {
  1362. return fmt.Errorf("proto: wrong wireType = %d for field Txn", wireType)
  1363. }
  1364. var msglen int
  1365. for shift := uint(0); ; shift += 7 {
  1366. if shift >= 64 {
  1367. return ErrIntOverflowRaftInternal
  1368. }
  1369. if iNdEx >= l {
  1370. return io.ErrUnexpectedEOF
  1371. }
  1372. b := dAtA[iNdEx]
  1373. iNdEx++
  1374. msglen |= int(b&0x7F) << shift
  1375. if b < 0x80 {
  1376. break
  1377. }
  1378. }
  1379. if msglen < 0 {
  1380. return ErrInvalidLengthRaftInternal
  1381. }
  1382. postIndex := iNdEx + msglen
  1383. if postIndex < 0 {
  1384. return ErrInvalidLengthRaftInternal
  1385. }
  1386. if postIndex > l {
  1387. return io.ErrUnexpectedEOF
  1388. }
  1389. if m.Txn == nil {
  1390. m.Txn = &TxnRequest{}
  1391. }
  1392. if err := m.Txn.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1393. return err
  1394. }
  1395. iNdEx = postIndex
  1396. case 7:
  1397. if wireType != 2 {
  1398. return fmt.Errorf("proto: wrong wireType = %d for field Compaction", 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 < 0 {
  1420. return ErrInvalidLengthRaftInternal
  1421. }
  1422. if postIndex > l {
  1423. return io.ErrUnexpectedEOF
  1424. }
  1425. if m.Compaction == nil {
  1426. m.Compaction = &CompactionRequest{}
  1427. }
  1428. if err := m.Compaction.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1429. return err
  1430. }
  1431. iNdEx = postIndex
  1432. case 8:
  1433. if wireType != 2 {
  1434. return fmt.Errorf("proto: wrong wireType = %d for field LeaseGrant", wireType)
  1435. }
  1436. var msglen int
  1437. for shift := uint(0); ; shift += 7 {
  1438. if shift >= 64 {
  1439. return ErrIntOverflowRaftInternal
  1440. }
  1441. if iNdEx >= l {
  1442. return io.ErrUnexpectedEOF
  1443. }
  1444. b := dAtA[iNdEx]
  1445. iNdEx++
  1446. msglen |= int(b&0x7F) << shift
  1447. if b < 0x80 {
  1448. break
  1449. }
  1450. }
  1451. if msglen < 0 {
  1452. return ErrInvalidLengthRaftInternal
  1453. }
  1454. postIndex := iNdEx + msglen
  1455. if postIndex < 0 {
  1456. return ErrInvalidLengthRaftInternal
  1457. }
  1458. if postIndex > l {
  1459. return io.ErrUnexpectedEOF
  1460. }
  1461. if m.LeaseGrant == nil {
  1462. m.LeaseGrant = &LeaseGrantRequest{}
  1463. }
  1464. if err := m.LeaseGrant.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1465. return err
  1466. }
  1467. iNdEx = postIndex
  1468. case 9:
  1469. if wireType != 2 {
  1470. return fmt.Errorf("proto: wrong wireType = %d for field LeaseRevoke", wireType)
  1471. }
  1472. var msglen int
  1473. for shift := uint(0); ; shift += 7 {
  1474. if shift >= 64 {
  1475. return ErrIntOverflowRaftInternal
  1476. }
  1477. if iNdEx >= l {
  1478. return io.ErrUnexpectedEOF
  1479. }
  1480. b := dAtA[iNdEx]
  1481. iNdEx++
  1482. msglen |= int(b&0x7F) << shift
  1483. if b < 0x80 {
  1484. break
  1485. }
  1486. }
  1487. if msglen < 0 {
  1488. return ErrInvalidLengthRaftInternal
  1489. }
  1490. postIndex := iNdEx + msglen
  1491. if postIndex < 0 {
  1492. return ErrInvalidLengthRaftInternal
  1493. }
  1494. if postIndex > l {
  1495. return io.ErrUnexpectedEOF
  1496. }
  1497. if m.LeaseRevoke == nil {
  1498. m.LeaseRevoke = &LeaseRevokeRequest{}
  1499. }
  1500. if err := m.LeaseRevoke.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1501. return err
  1502. }
  1503. iNdEx = postIndex
  1504. case 10:
  1505. if wireType != 2 {
  1506. return fmt.Errorf("proto: wrong wireType = %d for field Alarm", wireType)
  1507. }
  1508. var msglen int
  1509. for shift := uint(0); ; shift += 7 {
  1510. if shift >= 64 {
  1511. return ErrIntOverflowRaftInternal
  1512. }
  1513. if iNdEx >= l {
  1514. return io.ErrUnexpectedEOF
  1515. }
  1516. b := dAtA[iNdEx]
  1517. iNdEx++
  1518. msglen |= int(b&0x7F) << shift
  1519. if b < 0x80 {
  1520. break
  1521. }
  1522. }
  1523. if msglen < 0 {
  1524. return ErrInvalidLengthRaftInternal
  1525. }
  1526. postIndex := iNdEx + msglen
  1527. if postIndex < 0 {
  1528. return ErrInvalidLengthRaftInternal
  1529. }
  1530. if postIndex > l {
  1531. return io.ErrUnexpectedEOF
  1532. }
  1533. if m.Alarm == nil {
  1534. m.Alarm = &AlarmRequest{}
  1535. }
  1536. if err := m.Alarm.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1537. return err
  1538. }
  1539. iNdEx = postIndex
  1540. case 11:
  1541. if wireType != 2 {
  1542. return fmt.Errorf("proto: wrong wireType = %d for field LeaseCheckpoint", wireType)
  1543. }
  1544. var msglen int
  1545. for shift := uint(0); ; shift += 7 {
  1546. if shift >= 64 {
  1547. return ErrIntOverflowRaftInternal
  1548. }
  1549. if iNdEx >= l {
  1550. return io.ErrUnexpectedEOF
  1551. }
  1552. b := dAtA[iNdEx]
  1553. iNdEx++
  1554. msglen |= int(b&0x7F) << shift
  1555. if b < 0x80 {
  1556. break
  1557. }
  1558. }
  1559. if msglen < 0 {
  1560. return ErrInvalidLengthRaftInternal
  1561. }
  1562. postIndex := iNdEx + msglen
  1563. if postIndex < 0 {
  1564. return ErrInvalidLengthRaftInternal
  1565. }
  1566. if postIndex > l {
  1567. return io.ErrUnexpectedEOF
  1568. }
  1569. if m.LeaseCheckpoint == nil {
  1570. m.LeaseCheckpoint = &LeaseCheckpointRequest{}
  1571. }
  1572. if err := m.LeaseCheckpoint.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1573. return err
  1574. }
  1575. iNdEx = postIndex
  1576. case 100:
  1577. if wireType != 2 {
  1578. return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
  1579. }
  1580. var msglen int
  1581. for shift := uint(0); ; shift += 7 {
  1582. if shift >= 64 {
  1583. return ErrIntOverflowRaftInternal
  1584. }
  1585. if iNdEx >= l {
  1586. return io.ErrUnexpectedEOF
  1587. }
  1588. b := dAtA[iNdEx]
  1589. iNdEx++
  1590. msglen |= int(b&0x7F) << shift
  1591. if b < 0x80 {
  1592. break
  1593. }
  1594. }
  1595. if msglen < 0 {
  1596. return ErrInvalidLengthRaftInternal
  1597. }
  1598. postIndex := iNdEx + msglen
  1599. if postIndex < 0 {
  1600. return ErrInvalidLengthRaftInternal
  1601. }
  1602. if postIndex > l {
  1603. return io.ErrUnexpectedEOF
  1604. }
  1605. if m.Header == nil {
  1606. m.Header = &RequestHeader{}
  1607. }
  1608. if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1609. return err
  1610. }
  1611. iNdEx = postIndex
  1612. case 1000:
  1613. if wireType != 2 {
  1614. return fmt.Errorf("proto: wrong wireType = %d for field AuthEnable", 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 < 0 {
  1636. return ErrInvalidLengthRaftInternal
  1637. }
  1638. if postIndex > l {
  1639. return io.ErrUnexpectedEOF
  1640. }
  1641. if m.AuthEnable == nil {
  1642. m.AuthEnable = &AuthEnableRequest{}
  1643. }
  1644. if err := m.AuthEnable.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1645. return err
  1646. }
  1647. iNdEx = postIndex
  1648. case 1011:
  1649. if wireType != 2 {
  1650. return fmt.Errorf("proto: wrong wireType = %d for field AuthDisable", wireType)
  1651. }
  1652. var msglen int
  1653. for shift := uint(0); ; shift += 7 {
  1654. if shift >= 64 {
  1655. return ErrIntOverflowRaftInternal
  1656. }
  1657. if iNdEx >= l {
  1658. return io.ErrUnexpectedEOF
  1659. }
  1660. b := dAtA[iNdEx]
  1661. iNdEx++
  1662. msglen |= int(b&0x7F) << shift
  1663. if b < 0x80 {
  1664. break
  1665. }
  1666. }
  1667. if msglen < 0 {
  1668. return ErrInvalidLengthRaftInternal
  1669. }
  1670. postIndex := iNdEx + msglen
  1671. if postIndex < 0 {
  1672. return ErrInvalidLengthRaftInternal
  1673. }
  1674. if postIndex > l {
  1675. return io.ErrUnexpectedEOF
  1676. }
  1677. if m.AuthDisable == nil {
  1678. m.AuthDisable = &AuthDisableRequest{}
  1679. }
  1680. if err := m.AuthDisable.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1681. return err
  1682. }
  1683. iNdEx = postIndex
  1684. case 1012:
  1685. if wireType != 2 {
  1686. return fmt.Errorf("proto: wrong wireType = %d for field Authenticate", wireType)
  1687. }
  1688. var msglen int
  1689. for shift := uint(0); ; shift += 7 {
  1690. if shift >= 64 {
  1691. return ErrIntOverflowRaftInternal
  1692. }
  1693. if iNdEx >= l {
  1694. return io.ErrUnexpectedEOF
  1695. }
  1696. b := dAtA[iNdEx]
  1697. iNdEx++
  1698. msglen |= int(b&0x7F) << shift
  1699. if b < 0x80 {
  1700. break
  1701. }
  1702. }
  1703. if msglen < 0 {
  1704. return ErrInvalidLengthRaftInternal
  1705. }
  1706. postIndex := iNdEx + msglen
  1707. if postIndex < 0 {
  1708. return ErrInvalidLengthRaftInternal
  1709. }
  1710. if postIndex > l {
  1711. return io.ErrUnexpectedEOF
  1712. }
  1713. if m.Authenticate == nil {
  1714. m.Authenticate = &InternalAuthenticateRequest{}
  1715. }
  1716. if err := m.Authenticate.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1717. return err
  1718. }
  1719. iNdEx = postIndex
  1720. case 1013:
  1721. if wireType != 2 {
  1722. return fmt.Errorf("proto: wrong wireType = %d for field AuthStatus", wireType)
  1723. }
  1724. var msglen int
  1725. for shift := uint(0); ; shift += 7 {
  1726. if shift >= 64 {
  1727. return ErrIntOverflowRaftInternal
  1728. }
  1729. if iNdEx >= l {
  1730. return io.ErrUnexpectedEOF
  1731. }
  1732. b := dAtA[iNdEx]
  1733. iNdEx++
  1734. msglen |= int(b&0x7F) << shift
  1735. if b < 0x80 {
  1736. break
  1737. }
  1738. }
  1739. if msglen < 0 {
  1740. return ErrInvalidLengthRaftInternal
  1741. }
  1742. postIndex := iNdEx + msglen
  1743. if postIndex < 0 {
  1744. return ErrInvalidLengthRaftInternal
  1745. }
  1746. if postIndex > l {
  1747. return io.ErrUnexpectedEOF
  1748. }
  1749. if m.AuthStatus == nil {
  1750. m.AuthStatus = &AuthStatusRequest{}
  1751. }
  1752. if err := m.AuthStatus.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1753. return err
  1754. }
  1755. iNdEx = postIndex
  1756. case 1100:
  1757. if wireType != 2 {
  1758. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserAdd", wireType)
  1759. }
  1760. var msglen int
  1761. for shift := uint(0); ; shift += 7 {
  1762. if shift >= 64 {
  1763. return ErrIntOverflowRaftInternal
  1764. }
  1765. if iNdEx >= l {
  1766. return io.ErrUnexpectedEOF
  1767. }
  1768. b := dAtA[iNdEx]
  1769. iNdEx++
  1770. msglen |= int(b&0x7F) << shift
  1771. if b < 0x80 {
  1772. break
  1773. }
  1774. }
  1775. if msglen < 0 {
  1776. return ErrInvalidLengthRaftInternal
  1777. }
  1778. postIndex := iNdEx + msglen
  1779. if postIndex < 0 {
  1780. return ErrInvalidLengthRaftInternal
  1781. }
  1782. if postIndex > l {
  1783. return io.ErrUnexpectedEOF
  1784. }
  1785. if m.AuthUserAdd == nil {
  1786. m.AuthUserAdd = &AuthUserAddRequest{}
  1787. }
  1788. if err := m.AuthUserAdd.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1789. return err
  1790. }
  1791. iNdEx = postIndex
  1792. case 1101:
  1793. if wireType != 2 {
  1794. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserDelete", wireType)
  1795. }
  1796. var msglen int
  1797. for shift := uint(0); ; shift += 7 {
  1798. if shift >= 64 {
  1799. return ErrIntOverflowRaftInternal
  1800. }
  1801. if iNdEx >= l {
  1802. return io.ErrUnexpectedEOF
  1803. }
  1804. b := dAtA[iNdEx]
  1805. iNdEx++
  1806. msglen |= int(b&0x7F) << shift
  1807. if b < 0x80 {
  1808. break
  1809. }
  1810. }
  1811. if msglen < 0 {
  1812. return ErrInvalidLengthRaftInternal
  1813. }
  1814. postIndex := iNdEx + msglen
  1815. if postIndex < 0 {
  1816. return ErrInvalidLengthRaftInternal
  1817. }
  1818. if postIndex > l {
  1819. return io.ErrUnexpectedEOF
  1820. }
  1821. if m.AuthUserDelete == nil {
  1822. m.AuthUserDelete = &AuthUserDeleteRequest{}
  1823. }
  1824. if err := m.AuthUserDelete.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1825. return err
  1826. }
  1827. iNdEx = postIndex
  1828. case 1102:
  1829. if wireType != 2 {
  1830. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGet", wireType)
  1831. }
  1832. var msglen int
  1833. for shift := uint(0); ; shift += 7 {
  1834. if shift >= 64 {
  1835. return ErrIntOverflowRaftInternal
  1836. }
  1837. if iNdEx >= l {
  1838. return io.ErrUnexpectedEOF
  1839. }
  1840. b := dAtA[iNdEx]
  1841. iNdEx++
  1842. msglen |= int(b&0x7F) << shift
  1843. if b < 0x80 {
  1844. break
  1845. }
  1846. }
  1847. if msglen < 0 {
  1848. return ErrInvalidLengthRaftInternal
  1849. }
  1850. postIndex := iNdEx + msglen
  1851. if postIndex < 0 {
  1852. return ErrInvalidLengthRaftInternal
  1853. }
  1854. if postIndex > l {
  1855. return io.ErrUnexpectedEOF
  1856. }
  1857. if m.AuthUserGet == nil {
  1858. m.AuthUserGet = &AuthUserGetRequest{}
  1859. }
  1860. if err := m.AuthUserGet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1861. return err
  1862. }
  1863. iNdEx = postIndex
  1864. case 1103:
  1865. if wireType != 2 {
  1866. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserChangePassword", wireType)
  1867. }
  1868. var msglen int
  1869. for shift := uint(0); ; shift += 7 {
  1870. if shift >= 64 {
  1871. return ErrIntOverflowRaftInternal
  1872. }
  1873. if iNdEx >= l {
  1874. return io.ErrUnexpectedEOF
  1875. }
  1876. b := dAtA[iNdEx]
  1877. iNdEx++
  1878. msglen |= int(b&0x7F) << shift
  1879. if b < 0x80 {
  1880. break
  1881. }
  1882. }
  1883. if msglen < 0 {
  1884. return ErrInvalidLengthRaftInternal
  1885. }
  1886. postIndex := iNdEx + msglen
  1887. if postIndex < 0 {
  1888. return ErrInvalidLengthRaftInternal
  1889. }
  1890. if postIndex > l {
  1891. return io.ErrUnexpectedEOF
  1892. }
  1893. if m.AuthUserChangePassword == nil {
  1894. m.AuthUserChangePassword = &AuthUserChangePasswordRequest{}
  1895. }
  1896. if err := m.AuthUserChangePassword.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1897. return err
  1898. }
  1899. iNdEx = postIndex
  1900. case 1104:
  1901. if wireType != 2 {
  1902. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserGrantRole", wireType)
  1903. }
  1904. var msglen int
  1905. for shift := uint(0); ; shift += 7 {
  1906. if shift >= 64 {
  1907. return ErrIntOverflowRaftInternal
  1908. }
  1909. if iNdEx >= l {
  1910. return io.ErrUnexpectedEOF
  1911. }
  1912. b := dAtA[iNdEx]
  1913. iNdEx++
  1914. msglen |= int(b&0x7F) << shift
  1915. if b < 0x80 {
  1916. break
  1917. }
  1918. }
  1919. if msglen < 0 {
  1920. return ErrInvalidLengthRaftInternal
  1921. }
  1922. postIndex := iNdEx + msglen
  1923. if postIndex < 0 {
  1924. return ErrInvalidLengthRaftInternal
  1925. }
  1926. if postIndex > l {
  1927. return io.ErrUnexpectedEOF
  1928. }
  1929. if m.AuthUserGrantRole == nil {
  1930. m.AuthUserGrantRole = &AuthUserGrantRoleRequest{}
  1931. }
  1932. if err := m.AuthUserGrantRole.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1933. return err
  1934. }
  1935. iNdEx = postIndex
  1936. case 1105:
  1937. if wireType != 2 {
  1938. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserRevokeRole", wireType)
  1939. }
  1940. var msglen int
  1941. for shift := uint(0); ; shift += 7 {
  1942. if shift >= 64 {
  1943. return ErrIntOverflowRaftInternal
  1944. }
  1945. if iNdEx >= l {
  1946. return io.ErrUnexpectedEOF
  1947. }
  1948. b := dAtA[iNdEx]
  1949. iNdEx++
  1950. msglen |= int(b&0x7F) << shift
  1951. if b < 0x80 {
  1952. break
  1953. }
  1954. }
  1955. if msglen < 0 {
  1956. return ErrInvalidLengthRaftInternal
  1957. }
  1958. postIndex := iNdEx + msglen
  1959. if postIndex < 0 {
  1960. return ErrInvalidLengthRaftInternal
  1961. }
  1962. if postIndex > l {
  1963. return io.ErrUnexpectedEOF
  1964. }
  1965. if m.AuthUserRevokeRole == nil {
  1966. m.AuthUserRevokeRole = &AuthUserRevokeRoleRequest{}
  1967. }
  1968. if err := m.AuthUserRevokeRole.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1969. return err
  1970. }
  1971. iNdEx = postIndex
  1972. case 1106:
  1973. if wireType != 2 {
  1974. return fmt.Errorf("proto: wrong wireType = %d for field AuthUserList", wireType)
  1975. }
  1976. var msglen int
  1977. for shift := uint(0); ; shift += 7 {
  1978. if shift >= 64 {
  1979. return ErrIntOverflowRaftInternal
  1980. }
  1981. if iNdEx >= l {
  1982. return io.ErrUnexpectedEOF
  1983. }
  1984. b := dAtA[iNdEx]
  1985. iNdEx++
  1986. msglen |= int(b&0x7F) << shift
  1987. if b < 0x80 {
  1988. break
  1989. }
  1990. }
  1991. if msglen < 0 {
  1992. return ErrInvalidLengthRaftInternal
  1993. }
  1994. postIndex := iNdEx + msglen
  1995. if postIndex < 0 {
  1996. return ErrInvalidLengthRaftInternal
  1997. }
  1998. if postIndex > l {
  1999. return io.ErrUnexpectedEOF
  2000. }
  2001. if m.AuthUserList == nil {
  2002. m.AuthUserList = &AuthUserListRequest{}
  2003. }
  2004. if err := m.AuthUserList.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2005. return err
  2006. }
  2007. iNdEx = postIndex
  2008. case 1107:
  2009. if wireType != 2 {
  2010. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleList", wireType)
  2011. }
  2012. var msglen int
  2013. for shift := uint(0); ; shift += 7 {
  2014. if shift >= 64 {
  2015. return ErrIntOverflowRaftInternal
  2016. }
  2017. if iNdEx >= l {
  2018. return io.ErrUnexpectedEOF
  2019. }
  2020. b := dAtA[iNdEx]
  2021. iNdEx++
  2022. msglen |= int(b&0x7F) << shift
  2023. if b < 0x80 {
  2024. break
  2025. }
  2026. }
  2027. if msglen < 0 {
  2028. return ErrInvalidLengthRaftInternal
  2029. }
  2030. postIndex := iNdEx + msglen
  2031. if postIndex < 0 {
  2032. return ErrInvalidLengthRaftInternal
  2033. }
  2034. if postIndex > l {
  2035. return io.ErrUnexpectedEOF
  2036. }
  2037. if m.AuthRoleList == nil {
  2038. m.AuthRoleList = &AuthRoleListRequest{}
  2039. }
  2040. if err := m.AuthRoleList.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2041. return err
  2042. }
  2043. iNdEx = postIndex
  2044. case 1200:
  2045. if wireType != 2 {
  2046. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleAdd", wireType)
  2047. }
  2048. var msglen int
  2049. for shift := uint(0); ; shift += 7 {
  2050. if shift >= 64 {
  2051. return ErrIntOverflowRaftInternal
  2052. }
  2053. if iNdEx >= l {
  2054. return io.ErrUnexpectedEOF
  2055. }
  2056. b := dAtA[iNdEx]
  2057. iNdEx++
  2058. msglen |= int(b&0x7F) << shift
  2059. if b < 0x80 {
  2060. break
  2061. }
  2062. }
  2063. if msglen < 0 {
  2064. return ErrInvalidLengthRaftInternal
  2065. }
  2066. postIndex := iNdEx + msglen
  2067. if postIndex < 0 {
  2068. return ErrInvalidLengthRaftInternal
  2069. }
  2070. if postIndex > l {
  2071. return io.ErrUnexpectedEOF
  2072. }
  2073. if m.AuthRoleAdd == nil {
  2074. m.AuthRoleAdd = &AuthRoleAddRequest{}
  2075. }
  2076. if err := m.AuthRoleAdd.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2077. return err
  2078. }
  2079. iNdEx = postIndex
  2080. case 1201:
  2081. if wireType != 2 {
  2082. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleDelete", wireType)
  2083. }
  2084. var msglen int
  2085. for shift := uint(0); ; shift += 7 {
  2086. if shift >= 64 {
  2087. return ErrIntOverflowRaftInternal
  2088. }
  2089. if iNdEx >= l {
  2090. return io.ErrUnexpectedEOF
  2091. }
  2092. b := dAtA[iNdEx]
  2093. iNdEx++
  2094. msglen |= int(b&0x7F) << shift
  2095. if b < 0x80 {
  2096. break
  2097. }
  2098. }
  2099. if msglen < 0 {
  2100. return ErrInvalidLengthRaftInternal
  2101. }
  2102. postIndex := iNdEx + msglen
  2103. if postIndex < 0 {
  2104. return ErrInvalidLengthRaftInternal
  2105. }
  2106. if postIndex > l {
  2107. return io.ErrUnexpectedEOF
  2108. }
  2109. if m.AuthRoleDelete == nil {
  2110. m.AuthRoleDelete = &AuthRoleDeleteRequest{}
  2111. }
  2112. if err := m.AuthRoleDelete.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2113. return err
  2114. }
  2115. iNdEx = postIndex
  2116. case 1202:
  2117. if wireType != 2 {
  2118. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleGet", wireType)
  2119. }
  2120. var msglen int
  2121. for shift := uint(0); ; shift += 7 {
  2122. if shift >= 64 {
  2123. return ErrIntOverflowRaftInternal
  2124. }
  2125. if iNdEx >= l {
  2126. return io.ErrUnexpectedEOF
  2127. }
  2128. b := dAtA[iNdEx]
  2129. iNdEx++
  2130. msglen |= int(b&0x7F) << shift
  2131. if b < 0x80 {
  2132. break
  2133. }
  2134. }
  2135. if msglen < 0 {
  2136. return ErrInvalidLengthRaftInternal
  2137. }
  2138. postIndex := iNdEx + msglen
  2139. if postIndex < 0 {
  2140. return ErrInvalidLengthRaftInternal
  2141. }
  2142. if postIndex > l {
  2143. return io.ErrUnexpectedEOF
  2144. }
  2145. if m.AuthRoleGet == nil {
  2146. m.AuthRoleGet = &AuthRoleGetRequest{}
  2147. }
  2148. if err := m.AuthRoleGet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2149. return err
  2150. }
  2151. iNdEx = postIndex
  2152. case 1203:
  2153. if wireType != 2 {
  2154. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleGrantPermission", wireType)
  2155. }
  2156. var msglen int
  2157. for shift := uint(0); ; shift += 7 {
  2158. if shift >= 64 {
  2159. return ErrIntOverflowRaftInternal
  2160. }
  2161. if iNdEx >= l {
  2162. return io.ErrUnexpectedEOF
  2163. }
  2164. b := dAtA[iNdEx]
  2165. iNdEx++
  2166. msglen |= int(b&0x7F) << shift
  2167. if b < 0x80 {
  2168. break
  2169. }
  2170. }
  2171. if msglen < 0 {
  2172. return ErrInvalidLengthRaftInternal
  2173. }
  2174. postIndex := iNdEx + msglen
  2175. if postIndex < 0 {
  2176. return ErrInvalidLengthRaftInternal
  2177. }
  2178. if postIndex > l {
  2179. return io.ErrUnexpectedEOF
  2180. }
  2181. if m.AuthRoleGrantPermission == nil {
  2182. m.AuthRoleGrantPermission = &AuthRoleGrantPermissionRequest{}
  2183. }
  2184. if err := m.AuthRoleGrantPermission.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2185. return err
  2186. }
  2187. iNdEx = postIndex
  2188. case 1204:
  2189. if wireType != 2 {
  2190. return fmt.Errorf("proto: wrong wireType = %d for field AuthRoleRevokePermission", wireType)
  2191. }
  2192. var msglen int
  2193. for shift := uint(0); ; shift += 7 {
  2194. if shift >= 64 {
  2195. return ErrIntOverflowRaftInternal
  2196. }
  2197. if iNdEx >= l {
  2198. return io.ErrUnexpectedEOF
  2199. }
  2200. b := dAtA[iNdEx]
  2201. iNdEx++
  2202. msglen |= int(b&0x7F) << shift
  2203. if b < 0x80 {
  2204. break
  2205. }
  2206. }
  2207. if msglen < 0 {
  2208. return ErrInvalidLengthRaftInternal
  2209. }
  2210. postIndex := iNdEx + msglen
  2211. if postIndex < 0 {
  2212. return ErrInvalidLengthRaftInternal
  2213. }
  2214. if postIndex > l {
  2215. return io.ErrUnexpectedEOF
  2216. }
  2217. if m.AuthRoleRevokePermission == nil {
  2218. m.AuthRoleRevokePermission = &AuthRoleRevokePermissionRequest{}
  2219. }
  2220. if err := m.AuthRoleRevokePermission.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2221. return err
  2222. }
  2223. iNdEx = postIndex
  2224. case 1300:
  2225. if wireType != 2 {
  2226. return fmt.Errorf("proto: wrong wireType = %d for field ClusterVersionSet", wireType)
  2227. }
  2228. var msglen int
  2229. for shift := uint(0); ; shift += 7 {
  2230. if shift >= 64 {
  2231. return ErrIntOverflowRaftInternal
  2232. }
  2233. if iNdEx >= l {
  2234. return io.ErrUnexpectedEOF
  2235. }
  2236. b := dAtA[iNdEx]
  2237. iNdEx++
  2238. msglen |= int(b&0x7F) << shift
  2239. if b < 0x80 {
  2240. break
  2241. }
  2242. }
  2243. if msglen < 0 {
  2244. return ErrInvalidLengthRaftInternal
  2245. }
  2246. postIndex := iNdEx + msglen
  2247. if postIndex < 0 {
  2248. return ErrInvalidLengthRaftInternal
  2249. }
  2250. if postIndex > l {
  2251. return io.ErrUnexpectedEOF
  2252. }
  2253. if m.ClusterVersionSet == nil {
  2254. m.ClusterVersionSet = &membershippb.ClusterVersionSetRequest{}
  2255. }
  2256. if err := m.ClusterVersionSet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2257. return err
  2258. }
  2259. iNdEx = postIndex
  2260. case 1301:
  2261. if wireType != 2 {
  2262. return fmt.Errorf("proto: wrong wireType = %d for field ClusterMemberAttrSet", wireType)
  2263. }
  2264. var msglen int
  2265. for shift := uint(0); ; shift += 7 {
  2266. if shift >= 64 {
  2267. return ErrIntOverflowRaftInternal
  2268. }
  2269. if iNdEx >= l {
  2270. return io.ErrUnexpectedEOF
  2271. }
  2272. b := dAtA[iNdEx]
  2273. iNdEx++
  2274. msglen |= int(b&0x7F) << shift
  2275. if b < 0x80 {
  2276. break
  2277. }
  2278. }
  2279. if msglen < 0 {
  2280. return ErrInvalidLengthRaftInternal
  2281. }
  2282. postIndex := iNdEx + msglen
  2283. if postIndex < 0 {
  2284. return ErrInvalidLengthRaftInternal
  2285. }
  2286. if postIndex > l {
  2287. return io.ErrUnexpectedEOF
  2288. }
  2289. if m.ClusterMemberAttrSet == nil {
  2290. m.ClusterMemberAttrSet = &membershippb.ClusterMemberAttrSetRequest{}
  2291. }
  2292. if err := m.ClusterMemberAttrSet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2293. return err
  2294. }
  2295. iNdEx = postIndex
  2296. case 1302:
  2297. if wireType != 2 {
  2298. return fmt.Errorf("proto: wrong wireType = %d for field DowngradeInfoSet", wireType)
  2299. }
  2300. var msglen int
  2301. for shift := uint(0); ; shift += 7 {
  2302. if shift >= 64 {
  2303. return ErrIntOverflowRaftInternal
  2304. }
  2305. if iNdEx >= l {
  2306. return io.ErrUnexpectedEOF
  2307. }
  2308. b := dAtA[iNdEx]
  2309. iNdEx++
  2310. msglen |= int(b&0x7F) << shift
  2311. if b < 0x80 {
  2312. break
  2313. }
  2314. }
  2315. if msglen < 0 {
  2316. return ErrInvalidLengthRaftInternal
  2317. }
  2318. postIndex := iNdEx + msglen
  2319. if postIndex < 0 {
  2320. return ErrInvalidLengthRaftInternal
  2321. }
  2322. if postIndex > l {
  2323. return io.ErrUnexpectedEOF
  2324. }
  2325. if m.DowngradeInfoSet == nil {
  2326. m.DowngradeInfoSet = &membershippb.DowngradeInfoSetRequest{}
  2327. }
  2328. if err := m.DowngradeInfoSet.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  2329. return err
  2330. }
  2331. iNdEx = postIndex
  2332. default:
  2333. iNdEx = preIndex
  2334. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  2335. if err != nil {
  2336. return err
  2337. }
  2338. if (skippy < 0) || (iNdEx+skippy) < 0 {
  2339. return ErrInvalidLengthRaftInternal
  2340. }
  2341. if (iNdEx + skippy) > l {
  2342. return io.ErrUnexpectedEOF
  2343. }
  2344. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  2345. iNdEx += skippy
  2346. }
  2347. }
  2348. if iNdEx > l {
  2349. return io.ErrUnexpectedEOF
  2350. }
  2351. return nil
  2352. }
  2353. func (m *EmptyResponse) Unmarshal(dAtA []byte) error {
  2354. l := len(dAtA)
  2355. iNdEx := 0
  2356. for iNdEx < l {
  2357. preIndex := iNdEx
  2358. var wire uint64
  2359. for shift := uint(0); ; shift += 7 {
  2360. if shift >= 64 {
  2361. return ErrIntOverflowRaftInternal
  2362. }
  2363. if iNdEx >= l {
  2364. return io.ErrUnexpectedEOF
  2365. }
  2366. b := dAtA[iNdEx]
  2367. iNdEx++
  2368. wire |= uint64(b&0x7F) << shift
  2369. if b < 0x80 {
  2370. break
  2371. }
  2372. }
  2373. fieldNum := int32(wire >> 3)
  2374. wireType := int(wire & 0x7)
  2375. if wireType == 4 {
  2376. return fmt.Errorf("proto: EmptyResponse: wiretype end group for non-group")
  2377. }
  2378. if fieldNum <= 0 {
  2379. return fmt.Errorf("proto: EmptyResponse: illegal tag %d (wire type %d)", fieldNum, wire)
  2380. }
  2381. switch fieldNum {
  2382. default:
  2383. iNdEx = preIndex
  2384. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  2385. if err != nil {
  2386. return err
  2387. }
  2388. if (skippy < 0) || (iNdEx+skippy) < 0 {
  2389. return ErrInvalidLengthRaftInternal
  2390. }
  2391. if (iNdEx + skippy) > l {
  2392. return io.ErrUnexpectedEOF
  2393. }
  2394. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  2395. iNdEx += skippy
  2396. }
  2397. }
  2398. if iNdEx > l {
  2399. return io.ErrUnexpectedEOF
  2400. }
  2401. return nil
  2402. }
  2403. func (m *InternalAuthenticateRequest) Unmarshal(dAtA []byte) error {
  2404. l := len(dAtA)
  2405. iNdEx := 0
  2406. for iNdEx < l {
  2407. preIndex := iNdEx
  2408. var wire uint64
  2409. for shift := uint(0); ; shift += 7 {
  2410. if shift >= 64 {
  2411. return ErrIntOverflowRaftInternal
  2412. }
  2413. if iNdEx >= l {
  2414. return io.ErrUnexpectedEOF
  2415. }
  2416. b := dAtA[iNdEx]
  2417. iNdEx++
  2418. wire |= uint64(b&0x7F) << shift
  2419. if b < 0x80 {
  2420. break
  2421. }
  2422. }
  2423. fieldNum := int32(wire >> 3)
  2424. wireType := int(wire & 0x7)
  2425. if wireType == 4 {
  2426. return fmt.Errorf("proto: InternalAuthenticateRequest: wiretype end group for non-group")
  2427. }
  2428. if fieldNum <= 0 {
  2429. return fmt.Errorf("proto: InternalAuthenticateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  2430. }
  2431. switch fieldNum {
  2432. case 1:
  2433. if wireType != 2 {
  2434. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  2435. }
  2436. var stringLen uint64
  2437. for shift := uint(0); ; shift += 7 {
  2438. if shift >= 64 {
  2439. return ErrIntOverflowRaftInternal
  2440. }
  2441. if iNdEx >= l {
  2442. return io.ErrUnexpectedEOF
  2443. }
  2444. b := dAtA[iNdEx]
  2445. iNdEx++
  2446. stringLen |= uint64(b&0x7F) << shift
  2447. if b < 0x80 {
  2448. break
  2449. }
  2450. }
  2451. intStringLen := int(stringLen)
  2452. if intStringLen < 0 {
  2453. return ErrInvalidLengthRaftInternal
  2454. }
  2455. postIndex := iNdEx + intStringLen
  2456. if postIndex < 0 {
  2457. return ErrInvalidLengthRaftInternal
  2458. }
  2459. if postIndex > l {
  2460. return io.ErrUnexpectedEOF
  2461. }
  2462. m.Name = string(dAtA[iNdEx:postIndex])
  2463. iNdEx = postIndex
  2464. case 2:
  2465. if wireType != 2 {
  2466. return fmt.Errorf("proto: wrong wireType = %d for field Password", wireType)
  2467. }
  2468. var stringLen uint64
  2469. for shift := uint(0); ; shift += 7 {
  2470. if shift >= 64 {
  2471. return ErrIntOverflowRaftInternal
  2472. }
  2473. if iNdEx >= l {
  2474. return io.ErrUnexpectedEOF
  2475. }
  2476. b := dAtA[iNdEx]
  2477. iNdEx++
  2478. stringLen |= uint64(b&0x7F) << shift
  2479. if b < 0x80 {
  2480. break
  2481. }
  2482. }
  2483. intStringLen := int(stringLen)
  2484. if intStringLen < 0 {
  2485. return ErrInvalidLengthRaftInternal
  2486. }
  2487. postIndex := iNdEx + intStringLen
  2488. if postIndex < 0 {
  2489. return ErrInvalidLengthRaftInternal
  2490. }
  2491. if postIndex > l {
  2492. return io.ErrUnexpectedEOF
  2493. }
  2494. m.Password = string(dAtA[iNdEx:postIndex])
  2495. iNdEx = postIndex
  2496. case 3:
  2497. if wireType != 2 {
  2498. return fmt.Errorf("proto: wrong wireType = %d for field SimpleToken", wireType)
  2499. }
  2500. var stringLen uint64
  2501. for shift := uint(0); ; shift += 7 {
  2502. if shift >= 64 {
  2503. return ErrIntOverflowRaftInternal
  2504. }
  2505. if iNdEx >= l {
  2506. return io.ErrUnexpectedEOF
  2507. }
  2508. b := dAtA[iNdEx]
  2509. iNdEx++
  2510. stringLen |= uint64(b&0x7F) << shift
  2511. if b < 0x80 {
  2512. break
  2513. }
  2514. }
  2515. intStringLen := int(stringLen)
  2516. if intStringLen < 0 {
  2517. return ErrInvalidLengthRaftInternal
  2518. }
  2519. postIndex := iNdEx + intStringLen
  2520. if postIndex < 0 {
  2521. return ErrInvalidLengthRaftInternal
  2522. }
  2523. if postIndex > l {
  2524. return io.ErrUnexpectedEOF
  2525. }
  2526. m.SimpleToken = string(dAtA[iNdEx:postIndex])
  2527. iNdEx = postIndex
  2528. default:
  2529. iNdEx = preIndex
  2530. skippy, err := skipRaftInternal(dAtA[iNdEx:])
  2531. if err != nil {
  2532. return err
  2533. }
  2534. if (skippy < 0) || (iNdEx+skippy) < 0 {
  2535. return ErrInvalidLengthRaftInternal
  2536. }
  2537. if (iNdEx + skippy) > l {
  2538. return io.ErrUnexpectedEOF
  2539. }
  2540. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  2541. iNdEx += skippy
  2542. }
  2543. }
  2544. if iNdEx > l {
  2545. return io.ErrUnexpectedEOF
  2546. }
  2547. return nil
  2548. }
  2549. func skipRaftInternal(dAtA []byte) (n int, err error) {
  2550. l := len(dAtA)
  2551. iNdEx := 0
  2552. depth := 0
  2553. for iNdEx < l {
  2554. var wire uint64
  2555. for shift := uint(0); ; shift += 7 {
  2556. if shift >= 64 {
  2557. return 0, ErrIntOverflowRaftInternal
  2558. }
  2559. if iNdEx >= l {
  2560. return 0, io.ErrUnexpectedEOF
  2561. }
  2562. b := dAtA[iNdEx]
  2563. iNdEx++
  2564. wire |= (uint64(b) & 0x7F) << shift
  2565. if b < 0x80 {
  2566. break
  2567. }
  2568. }
  2569. wireType := int(wire & 0x7)
  2570. switch wireType {
  2571. case 0:
  2572. for shift := uint(0); ; shift += 7 {
  2573. if shift >= 64 {
  2574. return 0, ErrIntOverflowRaftInternal
  2575. }
  2576. if iNdEx >= l {
  2577. return 0, io.ErrUnexpectedEOF
  2578. }
  2579. iNdEx++
  2580. if dAtA[iNdEx-1] < 0x80 {
  2581. break
  2582. }
  2583. }
  2584. case 1:
  2585. iNdEx += 8
  2586. case 2:
  2587. var length int
  2588. for shift := uint(0); ; shift += 7 {
  2589. if shift >= 64 {
  2590. return 0, ErrIntOverflowRaftInternal
  2591. }
  2592. if iNdEx >= l {
  2593. return 0, io.ErrUnexpectedEOF
  2594. }
  2595. b := dAtA[iNdEx]
  2596. iNdEx++
  2597. length |= (int(b) & 0x7F) << shift
  2598. if b < 0x80 {
  2599. break
  2600. }
  2601. }
  2602. if length < 0 {
  2603. return 0, ErrInvalidLengthRaftInternal
  2604. }
  2605. iNdEx += length
  2606. case 3:
  2607. depth++
  2608. case 4:
  2609. if depth == 0 {
  2610. return 0, ErrUnexpectedEndOfGroupRaftInternal
  2611. }
  2612. depth--
  2613. case 5:
  2614. iNdEx += 4
  2615. default:
  2616. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  2617. }
  2618. if iNdEx < 0 {
  2619. return 0, ErrInvalidLengthRaftInternal
  2620. }
  2621. if depth == 0 {
  2622. return iNdEx, nil
  2623. }
  2624. }
  2625. return 0, io.ErrUnexpectedEOF
  2626. }
  2627. var (
  2628. ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling")
  2629. ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow")
  2630. ErrUnexpectedEndOfGroupRaftInternal = fmt.Errorf("proto: unexpected end of group")
  2631. )