/
clusterwideresourceinterceptor.go
59 lines (52 loc) · 1.44 KB
/
clusterwideresourceinterceptor.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
package service
import (
"github.com/kyma-incubator/reconciler/pkg/reconciler/kubernetes"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
)
type clusterWideResource struct {
kind string
apiVersion string
}
type ClusterWideResourceInterceptor struct {
clusterWideResources []clusterWideResource
}
func (c *ClusterWideResourceInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error {
interceptorFunc := func(u *unstructured.Unstructured) error {
//clean namespace field from cluster-wide resource template
u.SetNamespace("")
return nil
}
for i := range c.clusterWideResources {
err := resources.VisitByKindAndAPIVersion(c.clusterWideResources[i].kind, c.clusterWideResources[i].apiVersion, interceptorFunc)
if err != nil {
return err
}
}
return nil
}
func newClusterWideResourceInterceptor() *ClusterWideResourceInterceptor {
return &ClusterWideResourceInterceptor{
clusterWideResources: []clusterWideResource{
{
kind: "clusterrolebinding",
apiVersion: "rbac.authorization.k8s.io/v1",
},
{
kind: "clusterrole",
apiVersion: "rbac.authorization.k8s.io/v1",
},
{
kind: "mutatingwebhookconfiguration",
apiVersion: "admissionregistration.k8s.io/v1",
},
{
kind: "validatingwebhookconfiguration",
apiVersion: "admissionregistration.k8s.io/v1",
},
{
kind: "podsecuritypolicy",
apiVersion: "policy/v1beta1",
},
},
}
}