raft_internal.pb.go 37 KB

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