(plugins []string, pluginEnvs PluginEnvVars, e2eRegistryConfig, k8sVersion string, client image.Client)
| 367 | } |
| 368 | |
| 369 | func downloadImages(plugins []string, pluginEnvs PluginEnvVars, e2eRegistryConfig, k8sVersion string, client image.Client) error { |
| 370 | images, err := collectPluginsImages(plugins, pluginEnvs, k8sVersion, client) |
| 371 | if err != nil { |
| 372 | return errors.Wrapf(err, "unable to collect images of plugins") |
| 373 | } |
| 374 | if e2eRegistryConfig != "" { |
| 375 | imagePairs, err := convertImagesToPairs(images, "", e2eRegistryConfig, k8sVersion) |
| 376 | if err != nil { |
| 377 | return err |
| 378 | } |
| 379 | images = []string{} |
| 380 | for _, imagePair := range imagePairs { |
| 381 | images = append(images, imagePair.Dst) |
| 382 | } |
| 383 | } |
| 384 | filename, err := client.DownloadImages(images, k8sVersion) |
| 385 | if err != nil { |
| 386 | return errors.Wrap(err, "unable to download images") |
| 387 | } |
| 388 | fmt.Println(filename) |
| 389 | return nil |
| 390 | } |
| 391 | |
| 392 | func pushImages(plugins []string, pluginEnvs PluginEnvVars, customRegistry, e2eRegistryConfig, k8sVersion string, client image.Client) []error { |
| 393 | images, err := collectPluginsImages(plugins, pluginEnvs, k8sVersion, client) |
no test coverage detected