From ad124e60d96d93a56607b066f98e2c99996c0284 Mon Sep 17 00:00:00 2001 From: Alan Amoyel Date: Tue, 25 Apr 2023 18:52:55 +0200 Subject: [PATCH] Revert "feat: add condition to controlPlaneServiceTemplate in KubevirtCluster CRD to deploy LB service in namespace provided in metadata" This reverts commit ed152f9daed5f119b1662c2017e59d4ba121189d. --- api/v1alpha1/kubevirtcluster_types.go | 3 +-- controllers/kubevirtcluster_controller.go | 12 +--------- .../kubevirtcluster_controller_test.go | 23 ------------------- pkg/testing/common.go | 23 ------------------- 4 files changed, 2 insertions(+), 59 deletions(-) diff --git a/api/v1alpha1/kubevirtcluster_types.go b/api/v1alpha1/kubevirtcluster_types.go index e327b530..c07f0701 100644 --- a/api/v1alpha1/kubevirtcluster_types.go +++ b/api/v1alpha1/kubevirtcluster_types.go @@ -103,8 +103,7 @@ type SSHKeys struct { // ControlPlaneServiceTemplate describes the template for the control plane service. type ControlPlaneServiceTemplate struct { - // Service metadata allows to set labels, annotations and namespace for the service. - // When infraClusterSecretRef is used, ControlPlaneService take the kubeconfig namespace by default if metadata.namespace is not specified. + // Service metadata allows to set labels and annotations for the service. // This field is optional. // +kubebuilder:pruning:PreserveUnknownFields // +nullable diff --git a/controllers/kubevirtcluster_controller.go b/controllers/kubevirtcluster_controller.go index a4c43885..10ba5f3a 100644 --- a/controllers/kubevirtcluster_controller.go +++ b/controllers/kubevirtcluster_controller.go @@ -54,14 +54,6 @@ type KubevirtClusterReconciler struct { Log logr.Logger } -func GetLoadBalancerNamespace(kc *infrav1.KubevirtCluster, infraClusterNamespace string ) string { - // Use namespace specified in Service Template if exist - if kc.Spec.ControlPlaneServiceTemplate.ObjectMeta.Namespace != "" { - return kc.Spec.ControlPlaneServiceTemplate.ObjectMeta.Namespace - } - return infraClusterNamespace -} - // +kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=kubevirtclusters,verbs=get;list;watch;create;update;patch;delete // +kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=kubevirtclusters/status,verbs=get;update;patch // +kubebuilder:rbac:groups="",resources=services;,verbs=get;list;watch;create;update;patch;delete @@ -115,10 +107,8 @@ func (r *KubevirtClusterReconciler) Reconcile(goctx gocontext.Context, req ctrl. return ctrl.Result{RequeueAfter: 10 * time.Second}, nil } - loadBalancerNamespace := GetLoadBalancerNamespace(kubevirtCluster, infraClusterNamespace) - // Create a helper for managing a service hosting the load-balancer. - externalLoadBalancer, err := loadbalancer.NewLoadBalancer(clusterContext, infraClusterClient, loadBalancerNamespace) + externalLoadBalancer, err := loadbalancer.NewLoadBalancer(clusterContext, infraClusterClient, infraClusterNamespace) if err != nil { return ctrl.Result{}, errors.Wrapf(err, "failed to create helper for managing the externalLoadBalancer") } diff --git a/controllers/kubevirtcluster_controller_test.go b/controllers/kubevirtcluster_controller_test.go index a16dcc0d..11b5066f 100644 --- a/controllers/kubevirtcluster_controller_test.go +++ b/controllers/kubevirtcluster_controller_test.go @@ -25,7 +25,6 @@ var ( clusterName string kubevirtClusterName string kubevirtCluster *infrav1.KubevirtCluster - kubeconfigNamespace string cluster *clusterv1.Cluster fakeClient client.Client kubevirtClusterReconciler controllers.KubevirtClusterReconciler @@ -176,26 +175,4 @@ var _ = Describe("Reconcile", func() { Expect(err).Should(HaveOccurred()) }) }) - - Context("Compute Control Plane LB service namespace values precedence before it's created", func() { - BeforeEach(func() { - clusterName = "test-cluster" - kubevirtClusterName = "test-kubevirt-cluster" - kubeconfigNamespace = "kubeconfig-namespace" - cluster = testing.NewCluster(kubevirtClusterName, kubevirtCluster) - }) - - AfterEach(func() {}) - - It("should use provided LB namespace if its set", func() { - kubevirtCluster = testing.NewKubevirtClusterWithNamespacedLB(kubevirtClusterName, kubevirtClusterName, "lb-namespace") - ns := controllers.GetLoadBalancerNamespace(kubevirtCluster, kubeconfigNamespace) - Expect(ns).To(Equal("lb-namespace")) - }) - It("should use kubeconfig namespace if LB namespace is not set", func() { - kubevirtCluster = testing.NewKubevirtClusterWithNamespacedLB(kubevirtClusterName, kubevirtClusterName, "") - ns := controllers.GetLoadBalancerNamespace(kubevirtCluster, kubeconfigNamespace) - Expect(ns).To(Equal(kubeconfigNamespace)) - }) - }) }) diff --git a/pkg/testing/common.go b/pkg/testing/common.go index fe53b138..572cc623 100644 --- a/pkg/testing/common.go +++ b/pkg/testing/common.go @@ -46,29 +46,6 @@ func NewKubevirtCluster(clusterName, kubevirtName string) *infrav1.KubevirtClust } } -func NewKubevirtClusterWithNamespacedLB(clusterName, kubevirtName string, lbNamespace string) *infrav1.KubevirtCluster { - return &infrav1.KubevirtCluster{ - TypeMeta: metav1.TypeMeta{}, - ObjectMeta: metav1.ObjectMeta{ - Name: kubevirtName, - OwnerReferences: []metav1.OwnerReference{ - { - APIVersion: clusterv1.GroupVersion.String(), - Kind: "Cluster", - Name: clusterName, - }, - }, - }, - Spec: infrav1.KubevirtClusterSpec { - ControlPlaneServiceTemplate: infrav1.ControlPlaneServiceTemplate{ - ObjectMeta: metav1.ObjectMeta { - Namespace: lbNamespace, - }, - }, - }, - } -} - func NewKubevirtMachine(kubevirtMachineName, machineName string) *infrav1.KubevirtMachine { return &infrav1.KubevirtMachine{ TypeMeta: metav1.TypeMeta{},