fix: added unique names to all controllers

cmd/crd-replicator/main.go

@@ -95,13 +95,13 @@ func main() {
 			clusterID, namespaceManager),
 	}
 	if err = d.SetupWithManager(mgr); err != nil {
-		klog.Error(err, "unable to setup the crdreplicator-operator")
+		klog.Error(err, "unable to setup the crdReplicator controller")
 		os.Exit(1)
 	}
 
-	klog.Info("Starting crdreplicator-operator")
+	klog.Info("Starting crdReplicator manager")
 	if err := mgr.Start(ctx); err != nil {
-		klog.Error(err, "problem running manager")
+		klog.Error(err, "unable to start the crdReplicator manager")
 		os.Exit(1)
 	}
 }

internal/crdReplicator/crdReplicator-operator.go

@@ -45,8 +45,7 @@ import (
 )
 
 const (
-	operatorName = "crdReplicator-operator"
-	finalizer    = "crdreplicator.liqo.io/operator"
+	finalizer = "crdreplicator.liqo.io/operator"
 )
 
 // Controller reconciles identity Secrets to start/stop the reflection of registered resources to remote clusters.
@@ -188,10 +187,9 @@ func (c *Controller) SetupWithManager(mgr ctrl.Manager) error {
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
-		Named(operatorName).
-		WithEventFilter(resourceToBeProccesedPredicate).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlSecretsCRDReplicator).
 		For(&corev1.Secret{}, builder.WithPredicates(secretsFilter)).
+		WithEventFilter(resourceToBeProccesedPredicate).
 		Complete(c)
 }
 

pkg/consts/controllers.go

@@ -0,0 +1,80 @@
+// Copyright 2019-2024 The Liqo Authors
+//
+// 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 consts
+
+// Constants used to name and identify controllers.
+// Controller-runtime requires that each controller has a unique name within the container.
+// This name is used, for example, to identify a controller univocally in the logs
+// and must be a prometheus compatible name (underscores and alphanumeric characters only).
+// As a convention to avoid conflicts, we use the name of the reconciled resource (lowercase version of their kind),
+// and, if already used, we add a recognizable identifier, separated by the underscore character.
+// To catch duplicated names, we name the constant as its value (in CamelCase and stripping the separator character),
+// with the prefix "Ctrl".
+const (
+	// Core.
+	CtrlForeignCluster       = "foreigncluster"
+	CtrlSecretsCRDReplicator = "secrets_crdreplicator"
+
+	// Networking.
+	CtrlConfigurationExternal  = "configuration_external"
+	CtrlConfigurationInternal  = "configuration_internal"
+	CtrlConfigurationIPMapping = "configuration_ipmapping"
+	CtrlConfigurationRemapping = "configuration_remapping"
+	CtrlConfigurationRoute     = "configuration_route"
+	CtrlConnections            = "connections"
+	CtrlFirewallConfiguration  = "firewallconfiguration"
+	CtrlGatewayClientExternal  = "gatewayclient_external"
+	CtrlGatewayClientInternal  = "gatewayclient_internal"
+	CtrlGatewayServerExternal  = "gatewayserver_external"
+	CtrlGatewayServerInternal  = "gatewayserver_internal"
+	CtrlInternalFabricsCM      = "internalfabrics_cm"
+	CtrlInternalFabricsFabric  = "internalfabrics_fabric"
+	CtrlInternalNodeGeneve     = "internalnode_geneve"
+	CtrlInternalNodeRoute      = "internalnode_route"
+	CtrlIP                     = "ip"
+	CtrlIPRemapping            = "ip_remapping"
+	CtrlNetwork                = "network"
+	CtrlNode                   = "node"
+	CtrlPodGateway             = "pod_gateway"
+	CtrlPodGwMasq              = "pod_gw_masq"
+	CtrlPodInternalNet         = "pod_internalnet"
+	CtrlPodIPMapping           = "pod_ipmapping"
+	CtrlPulicKeys              = "publickeys"
+	CtrlRouteConfiguration     = "routeconfiguration"
+	CtrlWGGatewayClient        = "wggatewayclient"
+	CtrlWGGatewayServer        = "wggatewayserver"
+
+	// Authentication.
+	CtrlIdentity             = "identity"
+	CtrlIdentityCreator      = "identity_creator"
+	CtrlNonceCreator         = "nonce_creator"
+	CtrlNonceSigner          = "nonce_signer"
+	CtrlResourceSlicesLocal  = "resourceslices_local"
+	CtrlResourceSlicesRemote = "resourceslices_remote"
+	CtrlTenant               = "tenant"
+
+	// Offloading.
+	CtrlNamespaceMap        = "namespace_map"
+	CtrlNamespaceOffloading = "namespaceoffloading"
+	CtrlNodeFailure         = "node_failure"
+	CtrlPodStatus           = "pod_status"
+	CtrlShadowEndpointSlice = "shadowendpointslice"
+	CtrlShadowPods          = "shadowpods"
+	CtrlVirtualNode         = "virtualnode"
+	CtrlVirtualNodeCreator  = "virtualnode_creator"
+
+	// Cross modules.
+	CtrlResourceSlicesQuotaCreator = "resourceslices_quotacreator"
+)

