Function collectPluginsImages

cmd/sonobuoy/app/images.go:494–529

(plugins []string, pluginEnvs PluginEnvVars, k8sVersion string, client image.Client)

}

func collectPluginsImages(plugins []string, pluginEnvs PluginEnvVars, k8sVersion string, client image.Client) ([]string, error) {
	images := []string{
		config.DefaultImage,
	}
	for _, plugin := range plugins {
		switch plugin {
		case systemdLogsPlugin:
			images = append(images, config.DefaultSystemdLogsImage)
		case e2ePlugin:
			conformanceImage := fmt.Sprintf("%v:%v", config.UpstreamKubeConformanceImageURL, k8sVersion)
			images = append(images, conformanceImage)
			logrus.Info("e2e image to be used: ", conformanceImage)

			// pull before running to ensure stderr is empty, because...
			client.PullImages([]string{conformanceImage}, numDockerRetries)

			// we only need stdout, but this combines stdout and stderr
			e2eImages, err := client.RunImage(conformanceImage, "e2e.test", pluginEnvs[e2ePlugin], "--list-images")
			if err != nil {
				return images, errors.Wrap(err, "failed to gather test images from e2e image")
			}

			// in case there are empty newlines getting parsed as a slice element
			validE2eImages := []string{}
			for _, e2eImage := range e2eImages {
				if e2eImage != "" {
					validE2eImages = append(validE2eImages, e2eImage)
				}
			}
			images = append(images, validE2eImages...)
		default:
			return images, errors.Errorf("Unsupported plugin: %v", plugin)
		}
	}
	return images, nil
}