snapshot.pb.go 33 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354
  1. // Code generated by protoc-gen-gogo.
  2. // source: snapshot.proto
  3. // DO NOT EDIT!
  4. package api
  5. import proto "github.com/gogo/protobuf/proto"
  6. import fmt "fmt"
  7. import math "math"
  8. // skipping weak import gogoproto "github.com/gogo/protobuf/gogoproto"
  9. import github_com_docker_swarmkit_api_deepcopy "github.com/docker/swarmkit/api/deepcopy"
  10. import strings "strings"
  11. import reflect "reflect"
  12. import io "io"
  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. type Snapshot_Version int32
  18. const (
  19. // V0 is the initial version of the StoreSnapshot message.
  20. Snapshot_V0 Snapshot_Version = 0
  21. )
  22. var Snapshot_Version_name = map[int32]string{
  23. 0: "V0",
  24. }
  25. var Snapshot_Version_value = map[string]int32{
  26. "V0": 0,
  27. }
  28. func (x Snapshot_Version) String() string {
  29. return proto.EnumName(Snapshot_Version_name, int32(x))
  30. }
  31. func (Snapshot_Version) EnumDescriptor() ([]byte, []int) { return fileDescriptorSnapshot, []int{2, 0} }
  32. // StoreSnapshot is used to store snapshots of the store.
  33. type StoreSnapshot struct {
  34. Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
  35. Services []*Service `protobuf:"bytes,2,rep,name=services" json:"services,omitempty"`
  36. Networks []*Network `protobuf:"bytes,3,rep,name=networks" json:"networks,omitempty"`
  37. Tasks []*Task `protobuf:"bytes,4,rep,name=tasks" json:"tasks,omitempty"`
  38. Clusters []*Cluster `protobuf:"bytes,5,rep,name=clusters" json:"clusters,omitempty"`
  39. Secrets []*Secret `protobuf:"bytes,6,rep,name=secrets" json:"secrets,omitempty"`
  40. Resources []*Resource `protobuf:"bytes,7,rep,name=resources" json:"resources,omitempty"`
  41. Extensions []*Extension `protobuf:"bytes,8,rep,name=extensions" json:"extensions,omitempty"`
  42. Configs []*Config `protobuf:"bytes,9,rep,name=configs" json:"configs,omitempty"`
  43. }
  44. func (m *StoreSnapshot) Reset() { *m = StoreSnapshot{} }
  45. func (*StoreSnapshot) ProtoMessage() {}
  46. func (*StoreSnapshot) Descriptor() ([]byte, []int) { return fileDescriptorSnapshot, []int{0} }
  47. // ClusterSnapshot stores cluster membership information in snapshots.
  48. type ClusterSnapshot struct {
  49. Members []*RaftMember `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
  50. Removed []uint64 `protobuf:"varint,2,rep,packed,name=removed" json:"removed,omitempty"`
  51. }
  52. func (m *ClusterSnapshot) Reset() { *m = ClusterSnapshot{} }
  53. func (*ClusterSnapshot) ProtoMessage() {}
  54. func (*ClusterSnapshot) Descriptor() ([]byte, []int) { return fileDescriptorSnapshot, []int{1} }
  55. type Snapshot struct {
  56. Version Snapshot_Version `protobuf:"varint,1,opt,name=version,proto3,enum=docker.swarmkit.v1.Snapshot_Version" json:"version,omitempty"`
  57. Membership ClusterSnapshot `protobuf:"bytes,2,opt,name=membership" json:"membership"`
  58. Store StoreSnapshot `protobuf:"bytes,3,opt,name=store" json:"store"`
  59. }
  60. func (m *Snapshot) Reset() { *m = Snapshot{} }
  61. func (*Snapshot) ProtoMessage() {}
  62. func (*Snapshot) Descriptor() ([]byte, []int) { return fileDescriptorSnapshot, []int{2} }
  63. func init() {
  64. proto.RegisterType((*StoreSnapshot)(nil), "docker.swarmkit.v1.StoreSnapshot")
  65. proto.RegisterType((*ClusterSnapshot)(nil), "docker.swarmkit.v1.ClusterSnapshot")
  66. proto.RegisterType((*Snapshot)(nil), "docker.swarmkit.v1.Snapshot")
  67. proto.RegisterEnum("docker.swarmkit.v1.Snapshot_Version", Snapshot_Version_name, Snapshot_Version_value)
  68. }
  69. func (m *StoreSnapshot) Copy() *StoreSnapshot {
  70. if m == nil {
  71. return nil
  72. }
  73. o := &StoreSnapshot{}
  74. o.CopyFrom(m)
  75. return o
  76. }
  77. func (m *StoreSnapshot) CopyFrom(src interface{}) {
  78. o := src.(*StoreSnapshot)
  79. *m = *o
  80. if o.Nodes != nil {
  81. m.Nodes = make([]*Node, len(o.Nodes))
  82. for i := range m.Nodes {
  83. m.Nodes[i] = &Node{}
  84. github_com_docker_swarmkit_api_deepcopy.Copy(m.Nodes[i], o.Nodes[i])
  85. }
  86. }
  87. if o.Services != nil {
  88. m.Services = make([]*Service, len(o.Services))
  89. for i := range m.Services {
  90. m.Services[i] = &Service{}
  91. github_com_docker_swarmkit_api_deepcopy.Copy(m.Services[i], o.Services[i])
  92. }
  93. }
  94. if o.Networks != nil {
  95. m.Networks = make([]*Network, len(o.Networks))
  96. for i := range m.Networks {
  97. m.Networks[i] = &Network{}
  98. github_com_docker_swarmkit_api_deepcopy.Copy(m.Networks[i], o.Networks[i])
  99. }
  100. }
  101. if o.Tasks != nil {
  102. m.Tasks = make([]*Task, len(o.Tasks))
  103. for i := range m.Tasks {
  104. m.Tasks[i] = &Task{}
  105. github_com_docker_swarmkit_api_deepcopy.Copy(m.Tasks[i], o.Tasks[i])
  106. }
  107. }
  108. if o.Clusters != nil {
  109. m.Clusters = make([]*Cluster, len(o.Clusters))
  110. for i := range m.Clusters {
  111. m.Clusters[i] = &Cluster{}
  112. github_com_docker_swarmkit_api_deepcopy.Copy(m.Clusters[i], o.Clusters[i])
  113. }
  114. }
  115. if o.Secrets != nil {
  116. m.Secrets = make([]*Secret, len(o.Secrets))
  117. for i := range m.Secrets {
  118. m.Secrets[i] = &Secret{}
  119. github_com_docker_swarmkit_api_deepcopy.Copy(m.Secrets[i], o.Secrets[i])
  120. }
  121. }
  122. if o.Resources != nil {
  123. m.Resources = make([]*Resource, len(o.Resources))
  124. for i := range m.Resources {
  125. m.Resources[i] = &Resource{}
  126. github_com_docker_swarmkit_api_deepcopy.Copy(m.Resources[i], o.Resources[i])
  127. }
  128. }
  129. if o.Extensions != nil {
  130. m.Extensions = make([]*Extension, len(o.Extensions))
  131. for i := range m.Extensions {
  132. m.Extensions[i] = &Extension{}
  133. github_com_docker_swarmkit_api_deepcopy.Copy(m.Extensions[i], o.Extensions[i])
  134. }
  135. }
  136. if o.Configs != nil {
  137. m.Configs = make([]*Config, len(o.Configs))
  138. for i := range m.Configs {
  139. m.Configs[i] = &Config{}
  140. github_com_docker_swarmkit_api_deepcopy.Copy(m.Configs[i], o.Configs[i])
  141. }
  142. }
  143. }
  144. func (m *ClusterSnapshot) Copy() *ClusterSnapshot {
  145. if m == nil {
  146. return nil
  147. }
  148. o := &ClusterSnapshot{}
  149. o.CopyFrom(m)
  150. return o
  151. }
  152. func (m *ClusterSnapshot) CopyFrom(src interface{}) {
  153. o := src.(*ClusterSnapshot)
  154. *m = *o
  155. if o.Members != nil {
  156. m.Members = make([]*RaftMember, len(o.Members))
  157. for i := range m.Members {
  158. m.Members[i] = &RaftMember{}
  159. github_com_docker_swarmkit_api_deepcopy.Copy(m.Members[i], o.Members[i])
  160. }
  161. }
  162. if o.Removed != nil {
  163. m.Removed = make([]uint64, len(o.Removed))
  164. copy(m.Removed, o.Removed)
  165. }
  166. }
  167. func (m *Snapshot) Copy() *Snapshot {
  168. if m == nil {
  169. return nil
  170. }
  171. o := &Snapshot{}
  172. o.CopyFrom(m)
  173. return o
  174. }
  175. func (m *Snapshot) CopyFrom(src interface{}) {
  176. o := src.(*Snapshot)
  177. *m = *o
  178. github_com_docker_swarmkit_api_deepcopy.Copy(&m.Membership, &o.Membership)
  179. github_com_docker_swarmkit_api_deepcopy.Copy(&m.Store, &o.Store)
  180. }
  181. func (m *StoreSnapshot) Marshal() (dAtA []byte, err error) {
  182. size := m.Size()
  183. dAtA = make([]byte, size)
  184. n, err := m.MarshalTo(dAtA)
  185. if err != nil {
  186. return nil, err
  187. }
  188. return dAtA[:n], nil
  189. }
  190. func (m *StoreSnapshot) MarshalTo(dAtA []byte) (int, error) {
  191. var i int
  192. _ = i
  193. var l int
  194. _ = l
  195. if len(m.Nodes) > 0 {
  196. for _, msg := range m.Nodes {
  197. dAtA[i] = 0xa
  198. i++
  199. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  200. n, err := msg.MarshalTo(dAtA[i:])
  201. if err != nil {
  202. return 0, err
  203. }
  204. i += n
  205. }
  206. }
  207. if len(m.Services) > 0 {
  208. for _, msg := range m.Services {
  209. dAtA[i] = 0x12
  210. i++
  211. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  212. n, err := msg.MarshalTo(dAtA[i:])
  213. if err != nil {
  214. return 0, err
  215. }
  216. i += n
  217. }
  218. }
  219. if len(m.Networks) > 0 {
  220. for _, msg := range m.Networks {
  221. dAtA[i] = 0x1a
  222. i++
  223. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  224. n, err := msg.MarshalTo(dAtA[i:])
  225. if err != nil {
  226. return 0, err
  227. }
  228. i += n
  229. }
  230. }
  231. if len(m.Tasks) > 0 {
  232. for _, msg := range m.Tasks {
  233. dAtA[i] = 0x22
  234. i++
  235. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  236. n, err := msg.MarshalTo(dAtA[i:])
  237. if err != nil {
  238. return 0, err
  239. }
  240. i += n
  241. }
  242. }
  243. if len(m.Clusters) > 0 {
  244. for _, msg := range m.Clusters {
  245. dAtA[i] = 0x2a
  246. i++
  247. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  248. n, err := msg.MarshalTo(dAtA[i:])
  249. if err != nil {
  250. return 0, err
  251. }
  252. i += n
  253. }
  254. }
  255. if len(m.Secrets) > 0 {
  256. for _, msg := range m.Secrets {
  257. dAtA[i] = 0x32
  258. i++
  259. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  260. n, err := msg.MarshalTo(dAtA[i:])
  261. if err != nil {
  262. return 0, err
  263. }
  264. i += n
  265. }
  266. }
  267. if len(m.Resources) > 0 {
  268. for _, msg := range m.Resources {
  269. dAtA[i] = 0x3a
  270. i++
  271. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  272. n, err := msg.MarshalTo(dAtA[i:])
  273. if err != nil {
  274. return 0, err
  275. }
  276. i += n
  277. }
  278. }
  279. if len(m.Extensions) > 0 {
  280. for _, msg := range m.Extensions {
  281. dAtA[i] = 0x42
  282. i++
  283. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  284. n, err := msg.MarshalTo(dAtA[i:])
  285. if err != nil {
  286. return 0, err
  287. }
  288. i += n
  289. }
  290. }
  291. if len(m.Configs) > 0 {
  292. for _, msg := range m.Configs {
  293. dAtA[i] = 0x4a
  294. i++
  295. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  296. n, err := msg.MarshalTo(dAtA[i:])
  297. if err != nil {
  298. return 0, err
  299. }
  300. i += n
  301. }
  302. }
  303. return i, nil
  304. }
  305. func (m *ClusterSnapshot) Marshal() (dAtA []byte, err error) {
  306. size := m.Size()
  307. dAtA = make([]byte, size)
  308. n, err := m.MarshalTo(dAtA)
  309. if err != nil {
  310. return nil, err
  311. }
  312. return dAtA[:n], nil
  313. }
  314. func (m *ClusterSnapshot) MarshalTo(dAtA []byte) (int, error) {
  315. var i int
  316. _ = i
  317. var l int
  318. _ = l
  319. if len(m.Members) > 0 {
  320. for _, msg := range m.Members {
  321. dAtA[i] = 0xa
  322. i++
  323. i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
  324. n, err := msg.MarshalTo(dAtA[i:])
  325. if err != nil {
  326. return 0, err
  327. }
  328. i += n
  329. }
  330. }
  331. if len(m.Removed) > 0 {
  332. dAtA2 := make([]byte, len(m.Removed)*10)
  333. var j1 int
  334. for _, num := range m.Removed {
  335. for num >= 1<<7 {
  336. dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  337. num >>= 7
  338. j1++
  339. }
  340. dAtA2[j1] = uint8(num)
  341. j1++
  342. }
  343. dAtA[i] = 0x12
  344. i++
  345. i = encodeVarintSnapshot(dAtA, i, uint64(j1))
  346. i += copy(dAtA[i:], dAtA2[:j1])
  347. }
  348. return i, nil
  349. }
  350. func (m *Snapshot) Marshal() (dAtA []byte, err error) {
  351. size := m.Size()
  352. dAtA = make([]byte, size)
  353. n, err := m.MarshalTo(dAtA)
  354. if err != nil {
  355. return nil, err
  356. }
  357. return dAtA[:n], nil
  358. }
  359. func (m *Snapshot) MarshalTo(dAtA []byte) (int, error) {
  360. var i int
  361. _ = i
  362. var l int
  363. _ = l
  364. if m.Version != 0 {
  365. dAtA[i] = 0x8
  366. i++
  367. i = encodeVarintSnapshot(dAtA, i, uint64(m.Version))
  368. }
  369. dAtA[i] = 0x12
  370. i++
  371. i = encodeVarintSnapshot(dAtA, i, uint64(m.Membership.Size()))
  372. n3, err := m.Membership.MarshalTo(dAtA[i:])
  373. if err != nil {
  374. return 0, err
  375. }
  376. i += n3
  377. dAtA[i] = 0x1a
  378. i++
  379. i = encodeVarintSnapshot(dAtA, i, uint64(m.Store.Size()))
  380. n4, err := m.Store.MarshalTo(dAtA[i:])
  381. if err != nil {
  382. return 0, err
  383. }
  384. i += n4
  385. return i, nil
  386. }
  387. func encodeFixed64Snapshot(dAtA []byte, offset int, v uint64) int {
  388. dAtA[offset] = uint8(v)
  389. dAtA[offset+1] = uint8(v >> 8)
  390. dAtA[offset+2] = uint8(v >> 16)
  391. dAtA[offset+3] = uint8(v >> 24)
  392. dAtA[offset+4] = uint8(v >> 32)
  393. dAtA[offset+5] = uint8(v >> 40)
  394. dAtA[offset+6] = uint8(v >> 48)
  395. dAtA[offset+7] = uint8(v >> 56)
  396. return offset + 8
  397. }
  398. func encodeFixed32Snapshot(dAtA []byte, offset int, v uint32) int {
  399. dAtA[offset] = uint8(v)
  400. dAtA[offset+1] = uint8(v >> 8)
  401. dAtA[offset+2] = uint8(v >> 16)
  402. dAtA[offset+3] = uint8(v >> 24)
  403. return offset + 4
  404. }
  405. func encodeVarintSnapshot(dAtA []byte, offset int, v uint64) int {
  406. for v >= 1<<7 {
  407. dAtA[offset] = uint8(v&0x7f | 0x80)
  408. v >>= 7
  409. offset++
  410. }
  411. dAtA[offset] = uint8(v)
  412. return offset + 1
  413. }
  414. func (m *StoreSnapshot) Size() (n int) {
  415. var l int
  416. _ = l
  417. if len(m.Nodes) > 0 {
  418. for _, e := range m.Nodes {
  419. l = e.Size()
  420. n += 1 + l + sovSnapshot(uint64(l))
  421. }
  422. }
  423. if len(m.Services) > 0 {
  424. for _, e := range m.Services {
  425. l = e.Size()
  426. n += 1 + l + sovSnapshot(uint64(l))
  427. }
  428. }
  429. if len(m.Networks) > 0 {
  430. for _, e := range m.Networks {
  431. l = e.Size()
  432. n += 1 + l + sovSnapshot(uint64(l))
  433. }
  434. }
  435. if len(m.Tasks) > 0 {
  436. for _, e := range m.Tasks {
  437. l = e.Size()
  438. n += 1 + l + sovSnapshot(uint64(l))
  439. }
  440. }
  441. if len(m.Clusters) > 0 {
  442. for _, e := range m.Clusters {
  443. l = e.Size()
  444. n += 1 + l + sovSnapshot(uint64(l))
  445. }
  446. }
  447. if len(m.Secrets) > 0 {
  448. for _, e := range m.Secrets {
  449. l = e.Size()
  450. n += 1 + l + sovSnapshot(uint64(l))
  451. }
  452. }
  453. if len(m.Resources) > 0 {
  454. for _, e := range m.Resources {
  455. l = e.Size()
  456. n += 1 + l + sovSnapshot(uint64(l))
  457. }
  458. }
  459. if len(m.Extensions) > 0 {
  460. for _, e := range m.Extensions {
  461. l = e.Size()
  462. n += 1 + l + sovSnapshot(uint64(l))
  463. }
  464. }
  465. if len(m.Configs) > 0 {
  466. for _, e := range m.Configs {
  467. l = e.Size()
  468. n += 1 + l + sovSnapshot(uint64(l))
  469. }
  470. }
  471. return n
  472. }
  473. func (m *ClusterSnapshot) Size() (n int) {
  474. var l int
  475. _ = l
  476. if len(m.Members) > 0 {
  477. for _, e := range m.Members {
  478. l = e.Size()
  479. n += 1 + l + sovSnapshot(uint64(l))
  480. }
  481. }
  482. if len(m.Removed) > 0 {
  483. l = 0
  484. for _, e := range m.Removed {
  485. l += sovSnapshot(uint64(e))
  486. }
  487. n += 1 + sovSnapshot(uint64(l)) + l
  488. }
  489. return n
  490. }
  491. func (m *Snapshot) Size() (n int) {
  492. var l int
  493. _ = l
  494. if m.Version != 0 {
  495. n += 1 + sovSnapshot(uint64(m.Version))
  496. }
  497. l = m.Membership.Size()
  498. n += 1 + l + sovSnapshot(uint64(l))
  499. l = m.Store.Size()
  500. n += 1 + l + sovSnapshot(uint64(l))
  501. return n
  502. }
  503. func sovSnapshot(x uint64) (n int) {
  504. for {
  505. n++
  506. x >>= 7
  507. if x == 0 {
  508. break
  509. }
  510. }
  511. return n
  512. }
  513. func sozSnapshot(x uint64) (n int) {
  514. return sovSnapshot(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  515. }
  516. func (this *StoreSnapshot) String() string {
  517. if this == nil {
  518. return "nil"
  519. }
  520. s := strings.Join([]string{`&StoreSnapshot{`,
  521. `Nodes:` + strings.Replace(fmt.Sprintf("%v", this.Nodes), "Node", "Node", 1) + `,`,
  522. `Services:` + strings.Replace(fmt.Sprintf("%v", this.Services), "Service", "Service", 1) + `,`,
  523. `Networks:` + strings.Replace(fmt.Sprintf("%v", this.Networks), "Network", "Network", 1) + `,`,
  524. `Tasks:` + strings.Replace(fmt.Sprintf("%v", this.Tasks), "Task", "Task", 1) + `,`,
  525. `Clusters:` + strings.Replace(fmt.Sprintf("%v", this.Clusters), "Cluster", "Cluster", 1) + `,`,
  526. `Secrets:` + strings.Replace(fmt.Sprintf("%v", this.Secrets), "Secret", "Secret", 1) + `,`,
  527. `Resources:` + strings.Replace(fmt.Sprintf("%v", this.Resources), "Resource", "Resource", 1) + `,`,
  528. `Extensions:` + strings.Replace(fmt.Sprintf("%v", this.Extensions), "Extension", "Extension", 1) + `,`,
  529. `Configs:` + strings.Replace(fmt.Sprintf("%v", this.Configs), "Config", "Config", 1) + `,`,
  530. `}`,
  531. }, "")
  532. return s
  533. }
  534. func (this *ClusterSnapshot) String() string {
  535. if this == nil {
  536. return "nil"
  537. }
  538. s := strings.Join([]string{`&ClusterSnapshot{`,
  539. `Members:` + strings.Replace(fmt.Sprintf("%v", this.Members), "RaftMember", "RaftMember", 1) + `,`,
  540. `Removed:` + fmt.Sprintf("%v", this.Removed) + `,`,
  541. `}`,
  542. }, "")
  543. return s
  544. }
  545. func (this *Snapshot) String() string {
  546. if this == nil {
  547. return "nil"
  548. }
  549. s := strings.Join([]string{`&Snapshot{`,
  550. `Version:` + fmt.Sprintf("%v", this.Version) + `,`,
  551. `Membership:` + strings.Replace(strings.Replace(this.Membership.String(), "ClusterSnapshot", "ClusterSnapshot", 1), `&`, ``, 1) + `,`,
  552. `Store:` + strings.Replace(strings.Replace(this.Store.String(), "StoreSnapshot", "StoreSnapshot", 1), `&`, ``, 1) + `,`,
  553. `}`,
  554. }, "")
  555. return s
  556. }
  557. func valueToStringSnapshot(v interface{}) string {
  558. rv := reflect.ValueOf(v)
  559. if rv.IsNil() {
  560. return "nil"
  561. }
  562. pv := reflect.Indirect(rv).Interface()
  563. return fmt.Sprintf("*%v", pv)
  564. }
  565. func (m *StoreSnapshot) 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 ErrIntOverflowSnapshot
  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: StoreSnapshot: wiretype end group for non-group")
  589. }
  590. if fieldNum <= 0 {
  591. return fmt.Errorf("proto: StoreSnapshot: illegal tag %d (wire type %d)", fieldNum, wire)
  592. }
  593. switch fieldNum {
  594. case 1:
  595. if wireType != 2 {
  596. return fmt.Errorf("proto: wrong wireType = %d for field Nodes", wireType)
  597. }
  598. var msglen int
  599. for shift := uint(0); ; shift += 7 {
  600. if shift >= 64 {
  601. return ErrIntOverflowSnapshot
  602. }
  603. if iNdEx >= l {
  604. return io.ErrUnexpectedEOF
  605. }
  606. b := dAtA[iNdEx]
  607. iNdEx++
  608. msglen |= (int(b) & 0x7F) << shift
  609. if b < 0x80 {
  610. break
  611. }
  612. }
  613. if msglen < 0 {
  614. return ErrInvalidLengthSnapshot
  615. }
  616. postIndex := iNdEx + msglen
  617. if postIndex > l {
  618. return io.ErrUnexpectedEOF
  619. }
  620. m.Nodes = append(m.Nodes, &Node{})
  621. if err := m.Nodes[len(m.Nodes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  622. return err
  623. }
  624. iNdEx = postIndex
  625. case 2:
  626. if wireType != 2 {
  627. return fmt.Errorf("proto: wrong wireType = %d for field Services", wireType)
  628. }
  629. var msglen int
  630. for shift := uint(0); ; shift += 7 {
  631. if shift >= 64 {
  632. return ErrIntOverflowSnapshot
  633. }
  634. if iNdEx >= l {
  635. return io.ErrUnexpectedEOF
  636. }
  637. b := dAtA[iNdEx]
  638. iNdEx++
  639. msglen |= (int(b) & 0x7F) << shift
  640. if b < 0x80 {
  641. break
  642. }
  643. }
  644. if msglen < 0 {
  645. return ErrInvalidLengthSnapshot
  646. }
  647. postIndex := iNdEx + msglen
  648. if postIndex > l {
  649. return io.ErrUnexpectedEOF
  650. }
  651. m.Services = append(m.Services, &Service{})
  652. if err := m.Services[len(m.Services)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  653. return err
  654. }
  655. iNdEx = postIndex
  656. case 3:
  657. if wireType != 2 {
  658. return fmt.Errorf("proto: wrong wireType = %d for field Networks", wireType)
  659. }
  660. var msglen int
  661. for shift := uint(0); ; shift += 7 {
  662. if shift >= 64 {
  663. return ErrIntOverflowSnapshot
  664. }
  665. if iNdEx >= l {
  666. return io.ErrUnexpectedEOF
  667. }
  668. b := dAtA[iNdEx]
  669. iNdEx++
  670. msglen |= (int(b) & 0x7F) << shift
  671. if b < 0x80 {
  672. break
  673. }
  674. }
  675. if msglen < 0 {
  676. return ErrInvalidLengthSnapshot
  677. }
  678. postIndex := iNdEx + msglen
  679. if postIndex > l {
  680. return io.ErrUnexpectedEOF
  681. }
  682. m.Networks = append(m.Networks, &Network{})
  683. if err := m.Networks[len(m.Networks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  684. return err
  685. }
  686. iNdEx = postIndex
  687. case 4:
  688. if wireType != 2 {
  689. return fmt.Errorf("proto: wrong wireType = %d for field Tasks", wireType)
  690. }
  691. var msglen int
  692. for shift := uint(0); ; shift += 7 {
  693. if shift >= 64 {
  694. return ErrIntOverflowSnapshot
  695. }
  696. if iNdEx >= l {
  697. return io.ErrUnexpectedEOF
  698. }
  699. b := dAtA[iNdEx]
  700. iNdEx++
  701. msglen |= (int(b) & 0x7F) << shift
  702. if b < 0x80 {
  703. break
  704. }
  705. }
  706. if msglen < 0 {
  707. return ErrInvalidLengthSnapshot
  708. }
  709. postIndex := iNdEx + msglen
  710. if postIndex > l {
  711. return io.ErrUnexpectedEOF
  712. }
  713. m.Tasks = append(m.Tasks, &Task{})
  714. if err := m.Tasks[len(m.Tasks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  715. return err
  716. }
  717. iNdEx = postIndex
  718. case 5:
  719. if wireType != 2 {
  720. return fmt.Errorf("proto: wrong wireType = %d for field Clusters", wireType)
  721. }
  722. var msglen int
  723. for shift := uint(0); ; shift += 7 {
  724. if shift >= 64 {
  725. return ErrIntOverflowSnapshot
  726. }
  727. if iNdEx >= l {
  728. return io.ErrUnexpectedEOF
  729. }
  730. b := dAtA[iNdEx]
  731. iNdEx++
  732. msglen |= (int(b) & 0x7F) << shift
  733. if b < 0x80 {
  734. break
  735. }
  736. }
  737. if msglen < 0 {
  738. return ErrInvalidLengthSnapshot
  739. }
  740. postIndex := iNdEx + msglen
  741. if postIndex > l {
  742. return io.ErrUnexpectedEOF
  743. }
  744. m.Clusters = append(m.Clusters, &Cluster{})
  745. if err := m.Clusters[len(m.Clusters)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  746. return err
  747. }
  748. iNdEx = postIndex
  749. case 6:
  750. if wireType != 2 {
  751. return fmt.Errorf("proto: wrong wireType = %d for field Secrets", wireType)
  752. }
  753. var msglen int
  754. for shift := uint(0); ; shift += 7 {
  755. if shift >= 64 {
  756. return ErrIntOverflowSnapshot
  757. }
  758. if iNdEx >= l {
  759. return io.ErrUnexpectedEOF
  760. }
  761. b := dAtA[iNdEx]
  762. iNdEx++
  763. msglen |= (int(b) & 0x7F) << shift
  764. if b < 0x80 {
  765. break
  766. }
  767. }
  768. if msglen < 0 {
  769. return ErrInvalidLengthSnapshot
  770. }
  771. postIndex := iNdEx + msglen
  772. if postIndex > l {
  773. return io.ErrUnexpectedEOF
  774. }
  775. m.Secrets = append(m.Secrets, &Secret{})
  776. if err := m.Secrets[len(m.Secrets)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  777. return err
  778. }
  779. iNdEx = postIndex
  780. case 7:
  781. if wireType != 2 {
  782. return fmt.Errorf("proto: wrong wireType = %d for field Resources", wireType)
  783. }
  784. var msglen int
  785. for shift := uint(0); ; shift += 7 {
  786. if shift >= 64 {
  787. return ErrIntOverflowSnapshot
  788. }
  789. if iNdEx >= l {
  790. return io.ErrUnexpectedEOF
  791. }
  792. b := dAtA[iNdEx]
  793. iNdEx++
  794. msglen |= (int(b) & 0x7F) << shift
  795. if b < 0x80 {
  796. break
  797. }
  798. }
  799. if msglen < 0 {
  800. return ErrInvalidLengthSnapshot
  801. }
  802. postIndex := iNdEx + msglen
  803. if postIndex > l {
  804. return io.ErrUnexpectedEOF
  805. }
  806. m.Resources = append(m.Resources, &Resource{})
  807. if err := m.Resources[len(m.Resources)-1].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 Extensions", wireType)
  814. }
  815. var msglen int
  816. for shift := uint(0); ; shift += 7 {
  817. if shift >= 64 {
  818. return ErrIntOverflowSnapshot
  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 ErrInvalidLengthSnapshot
  832. }
  833. postIndex := iNdEx + msglen
  834. if postIndex > l {
  835. return io.ErrUnexpectedEOF
  836. }
  837. m.Extensions = append(m.Extensions, &Extension{})
  838. if err := m.Extensions[len(m.Extensions)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  839. return err
  840. }
  841. iNdEx = postIndex
  842. case 9:
  843. if wireType != 2 {
  844. return fmt.Errorf("proto: wrong wireType = %d for field Configs", wireType)
  845. }
  846. var msglen int
  847. for shift := uint(0); ; shift += 7 {
  848. if shift >= 64 {
  849. return ErrIntOverflowSnapshot
  850. }
  851. if iNdEx >= l {
  852. return io.ErrUnexpectedEOF
  853. }
  854. b := dAtA[iNdEx]
  855. iNdEx++
  856. msglen |= (int(b) & 0x7F) << shift
  857. if b < 0x80 {
  858. break
  859. }
  860. }
  861. if msglen < 0 {
  862. return ErrInvalidLengthSnapshot
  863. }
  864. postIndex := iNdEx + msglen
  865. if postIndex > l {
  866. return io.ErrUnexpectedEOF
  867. }
  868. m.Configs = append(m.Configs, &Config{})
  869. if err := m.Configs[len(m.Configs)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  870. return err
  871. }
  872. iNdEx = postIndex
  873. default:
  874. iNdEx = preIndex
  875. skippy, err := skipSnapshot(dAtA[iNdEx:])
  876. if err != nil {
  877. return err
  878. }
  879. if skippy < 0 {
  880. return ErrInvalidLengthSnapshot
  881. }
  882. if (iNdEx + skippy) > l {
  883. return io.ErrUnexpectedEOF
  884. }
  885. iNdEx += skippy
  886. }
  887. }
  888. if iNdEx > l {
  889. return io.ErrUnexpectedEOF
  890. }
  891. return nil
  892. }
  893. func (m *ClusterSnapshot) Unmarshal(dAtA []byte) error {
  894. l := len(dAtA)
  895. iNdEx := 0
  896. for iNdEx < l {
  897. preIndex := iNdEx
  898. var wire uint64
  899. for shift := uint(0); ; shift += 7 {
  900. if shift >= 64 {
  901. return ErrIntOverflowSnapshot
  902. }
  903. if iNdEx >= l {
  904. return io.ErrUnexpectedEOF
  905. }
  906. b := dAtA[iNdEx]
  907. iNdEx++
  908. wire |= (uint64(b) & 0x7F) << shift
  909. if b < 0x80 {
  910. break
  911. }
  912. }
  913. fieldNum := int32(wire >> 3)
  914. wireType := int(wire & 0x7)
  915. if wireType == 4 {
  916. return fmt.Errorf("proto: ClusterSnapshot: wiretype end group for non-group")
  917. }
  918. if fieldNum <= 0 {
  919. return fmt.Errorf("proto: ClusterSnapshot: illegal tag %d (wire type %d)", fieldNum, wire)
  920. }
  921. switch fieldNum {
  922. case 1:
  923. if wireType != 2 {
  924. return fmt.Errorf("proto: wrong wireType = %d for field Members", wireType)
  925. }
  926. var msglen int
  927. for shift := uint(0); ; shift += 7 {
  928. if shift >= 64 {
  929. return ErrIntOverflowSnapshot
  930. }
  931. if iNdEx >= l {
  932. return io.ErrUnexpectedEOF
  933. }
  934. b := dAtA[iNdEx]
  935. iNdEx++
  936. msglen |= (int(b) & 0x7F) << shift
  937. if b < 0x80 {
  938. break
  939. }
  940. }
  941. if msglen < 0 {
  942. return ErrInvalidLengthSnapshot
  943. }
  944. postIndex := iNdEx + msglen
  945. if postIndex > l {
  946. return io.ErrUnexpectedEOF
  947. }
  948. m.Members = append(m.Members, &RaftMember{})
  949. if err := m.Members[len(m.Members)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  950. return err
  951. }
  952. iNdEx = postIndex
  953. case 2:
  954. if wireType == 2 {
  955. var packedLen int
  956. for shift := uint(0); ; shift += 7 {
  957. if shift >= 64 {
  958. return ErrIntOverflowSnapshot
  959. }
  960. if iNdEx >= l {
  961. return io.ErrUnexpectedEOF
  962. }
  963. b := dAtA[iNdEx]
  964. iNdEx++
  965. packedLen |= (int(b) & 0x7F) << shift
  966. if b < 0x80 {
  967. break
  968. }
  969. }
  970. if packedLen < 0 {
  971. return ErrInvalidLengthSnapshot
  972. }
  973. postIndex := iNdEx + packedLen
  974. if postIndex > l {
  975. return io.ErrUnexpectedEOF
  976. }
  977. for iNdEx < postIndex {
  978. var v uint64
  979. for shift := uint(0); ; shift += 7 {
  980. if shift >= 64 {
  981. return ErrIntOverflowSnapshot
  982. }
  983. if iNdEx >= l {
  984. return io.ErrUnexpectedEOF
  985. }
  986. b := dAtA[iNdEx]
  987. iNdEx++
  988. v |= (uint64(b) & 0x7F) << shift
  989. if b < 0x80 {
  990. break
  991. }
  992. }
  993. m.Removed = append(m.Removed, v)
  994. }
  995. } else if wireType == 0 {
  996. var v uint64
  997. for shift := uint(0); ; shift += 7 {
  998. if shift >= 64 {
  999. return ErrIntOverflowSnapshot
  1000. }
  1001. if iNdEx >= l {
  1002. return io.ErrUnexpectedEOF
  1003. }
  1004. b := dAtA[iNdEx]
  1005. iNdEx++
  1006. v |= (uint64(b) & 0x7F) << shift
  1007. if b < 0x80 {
  1008. break
  1009. }
  1010. }
  1011. m.Removed = append(m.Removed, v)
  1012. } else {
  1013. return fmt.Errorf("proto: wrong wireType = %d for field Removed", wireType)
  1014. }
  1015. default:
  1016. iNdEx = preIndex
  1017. skippy, err := skipSnapshot(dAtA[iNdEx:])
  1018. if err != nil {
  1019. return err
  1020. }
  1021. if skippy < 0 {
  1022. return ErrInvalidLengthSnapshot
  1023. }
  1024. if (iNdEx + skippy) > l {
  1025. return io.ErrUnexpectedEOF
  1026. }
  1027. iNdEx += skippy
  1028. }
  1029. }
  1030. if iNdEx > l {
  1031. return io.ErrUnexpectedEOF
  1032. }
  1033. return nil
  1034. }
  1035. func (m *Snapshot) Unmarshal(dAtA []byte) error {
  1036. l := len(dAtA)
  1037. iNdEx := 0
  1038. for iNdEx < l {
  1039. preIndex := iNdEx
  1040. var wire uint64
  1041. for shift := uint(0); ; shift += 7 {
  1042. if shift >= 64 {
  1043. return ErrIntOverflowSnapshot
  1044. }
  1045. if iNdEx >= l {
  1046. return io.ErrUnexpectedEOF
  1047. }
  1048. b := dAtA[iNdEx]
  1049. iNdEx++
  1050. wire |= (uint64(b) & 0x7F) << shift
  1051. if b < 0x80 {
  1052. break
  1053. }
  1054. }
  1055. fieldNum := int32(wire >> 3)
  1056. wireType := int(wire & 0x7)
  1057. if wireType == 4 {
  1058. return fmt.Errorf("proto: Snapshot: wiretype end group for non-group")
  1059. }
  1060. if fieldNum <= 0 {
  1061. return fmt.Errorf("proto: Snapshot: illegal tag %d (wire type %d)", fieldNum, wire)
  1062. }
  1063. switch fieldNum {
  1064. case 1:
  1065. if wireType != 0 {
  1066. return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType)
  1067. }
  1068. m.Version = 0
  1069. for shift := uint(0); ; shift += 7 {
  1070. if shift >= 64 {
  1071. return ErrIntOverflowSnapshot
  1072. }
  1073. if iNdEx >= l {
  1074. return io.ErrUnexpectedEOF
  1075. }
  1076. b := dAtA[iNdEx]
  1077. iNdEx++
  1078. m.Version |= (Snapshot_Version(b) & 0x7F) << shift
  1079. if b < 0x80 {
  1080. break
  1081. }
  1082. }
  1083. case 2:
  1084. if wireType != 2 {
  1085. return fmt.Errorf("proto: wrong wireType = %d for field Membership", wireType)
  1086. }
  1087. var msglen int
  1088. for shift := uint(0); ; shift += 7 {
  1089. if shift >= 64 {
  1090. return ErrIntOverflowSnapshot
  1091. }
  1092. if iNdEx >= l {
  1093. return io.ErrUnexpectedEOF
  1094. }
  1095. b := dAtA[iNdEx]
  1096. iNdEx++
  1097. msglen |= (int(b) & 0x7F) << shift
  1098. if b < 0x80 {
  1099. break
  1100. }
  1101. }
  1102. if msglen < 0 {
  1103. return ErrInvalidLengthSnapshot
  1104. }
  1105. postIndex := iNdEx + msglen
  1106. if postIndex > l {
  1107. return io.ErrUnexpectedEOF
  1108. }
  1109. if err := m.Membership.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1110. return err
  1111. }
  1112. iNdEx = postIndex
  1113. case 3:
  1114. if wireType != 2 {
  1115. return fmt.Errorf("proto: wrong wireType = %d for field Store", wireType)
  1116. }
  1117. var msglen int
  1118. for shift := uint(0); ; shift += 7 {
  1119. if shift >= 64 {
  1120. return ErrIntOverflowSnapshot
  1121. }
  1122. if iNdEx >= l {
  1123. return io.ErrUnexpectedEOF
  1124. }
  1125. b := dAtA[iNdEx]
  1126. iNdEx++
  1127. msglen |= (int(b) & 0x7F) << shift
  1128. if b < 0x80 {
  1129. break
  1130. }
  1131. }
  1132. if msglen < 0 {
  1133. return ErrInvalidLengthSnapshot
  1134. }
  1135. postIndex := iNdEx + msglen
  1136. if postIndex > l {
  1137. return io.ErrUnexpectedEOF
  1138. }
  1139. if err := m.Store.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1140. return err
  1141. }
  1142. iNdEx = postIndex
  1143. default:
  1144. iNdEx = preIndex
  1145. skippy, err := skipSnapshot(dAtA[iNdEx:])
  1146. if err != nil {
  1147. return err
  1148. }
  1149. if skippy < 0 {
  1150. return ErrInvalidLengthSnapshot
  1151. }
  1152. if (iNdEx + skippy) > l {
  1153. return io.ErrUnexpectedEOF
  1154. }
  1155. iNdEx += skippy
  1156. }
  1157. }
  1158. if iNdEx > l {
  1159. return io.ErrUnexpectedEOF
  1160. }
  1161. return nil
  1162. }
  1163. func skipSnapshot(dAtA []byte) (n int, err error) {
  1164. l := len(dAtA)
  1165. iNdEx := 0
  1166. for iNdEx < l {
  1167. var wire uint64
  1168. for shift := uint(0); ; shift += 7 {
  1169. if shift >= 64 {
  1170. return 0, ErrIntOverflowSnapshot
  1171. }
  1172. if iNdEx >= l {
  1173. return 0, io.ErrUnexpectedEOF
  1174. }
  1175. b := dAtA[iNdEx]
  1176. iNdEx++
  1177. wire |= (uint64(b) & 0x7F) << shift
  1178. if b < 0x80 {
  1179. break
  1180. }
  1181. }
  1182. wireType := int(wire & 0x7)
  1183. switch wireType {
  1184. case 0:
  1185. for shift := uint(0); ; shift += 7 {
  1186. if shift >= 64 {
  1187. return 0, ErrIntOverflowSnapshot
  1188. }
  1189. if iNdEx >= l {
  1190. return 0, io.ErrUnexpectedEOF
  1191. }
  1192. iNdEx++
  1193. if dAtA[iNdEx-1] < 0x80 {
  1194. break
  1195. }
  1196. }
  1197. return iNdEx, nil
  1198. case 1:
  1199. iNdEx += 8
  1200. return iNdEx, nil
  1201. case 2:
  1202. var length int
  1203. for shift := uint(0); ; shift += 7 {
  1204. if shift >= 64 {
  1205. return 0, ErrIntOverflowSnapshot
  1206. }
  1207. if iNdEx >= l {
  1208. return 0, io.ErrUnexpectedEOF
  1209. }
  1210. b := dAtA[iNdEx]
  1211. iNdEx++
  1212. length |= (int(b) & 0x7F) << shift
  1213. if b < 0x80 {
  1214. break
  1215. }
  1216. }
  1217. iNdEx += length
  1218. if length < 0 {
  1219. return 0, ErrInvalidLengthSnapshot
  1220. }
  1221. return iNdEx, nil
  1222. case 3:
  1223. for {
  1224. var innerWire uint64
  1225. var start int = iNdEx
  1226. for shift := uint(0); ; shift += 7 {
  1227. if shift >= 64 {
  1228. return 0, ErrIntOverflowSnapshot
  1229. }
  1230. if iNdEx >= l {
  1231. return 0, io.ErrUnexpectedEOF
  1232. }
  1233. b := dAtA[iNdEx]
  1234. iNdEx++
  1235. innerWire |= (uint64(b) & 0x7F) << shift
  1236. if b < 0x80 {
  1237. break
  1238. }
  1239. }
  1240. innerWireType := int(innerWire & 0x7)
  1241. if innerWireType == 4 {
  1242. break
  1243. }
  1244. next, err := skipSnapshot(dAtA[start:])
  1245. if err != nil {
  1246. return 0, err
  1247. }
  1248. iNdEx = start + next
  1249. }
  1250. return iNdEx, nil
  1251. case 4:
  1252. return iNdEx, nil
  1253. case 5:
  1254. iNdEx += 4
  1255. return iNdEx, nil
  1256. default:
  1257. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1258. }
  1259. }
  1260. panic("unreachable")
  1261. }
  1262. var (
  1263. ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling")
  1264. ErrIntOverflowSnapshot = fmt.Errorf("proto: integer overflow")
  1265. )
  1266. func init() { proto.RegisterFile("snapshot.proto", fileDescriptorSnapshot) }
  1267. var fileDescriptorSnapshot = []byte{
  1268. // 466 bytes of a gzipped FileDescriptorProto
  1269. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x7c, 0x93, 0x3f, 0x6f, 0x13, 0x4d,
  1270. 0x10, 0x87, 0xbd, 0xfe, 0x77, 0xce, 0x44, 0xc9, 0xfb, 0xb2, 0xa2, 0x58, 0x19, 0x38, 0x8c, 0xa1,
  1271. 0x70, 0x75, 0x80, 0x41, 0x02, 0x21, 0x85, 0x22, 0x11, 0x05, 0x05, 0x29, 0xd6, 0x28, 0xa2, 0x3d,
  1272. 0x9f, 0xc7, 0xce, 0x71, 0xf8, 0xd6, 0xda, 0xd9, 0x38, 0x94, 0xf0, 0xed, 0x5c, 0x52, 0x52, 0x21,
  1273. 0xe2, 0x86, 0xaf, 0x81, 0x76, 0xf7, 0xee, 0xb0, 0xc4, 0x99, 0x6e, 0x6d, 0x3d, 0xcf, 0xcc, 0x6f,
  1274. 0xf7, 0x66, 0xe0, 0x98, 0xf2, 0x78, 0x45, 0x97, 0xca, 0x44, 0x2b, 0xad, 0x8c, 0xe2, 0x7c, 0xa6,
  1275. 0x92, 0x0c, 0x75, 0x44, 0xd7, 0xb1, 0x5e, 0x66, 0xa9, 0x89, 0xd6, 0x4f, 0xfb, 0x47, 0x6a, 0xfa,
  1276. 0x11, 0x13, 0x43, 0x1e, 0xe9, 0x83, 0x8e, 0xe7, 0x05, 0xde, 0xbf, 0xbd, 0x50, 0x0b, 0xe5, 0x8e,
  1277. 0x8f, 0xed, 0xc9, 0xff, 0x3b, 0xfc, 0xda, 0x86, 0xa3, 0x89, 0x51, 0x1a, 0x27, 0x45, 0x71, 0x1e,
  1278. 0x41, 0x27, 0x57, 0x33, 0x24, 0xc1, 0x06, 0xad, 0xd1, 0xe1, 0x58, 0x44, 0x7f, 0xb7, 0x89, 0xce,
  1279. 0xd5, 0x0c, 0xa5, 0xc7, 0xf8, 0x0b, 0xe8, 0x11, 0xea, 0x75, 0x9a, 0x20, 0x89, 0xa6, 0x53, 0xee,
  1280. 0xd4, 0x29, 0x13, 0xcf, 0xc8, 0x0a, 0xb6, 0x62, 0x8e, 0xe6, 0x5a, 0xe9, 0x8c, 0x44, 0x6b, 0xbf,
  1281. 0x78, 0xee, 0x19, 0x59, 0xc1, 0x36, 0xa1, 0x89, 0x29, 0x23, 0xd1, 0xde, 0x9f, 0xf0, 0x7d, 0x4c,
  1282. 0x99, 0xf4, 0x98, 0x6d, 0x94, 0x7c, 0xba, 0x22, 0x83, 0x9a, 0x44, 0x67, 0x7f, 0xa3, 0x33, 0xcf,
  1283. 0xc8, 0x0a, 0xe6, 0xcf, 0x21, 0x20, 0x4c, 0x34, 0x1a, 0x12, 0x5d, 0xe7, 0xf5, 0xeb, 0x6f, 0x66,
  1284. 0x11, 0x59, 0xa2, 0xfc, 0x15, 0x1c, 0x68, 0x24, 0x75, 0xa5, 0xed, 0x8b, 0x04, 0xce, 0xbb, 0x5b,
  1285. 0xe7, 0xc9, 0x02, 0x92, 0x7f, 0x70, 0x7e, 0x02, 0x80, 0x9f, 0x0d, 0xe6, 0x94, 0xaa, 0x9c, 0x44,
  1286. 0xcf, 0xc9, 0xf7, 0xea, 0xe4, 0x37, 0x25, 0x25, 0x77, 0x04, 0x1b, 0x38, 0x51, 0xf9, 0x3c, 0x5d,
  1287. 0x90, 0x38, 0xd8, 0x1f, 0xf8, 0xcc, 0x21, 0xb2, 0x44, 0x87, 0x08, 0xff, 0x15, 0x77, 0xaf, 0x86,
  1288. 0xe0, 0x25, 0x04, 0x4b, 0x5c, 0x4e, 0xed, 0x8b, 0xf9, 0x31, 0x08, 0x6b, 0x6f, 0x10, 0xcf, 0xcd,
  1289. 0x3b, 0x87, 0xc9, 0x12, 0xe7, 0x02, 0x02, 0x8d, 0x4b, 0xb5, 0xc6, 0x99, 0x9b, 0x86, 0xb6, 0x2c,
  1290. 0x7f, 0x0e, 0x7f, 0x31, 0xe8, 0x55, 0x0d, 0x5e, 0x43, 0xb0, 0x46, 0x6d, 0x53, 0x0b, 0x36, 0x60,
  1291. 0xa3, 0xe3, 0xf1, 0xa3, 0xda, 0xa7, 0x2d, 0x27, 0xfe, 0xc2, 0xb3, 0xb2, 0x94, 0xf8, 0x5b, 0x80,
  1292. 0xa2, 0xe3, 0x65, 0xba, 0x12, 0xcd, 0x01, 0x1b, 0x1d, 0x8e, 0x1f, 0xfe, 0xe3, 0xab, 0x96, 0x95,
  1293. 0x4e, 0xdb, 0x9b, 0x1f, 0xf7, 0x1b, 0x72, 0x47, 0xe6, 0x27, 0xd0, 0x21, 0xbb, 0x01, 0xa2, 0xe5,
  1294. 0xaa, 0x3c, 0xa8, 0x0d, 0xb2, 0xbb, 0x22, 0x45, 0x0d, 0x6f, 0x0d, 0x6f, 0x41, 0x50, 0xa4, 0xe3,
  1295. 0x5d, 0x68, 0x5e, 0x3c, 0xf9, 0xbf, 0x71, 0x2a, 0x36, 0x37, 0x61, 0xe3, 0xfb, 0x4d, 0xd8, 0xf8,
  1296. 0xb2, 0x0d, 0xd9, 0x66, 0x1b, 0xb2, 0x6f, 0xdb, 0x90, 0xfd, 0xdc, 0x86, 0xec, 0x43, 0x73, 0xda,
  1297. 0x75, 0x7b, 0xf7, 0xec, 0x77, 0x00, 0x00, 0x00, 0xff, 0xff, 0x8f, 0x41, 0x5b, 0x51, 0xce, 0x03,
  1298. 0x00, 0x00,
  1299. }