pkg/fabric/internalfabric_controller.go

@@ -28,6 +28,7 @@ import (
 	ctrlutil "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 
 	networkingv1beta1 "github.com/liqotech/liqo/apis/networking/v1beta1"
+	"github.com/liqotech/liqo/pkg/consts"
 	"github.com/liqotech/liqo/pkg/utils/network/geneve"
 )
 
@@ -126,7 +127,7 @@ func (r *InternalFabricReconciler) Reconcile(ctx context.Context, req ctrl.Reque
 
 // SetupWithManager register the InternalFabricReconciler to the manager.
 func (r *InternalFabricReconciler) SetupWithManager(mgr ctrl.Manager) error {
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlInternalFabricsFabric).
 		For(&networkingv1beta1.InternalFabric{}).
 		Complete(r)
 }

pkg/fabric/source-detector/gateway_controller.go

@@ -32,6 +32,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
 
 	networkingv1beta1 "github.com/liqotech/liqo/apis/networking/v1beta1"
+	"github.com/liqotech/liqo/pkg/consts"
 	"github.com/liqotech/liqo/pkg/fabric"
 	"github.com/liqotech/liqo/pkg/gateway"
 )
@@ -115,7 +116,7 @@ func (r *GatewayReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlPodGateway).
 		For(&corev1.Pod{}, builder.WithPredicates(filterByLabelsGatewayPods)).
 		Complete(r)
 }

pkg/firewall/firewallconfiguration_controller.go

@@ -35,6 +35,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
 
 	networkingv1beta1 "github.com/liqotech/liqo/apis/networking/v1beta1"
+	"github.com/liqotech/liqo/pkg/consts"
 	"github.com/liqotech/liqo/pkg/utils/network/netmonitor"
 )
 
@@ -172,7 +173,7 @@ func (r *FirewallConfigurationReconciler) SetupWithManager(ctx context.Context,
 	go func() {
 		utilruntime.Must(netmonitor.InterfacesMonitoring(ctx, src, &netmonitor.Options{Nftables: &netmonitor.OptionsNftables{Delete: true}}))
 	}()
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlFirewallConfiguration).
 		For(&networkingv1beta1.FirewallConfiguration{}, builder.WithPredicates(filterByLabelsPredicate)).
 		WatchesRawSource(NewFirewallWatchSource(src, NewFirewallWatchEventHandler(r.Client, r.LabelsSets))).
 		Complete(r)

pkg/gateway/connection/connections_controller.go

@@ -117,7 +117,7 @@ func (r *ConnectionsReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	if err != nil {
 		return err
 	}
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlConnections).
 		For(&networkingv1beta1.Connection{}, builder.WithPredicates(filterByLabelsPredicate)).
 		Complete(r)
 }

pkg/gateway/fabric/geneve/internalnode_controller.go

@@ -28,6 +28,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	networkingv1beta1 "github.com/liqotech/liqo/apis/networking/v1beta1"
+	"github.com/liqotech/liqo/pkg/consts"
 	"github.com/liqotech/liqo/pkg/gateway/fabric"
 	"github.com/liqotech/liqo/pkg/utils/network/geneve"
 )
@@ -116,7 +117,7 @@ func (r *InternalNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request
 
 // SetupWithManager register the InternalNodeReconciler to the manager.
 func (r *InternalNodeReconciler) SetupWithManager(mgr ctrl.Manager) error {
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlInternalNodeGeneve).
 		For(&networkingv1beta1.InternalNode{}).
 		Complete(r)
 }

pkg/gateway/tunnel/wireguard/publickeys_controller.go

@@ -88,7 +88,7 @@ func (r *PublicKeysReconciler) Reconcile(ctx context.Context, req ctrl.Request)
 
 // SetupWithManager register the ConfigurationReconciler to the manager.
 func (r *PublicKeysReconciler) SetupWithManager(mgr ctrl.Manager, src <-chan event.GenericEvent) error {
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlPulicKeys).
 		For(&networkingv1beta1.PublicKey{}, r.Predicates()).
 		WatchesRawSource(NewDNSSource(src, NewDNSEventHandler(r.Client, r.Options))).
 		Complete(r)

