Skip to content

Commit

Permalink
move cache config for configmaps to a dedicated function
Browse files Browse the repository at this point in the history
  • Loading branch information
hisarbalik committed Jan 31, 2025
1 parent d2be1a3 commit 1fc8353
Showing 1 changed file with 13 additions and 11 deletions.
24 changes: 13 additions & 11 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -180,17 +180,10 @@ func run() error {
// The operator handles various resource that are namespace-scoped, and additionally some resources that are cluster-scoped (clusterroles, clusterrolebindings, etc.).
// For namespace-scoped resources we want to restrict the operator permissions to only fetch resources from a given namespace.
ByObject: map[client.Object]cache.ByObject{
&appsv1.Deployment{}: {Field: setNamespaceFieldSelector()},
&appsv1.ReplicaSet{}: {Field: setNamespaceFieldSelector()},
&appsv1.DaemonSet{}: {Field: setNamespaceFieldSelector()},
&corev1.ConfigMap{}: {
Namespaces: map[string]cache.Config{
"kube-system": {
FieldSelector: fields.SelectorFromSet(fields.Set{"metadata.name": "shoot-info"}),
},
telemetryNamespace: {},
},
},
&appsv1.Deployment{}: {Field: setNamespaceFieldSelector()},
&appsv1.ReplicaSet{}: {Field: setNamespaceFieldSelector()},
&appsv1.DaemonSet{}: {Field: setNamespaceFieldSelector()},
&corev1.ConfigMap{}: {Namespaces: setConfigMapNamespaceFieldSelector()},
&corev1.ServiceAccount{}: {Field: setNamespaceFieldSelector()},
&corev1.Service{}: {Field: setNamespaceFieldSelector()},
&networkingv1.NetworkPolicy{}: {Field: setNamespaceFieldSelector()},
Expand Down Expand Up @@ -463,6 +456,15 @@ func setNamespaceFieldSelector() fields.Selector {
return fields.SelectorFromSet(fields.Set{"metadata.namespace": telemetryNamespace})
}

func setConfigMapNamespaceFieldSelector() map[string]cache.Config {
return map[string]cache.Config{
"kube-system": {
FieldSelector: fields.SelectorFromSet(fields.Set{"metadata.name": "shoot-info"}),
},
telemetryNamespace: {},
}
}

func createSelfMonitoringConfig() telemetry.SelfMonitorConfig {
return telemetry.SelfMonitorConfig{
Config: selfmonitor.Config{
Expand Down

0 comments on commit 1fc8353

Please sign in to comment.