-
Notifications
You must be signed in to change notification settings - Fork 89
/
write_images.go
47 lines (41 loc) · 1.57 KB
/
write_images.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
package base
import (
"io"
"github.com/pkg/errors"
kotsv1beta1 "github.com/replicatedhq/kots/kotskinds/apis/kots/v1beta1"
"github.com/replicatedhq/kots/pkg/docker/registry"
"github.com/replicatedhq/kots/pkg/image"
"github.com/replicatedhq/kots/pkg/logger"
kustomizeimage "sigs.k8s.io/kustomize/api/types"
)
type WriteUpstreamImageOptions struct {
BaseDir string
AppSlug string
SourceRegistry registry.RegistryOptions
DestRegistry registry.RegistryOptions
DryRun bool
IsAirgap bool
Log *logger.Logger
ReportWriter io.Writer
Installation *kotsv1beta1.Installation
Application *kotsv1beta1.Application
}
type WriteUpstreamImageResult struct {
Images []kustomizeimage.Image // images to be rewritten
CheckedImages []kotsv1beta1.InstallationImage // all images found in the installation
}
func CopyUpstreamImages(options WriteUpstreamImageOptions) (*WriteUpstreamImageResult, error) {
additionalImages := make([]string, 0)
if options.Application != nil {
additionalImages = options.Application.Spec.AdditionalImages
}
checkedImages := makeImageInfoMap(options.Installation.Spec.KnownImages)
newImages, err := image.CopyImages(options.SourceRegistry, options.DestRegistry, options.AppSlug, options.Log, options.ReportWriter, options.BaseDir, additionalImages, options.DryRun, options.IsAirgap, checkedImages)
if err != nil {
return nil, errors.Wrap(err, "failed to save images")
}
return &WriteUpstreamImageResult{
Images: newImages,
CheckedImages: makeInstallationImages(checkedImages),
}, nil
}