forked from joeholley/supergloo
-
Notifications
You must be signed in to change notification settings - Fork 0
/
install_opts.go
89 lines (70 loc) · 2.37 KB
/
install_opts.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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package linkerd
import (
"bytes"
"context"
"k8s.io/client-go/kubernetes"
"github.com/solo-io/go-utils/contextutils"
"github.com/solo-io/go-utils/installutils/helmchart"
"github.com/solo-io/go-utils/installutils/kubeinstall"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
)
const (
Version_stable230 = "stable-2.3.0"
)
var supportedVersions = []string{Version_stable230}
type installOpts struct {
installVersion string
installNamespace string
enableMtls bool
enableAutoInject bool
}
func newInstallOpts(installVersion string, installNamespace string, enableMtls bool, enableAutoInject bool) *installOpts {
return &installOpts{installVersion: installVersion, installNamespace: installNamespace, enableMtls: enableMtls, enableAutoInject: enableAutoInject}
}
func (o *installOpts) install(ctx context.Context, installer kubeinstall.Installer, withLabels map[string]string, kube kubernetes.Interface) error {
uri, err := o.chartURI()
if err != nil {
return err
}
injector, values, err := o.values(kube)
if err != nil {
return err
}
manifests, err := helmchart.RenderManifests(ctx, uri, values, "linkerd2", o.installNamespace, "")
if err != nil {
return err
}
manifests, err = injectManifests(injector, manifests)
if err != nil {
return err
}
resources, err := manifests.ResourceList()
if err != nil {
return err
}
resources = resources.Filter(func(resource *unstructured.Unstructured) bool {
gvk := resource.GroupVersionKind()
// overwrite the deployment group version to extensions/v1beta1 for all deployments
if gvk.Group == "apps" && gvk.Version == "v1" && gvk.Kind == "Deployment" {
gvk.Group = "extensions"
gvk.Version = "v1beta1"
resource.SetGroupVersionKind(gvk)
}
// filter out the install namespace, it's created by the custom installer
return gvk.Kind == "Namespace"
})
contextutils.LoggerFrom(ctx).Infof("installing linkerd with options: %#v", o)
if err := installer.ReconcileResources(ctx, o.installNamespace, resources, withLabels); err != nil {
return err
}
return nil
}
func injectManifests(injector *injector, in helmchart.Manifests) (helmchart.Manifests, error) {
input := bytes.NewBufferString(in.CombinedString())
out := &bytes.Buffer{}
err := processYAML(input, out, injector)
if err != nil {
return nil, err
}
return helmchart.Manifests{{Name: "linkerd-injected-manifest", Content: out.String()}}, nil
}