pkg/liqo-controller-manager/authentication/identity-controller/identity_controller.go

@@ -28,6 +28,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 
 	authv1beta1 "github.com/liqotech/liqo/apis/authentication/v1beta1"
+	"github.com/liqotech/liqo/pkg/consts"
 	"github.com/liqotech/liqo/pkg/liqo-controller-manager/authentication"
 	"github.com/liqotech/liqo/pkg/liqo-controller-manager/authentication/forge"
 )
@@ -88,7 +89,7 @@ func (r *IdentityReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *IdentityReconciler) SetupWithManager(mgr ctrl.Manager) error {
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlIdentity).
 		For(&authv1beta1.Identity{}).
 		Owns(&corev1.Secret{}).
 		Complete(r)

pkg/liqo-controller-manager/authentication/identitycreator-controller/identitycreator_controller.go

@@ -135,7 +135,7 @@ func (r *IdentityCreatorReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlIdentityCreator).
 		For(&authv1beta1.ResourceSlice{}, builder.WithPredicates(predicate.And(localResSliceFilter, withAuthCondition()))).
 		Owns(&authv1beta1.Identity{}).
 		Complete(r)

pkg/liqo-controller-manager/authentication/localresourceslice-controller/localresourceslice_controller.go

@@ -36,9 +36,6 @@ import (
 	tenantnamespace "github.com/liqotech/liqo/pkg/tenantNamespace"
 )
 
-// ControllerName is the name of the controller.
-const ControllerName = "localResourceSlice"
-
 // NewLocalResourceSliceReconciler returns a new LocalResourceSliceReconciler.
 func NewLocalResourceSliceReconciler(cl client.Client, s *runtime.Scheme,
 	recorder record.EventRecorder, liqoNamespace string,
@@ -120,7 +117,7 @@ func (r *LocalResourceSliceReconciler) Reconcile(ctx context.Context, req ctrl.R
 		return ctrl.Result{}, err
 	}
 
-	if resourceSlice.Spec.CSR == nil || len(resourceSlice.Spec.CSR) == 0 {
+	if len(resourceSlice.Spec.CSR) == 0 {
 		// Generate a CSR for the remote cluster.
 		CSR, err := authentication.GenerateCSRForResourceSlice(privateKey, &resourceSlice)
 		if err != nil {
@@ -153,7 +150,7 @@ func (r *LocalResourceSliceReconciler) SetupWithManager(mgr ctrl.Manager) error
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).Named(ControllerName).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlResourceSlicesLocal).
 		For(&authv1beta1.ResourceSlice{}, builder.WithPredicates(localResSliceFilter)).
 		Complete(r)
 }

pkg/liqo-controller-manager/authentication/noncecreator-controller/noncecreator_controller.go

@@ -148,7 +148,7 @@ func (r *NonceCreatorReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return selector.Matches(labels.Set(o.GetLabels()))
 	})
 
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlNonceCreator).
 		For(&corev1.Secret{}, builder.WithPredicates(filter)).
 		Complete(r)
 }

pkg/liqo-controller-manager/authentication/noncesigner-controller/noncesigner_controller.go

@@ -37,11 +37,6 @@ import (
 	"github.com/liqotech/liqo/pkg/utils"
 )
 
-const (
-	// ControllerName is the name of the controller.
-	ControllerName = "nonceSigner"
-)
-
 // NewNonceSignerReconciler returns a new SecretReconciler.
 func NewNonceSignerReconciler(cl client.Client, s *runtime.Scheme,
 	recorder record.EventRecorder,
@@ -153,7 +148,7 @@ func (r *NonceSignerReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return selector.Matches(labels.Set(o.GetLabels()))
 	})
 
-	return ctrl.NewControllerManagedBy(mgr).Named(ControllerName).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlNonceSigner).
 		For(&corev1.Secret{}, builder.WithPredicates(filter)).
 		Complete(r)
 }

pkg/liqo-controller-manager/authentication/remoteresourceslice-controller/remoteresourceslice_controller.go

@@ -36,15 +36,13 @@ import (
 
 	authv1beta1 "github.com/liqotech/liqo/apis/authentication/v1beta1"
 	"github.com/liqotech/liqo/internal/crdReplicator/reflection"
+	"github.com/liqotech/liqo/pkg/consts"
 	identitymanager "github.com/liqotech/liqo/pkg/identityManager"
 	"github.com/liqotech/liqo/pkg/liqo-controller-manager/authentication"
 	"github.com/liqotech/liqo/pkg/utils/getters"
 	liqolabels "github.com/liqotech/liqo/pkg/utils/labels"
 )
 
