-
Dennis Marttinen authored
Signed-off-by:
Dennis Marttinen <dennis@weave.works>
Unverified45102412
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package recipe
import (
"fmt"
"io/ioutil"
log "github.com/sirupsen/logrus"
"github.com/weaveworks/wksctl/pkg/apis/wksprovider/controller/manifests"
existinginfrav1 "github.com/weaveworks/wksctl/pkg/existinginfra/v1alpha3"
"github.com/weaveworks/wksctl/pkg/plan"
"github.com/weaveworks/wksctl/pkg/plan/resource"
)
// BuildConfigMapPlan creates a plan to handle config maps
func BuildConfigMapPlan(manifests map[string][]byte, namespace string) plan.Resource {
b := plan.NewBuilder()
for name, manifest := range manifests {
remoteName := fmt.Sprintf("config-map-%s", name)
b.AddResource("install:"+remoteName, &resource.KubectlApply{Filename: object.String(remoteName), Manifest: manifest, Namespace: object.String(namespace)})
}
p, err := b.Plan()
if err != nil {
log.Fatalf("%v", err)
}
return &p
}
// BuildCNIPlan creates a sub-plan to install the CNI plugin.
func BuildCNIPlan(cni string, manifests [][]byte) plan.Resource {
b := plan.NewBuilder()
b.AddResource(
"install-cni:apply-manifests",
&resource.KubectlApply{Manifest: manifests[0], Filename: object.String(cni + ".yaml")},
)
if len(manifests) == 2 {
b.AddResource(
"install-cni:apply-manifests-ds",
&resource.KubectlApply{Manifest: manifests[1], Filename: object.String(cni + "-daemon-set" + ".yaml")},
plan.DependOn("install-cni:apply-manifests"))
}
p, err := b.Plan()
if err != nil {
log.Fatalf("%v", err)
}
return &p
}
//BuildSealedSecretPlan creates a sub-plan to install sealed secrets so we can check secrets into GitHub for GitOps
func BuildSealedSecretPlan(sealedSecretVersion, ns string, manifest []byte) plan.Resource {
b := plan.NewBuilder()
fileCRD, err := manifests.Manifests.Open("05_sealed_secret_crd.yaml")
if err != nil {
log.Fatalf("%v", err)
}
manifestbytesCRD, err := ioutil.ReadAll(fileCRD)
if err != nil {
log.Fatalf("%v", err)
}
b.AddResource("install:sealed-secret-crd",
&resource.KubectlApply{Manifest: manifestbytesCRD, Filename: object.String("SealedSecretCRD.yaml"),
WaitCondition: "condition=Established"})
b.AddResource("install:sealed-secrets-key", &resource.KubectlApply{Manifest: manifest})
file, err := manifests.Manifests.Open("06_sealed_secret_controller.yaml")
if err != nil {
log.Fatalf("%v", err)
}
manifestbytes, err := ioutil.ReadAll(file)
if err != nil {
log.Fatalf("%v", err)
}
b.AddResource("install:sealed-secrets-controller",
&resource.KubectlApply{Manifest: manifestbytes, Filename: object.String("SealedSecretController.yaml")},
plan.DependOn("install:sealed-secrets-key"))
p, err := b.Plan()
if err != nil {
log.Fatalf("%v", err)
}
return &p
}
// BuildAddonPlan creates a plan containing all the addons from the cluster manifest
func BuildAddonPlan(clusterManifestPath string, addons map[string][][]byte) plan.Resource {
b := plan.NewBuilder()
for name, manifests := range addons {
var previous *string
for i, m := range manifests {
resFile := fmt.Sprintf("%s-%02d", name, i)
resName := "install:addon:" + resFile
manRsc := &resource.KubectlApply{Manifest: m, Filename: object.String(resFile + ".yaml"), Namespace: object.String("addons")}
if previous != nil {
b.AddResource(resName, manRsc, plan.DependOn(*previous))
} else {
b.AddResource(resName, manRsc)
}
previous = &resName
}
}
p, err := b.Plan()
if err != nil {
log.Fatalf("%v", err)
}
return &p
}