forked from tigera/operator
/
namespaces.go
80 lines (69 loc) · 2.26 KB
/
namespaces.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
// Copyright (c) 2019 Tigera, Inc. 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 render
import (
operator "github.com/tigera/operator/pkg/apis/operator/v1"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
)
const (
calicoNamespace = "calico-system"
calicoMonitoringNamespace = "calico-monitoring"
)
func Namespaces(cr *operator.Installation, openshift bool, pullSecrets []*corev1.Secret) Component {
return &namespaceComponent{
cr: cr,
openshift: openshift,
pullSecrets: pullSecrets,
}
}
type namespaceComponent struct {
cr *operator.Installation
openshift bool
pullSecrets []*corev1.Secret
}
func (c *namespaceComponent) Objects() []runtime.Object {
ns := []runtime.Object{
createNamespace(calicoNamespace, c.openshift),
}
if len(c.pullSecrets) > 0 {
ns = append(ns, copyImagePullSecrets(c.pullSecrets, calicoNamespace)...)
}
if c.cr.Spec.Variant == operator.TigeraSecureEnterprise {
ns = append(ns, createNamespace(calicoMonitoringNamespace, c.openshift))
if len(c.pullSecrets) > 0 {
ns = append(ns, copyImagePullSecrets(c.pullSecrets, calicoMonitoringNamespace)...)
}
}
return ns
}
func (c *namespaceComponent) Ready() bool {
return true
}
func createNamespace(name string, openshift bool) *corev1.Namespace {
ns := &corev1.Namespace{
TypeMeta: metav1.TypeMeta{Kind: "Namespace", APIVersion: "v1"},
ObjectMeta: metav1.ObjectMeta{
Name: name,
Labels: map[string]string{"name": name},
Annotations: map[string]string{},
},
}
// OpenShift requires special labels and annotations.
if openshift {
ns.Labels["openshift.io/run-level"] = "0"
ns.Annotations["openshift.io/node-selector"] = ""
}
return ns
}