/
flannel.go
82 lines (66 loc) · 2.11 KB
/
flannel.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
/*
Copyright 2020 The Kubernetes Authors All rights reserved.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package cni
import (
"bytes"
_ "embed"
"os/exec"
"text/template"
"github.com/pkg/errors"
"k8s.io/minikube/pkg/minikube/assets"
"k8s.io/minikube/pkg/minikube/config"
)
// ref: https://github.com/flannel-io/flannel#deploying-flannel-manually: "For Kubernetes v1.17+"; multi-arch support
//go:embed flannel.yaml
var flannelYaml string
// https://raw.githubusercontent.com/flannel-io/flannel/master/Documentation/kube-flannel.yml
var flannelTmpl = template.Must(template.New("flannel").Parse(flannelYaml))
type flannelTmplStruct struct {
PodCIDR string
}
// Flannel is the Flannel CNI manager
type Flannel struct {
cc config.ClusterConfig
}
// String returns a string representation of this CNI
func (c Flannel) String() string {
return "Flannel"
}
// Apply enables the CNI
func (c Flannel) Apply(r Runner) error {
// Mostly applicable to the 'none' driver
_, err := r.RunCmd(exec.Command("stat", "/opt/cni/bin/portmap"))
if err != nil {
return errors.Wrap(err, "required 'portmap' CNI plug-in not found")
}
m, err := c.manifest()
if err != nil {
return errors.Wrap(err, "manifest")
}
return applyManifest(c.cc, r, m)
}
// manifest returns a Kubernetes manifest for a CNI
func (c Flannel) manifest() (assets.CopyableFile, error) {
input := &flannelTmplStruct{
PodCIDR: DefaultPodCIDR,
}
b := bytes.Buffer{}
if err := flannelTmpl.Execute(&b, input); err != nil {
return nil, err
}
return manifestAsset(b.Bytes()), nil
}
// CIDR returns the default CIDR used by this CNI
func (c Flannel) CIDR() string {
return DefaultPodCIDR
}