-// ControllerName is the name of the controller.
-const ControllerName = "remoteResourceSlice"
-
 // NewRemoteResourceSliceReconciler returns a new RemoteResourceSliceReconciler.
 func NewRemoteResourceSliceReconciler(cl client.Client, s *runtime.Scheme, config *rest.Config,
 	recorder record.EventRecorder,
@@ -258,7 +256,7 @@ func (r *RemoteResourceSliceReconciler) SetupWithManager(mgr ctrl.Manager) error
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).Named(ControllerName).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlResourceSlicesRemote).
 		For(&authv1beta1.ResourceSlice{}, builder.WithPredicates(predicate.And(remoteResSliceFilter, withCSR()))).
 		Watches(&authv1beta1.Tenant{}, handler.EnqueueRequestsFromMapFunc(r.resourceSlicesEnquer())).
 		Complete(r)
@@ -301,7 +299,7 @@ func withCSR() predicate.Funcs {
 		if !ok {
 			return false
 		}
-		return rs.Spec.CSR != nil && len(rs.Spec.CSR) > 0
+		return len(rs.Spec.CSR) > 0
 	})
 }
 

pkg/liqo-controller-manager/authentication/tenant-controller/tenant_controller.go

@@ -269,7 +269,7 @@ func (r *TenantReconciler) ensureSetup(ctx context.Context) error {
 
 // SetupWithManager sets up the TenantReconciler with the Manager.
 func (r *TenantReconciler) SetupWithManager(mgr ctrl.Manager) error {
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlTenant).
 		For(&authv1beta1.Tenant{}).
 		Owns(&corev1.Namespace{}).
 		Complete(r)

pkg/liqo-controller-manager/foreigncluster-controller/foreigncluster_controller.go

@@ -168,7 +168,7 @@ func (r *ForeignClusterReconciler) SetupWithManager(mgr ctrl.Manager, workers in
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlForeignCluster).
 		For(&liqov1beta1.ForeignCluster{}, builder.WithPredicates(foreignClusterPredicate)).
 		Watches(&networkingv1beta1.Connection{}, handler.EnqueueRequestsFromMapFunc(r.foreignclusterEnqueuer)).
 		Watches(&networkingv1beta1.GatewayServer{}, handler.EnqueueRequestsFromMapFunc(r.foreignclusterEnqueuer)).

pkg/liqo-controller-manager/ipmapping/configuration_controller.go

@@ -36,9 +36,6 @@ import (
 	configuration "github.com/liqotech/liqo/pkg/liqo-controller-manager/networking/external-network/configuration"
 )
 
-// ConfigurationControllerName is the name of the controller.
-const ConfigurationControllerName = "IpMappingConfiguration"
-
 // cluster-role
 // +kubebuilder:rbac:groups=networking.liqo.io,resources=configurations,verbs=get;list;watch
 // +kubebuilder:rbac:groups=ipam.liqo.io,resources=ips,verbs=get;list;watch;create;update;patch;delete
@@ -98,7 +95,7 @@ func (r *ConfigurationReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	if err != nil {
 		return err
 	}
-	return ctrl.NewControllerManagedBy(mgr).Named(ConfigurationControllerName).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlConfigurationIPMapping).
 		For(&networkingv1beta1.Configuration{}, builder.WithPredicates(filterByLabelsPredicate)).
 		Complete(r)
 }

pkg/liqo-controller-manager/ipmapping/pod_controller.go

@@ -33,11 +33,6 @@ import (
 	"github.com/liqotech/liqo/pkg/consts"
 )
 
-const (
-	// PodControllerName is the name of the controller.
-	PodControllerName = "IPMappingPod"
-)
-
 // OffloadedPodReconciler manage offloaded pods lifecycle.
 type OffloadedPodReconciler struct {
 	client.Client
@@ -93,7 +88,7 @@ func (r *OffloadedPodReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	if err != nil {
 		return fmt.Errorf("unable to create predicate: %w", err)
 	}
-	return ctrl.NewControllerManagedBy(mgr).Named(PodControllerName).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlPodIPMapping).
 		For(&corev1.Pod{}, builder.WithPredicates(p)).
 		Complete(r)
 }

pkg/liqo-controller-manager/networking/external-network/client-operator/client_controller.go

@@ -267,7 +267,7 @@ func (r *ClientReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		factorySource.ForResource(gvr)
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
+	return ctrl.NewControllerManagedBy(mgr).Named(consts.CtrlGatewayClientExternal).
 		WatchesRawSource(factorySource.Source(ownerEnqueuer)).
 		For(&networkingv1beta1.GatewayClient{}).
 		Complete(r)