clusterapi v1beta2 api changes

gainsley · gainsley · commit 3be05b0c0989 · 2025-11-19T10:48:31.000-08:00
diff --git a/api/v1alpha1/kamajicontrolplane_types.go b/api/v1alpha1/kamajicontrolplane_types.go
@@ -8,7 +8,7 @@ import (
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	capiv1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	capiv1beta2 "sigs.k8s.io/cluster-api/api/core/v1beta2"
 )
 
 // ControlPlaneComponent allows the customization for the given component of the control plane.
@@ -105,7 +105,7 @@ type CoreDNSAddonSpec struct {
 type KamajiControlPlaneSpec struct {
 	KamajiControlPlaneFields `json:",inline"`
 	// ControlPlaneEndpoint propagates the endpoint the Kubernetes API Server managed by Kamaji is located.
-	ControlPlaneEndpoint capiv1beta1.APIEndpoint `json:"controlPlaneEndpoint,omitempty"`
+	ControlPlaneEndpoint capiv1beta2.APIEndpoint `json:"controlPlaneEndpoint,omitempty"`
 	// Number of desired replicas for the given TenantControlPlane.
 	// Defaults to 2.
 	// +kubebuilder:default=2
diff --git a/api/v1alpha1/kamajicontrolplanetemplate_types.go b/api/v1alpha1/kamajicontrolplanetemplate_types.go
@@ -5,7 +5,7 @@ package v1alpha1
 
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	clusterv1 "sigs.k8s.io/cluster-api/api/core/v1beta1"
 )
 
 // KamajiControlPlaneTemplateSpec defines the desired state of KamajiControlPlaneTemplate.
diff --git a/config/control-plane-components.yaml b/config/control-plane-components.yaml
@@ -493,18 +493,19 @@ spec:
                 type: object
               controlPlaneEndpoint:
                 description: ControlPlaneEndpoint propagates the endpoint the Kubernetes API Server managed by Kamaji is located.
+                minProperties: 1
                 properties:
                   host:
                     description: host is the hostname on which the API server is serving.
                     maxLength: 512
+                    minLength: 1
                     type: string
                   port:
                     description: port is the port on which the API server is serving.
                     format: int32
+                    maximum: 65535
+                    minimum: 1
                     type: integer
-                required:
-                - host
-                - port
                 type: object
               controllerManager:
                 description: ControlPlaneComponent allows the customization for the given component of the control plane.
@@ -14093,6 +14094,14 @@ rules:
   - patch
   - update
   - watch
+- apiGroups:
+  - apiextensions.k8s.io
+  resources:
+  - customresourcedefinitions
+  verbs:
+  - get
+  - list
+  - watch
 - apiGroups:
   - cluster.x-k8s.io
   resources:
diff --git a/config/crd/bases/controlplane.cluster.x-k8s.io_kamajicontrolplanes.yaml b/config/crd/bases/controlplane.cluster.x-k8s.io_kamajicontrolplanes.yaml
@@ -493,18 +493,19 @@ spec:
               controlPlaneEndpoint:
                 description: ControlPlaneEndpoint propagates the endpoint the Kubernetes
                   API Server managed by Kamaji is located.
+                minProperties: 1
                 properties:
                   host:
                     description: host is the hostname on which the API server is serving.
                     maxLength: 512
+                    minLength: 1
                     type: string
                   port:
                     description: port is the port on which the API server is serving.
                     format: int32
+                    maximum: 65535
+                    minimum: 1
                     type: integer
-                required:
-                - host
-                - port
                 type: object
               controllerManager:
                 description: ControlPlaneComponent allows the customization for the
diff --git a/config/rbac/role.yaml b/config/rbac/role.yaml
@@ -15,6 +15,14 @@ rules:
   - patch
   - update
   - watch
+- apiGroups:
+  - apiextensions.k8s.io
+  resources:
+  - customresourcedefinitions
+  verbs:
+  - get
+  - list
+  - watch
 - apiGroups:
   - cluster.x-k8s.io
   resources:
diff --git a/controllers/kamajicontrolplane_controller.go b/controllers/kamajicontrolplane_controller.go
@@ -18,8 +18,9 @@ import (
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/util/retry"
 	"k8s.io/component-base/featuregate"
-	capiv1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	capiv1beta2 "sigs.k8s.io/cluster-api/api/core/v1beta2"
 	"sigs.k8s.io/cluster-api/util/annotations"
+	conditionsapi "sigs.k8s.io/cluster-api/util/conditions"
 	"sigs.k8s.io/cluster-api/util/predicates"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/builder"
@@ -80,18 +81,18 @@ func (r *KamajiControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.R
 	}
 
 	// Retrieving the Cluster information
-	cluster := capiv1beta1.Cluster{}
+	cluster := capiv1beta2.Cluster{}
 	cluster.SetName(kcp.GetOwnerReferences()[0].Name)
 	cluster.SetNamespace(kcp.GetNamespace())
 
 	if err = r.client.Get(ctx, types.NamespacedName{Name: cluster.Name, Namespace: cluster.Namespace}, &cluster); err != nil {
 		if errors.IsNotFound(err) {
-			log.Info("capiv1beta1.Cluster resource may have been deleted, withdrawing reconciliation")
+			log.Info("capiv1beta2.Cluster resource may have been deleted, withdrawing reconciliation")
 
 			return ctrl.Result{}, nil
 		}
 
-		log.Error(err, "unable to get capiv1beta1.Cluster")
+		log.Error(err, "unable to get capiv1beta2.Cluster")
 
 		return ctrl.Result{}, err //nolint:wrapcheck
 	}
@@ -199,12 +200,12 @@ func (r *KamajiControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.R
 	// check that happens latter will never succeed.
 	if err = r.client.Get(ctx, types.NamespacedName{Name: cluster.Name, Namespace: cluster.Namespace}, &cluster); err != nil {
 		if errors.IsNotFound(err) {
-			log.Info("capiv1beta1.Cluster resource may have been deleted, withdrawing reconciliation")
+			log.Info("capiv1beta2.Cluster resource may have been deleted, withdrawing reconciliation")
 
 			return ctrl.Result{}, nil
 		}
 
-		log.Error(err, "unable to get capiv1beta1.Cluster")
+		log.Error(err, "unable to get capiv1beta2.Cluster")
 
 		return ctrl.Result{}, err //nolint:wrapcheck
 	}
@@ -221,7 +222,7 @@ func (r *KamajiControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.R
 		})
 
 		if err != nil {
-			log.Error(err, "cannot patch capiv1beta1.Cluster")
+			log.Error(err, "cannot patch capiv1beta2.Cluster")
 
 			return ctrl.Result{}, err
 		}
@@ -231,13 +232,13 @@ func (r *KamajiControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.R
 	// 1. an assigned Control Plane endpoint
 	// 2. a ready infrastructure
 	if len(cluster.Spec.ControlPlaneEndpoint.Host) == 0 {
-		log.Info("capiv1beta1.Cluster Control Plane endpoint still unprocessed, enqueuing back")
+		log.Info("capiv1beta2.Cluster Control Plane endpoint still unprocessed, enqueuing back")
 
 		return ctrl.Result{RequeueAfter: time.Second}, nil
 	}
 
-	if !cluster.Status.InfrastructureReady {
-		log.Info("capiv1beta1.Cluster infrastructure is not yet ready, enqueuing back")
+	if conditionsapi.IsFalse(&cluster, capiv1beta2.InfrastructureReadyCondition) {
+		log.Info("capiv1beta2.Cluster infrastructure is not yet ready, enqueuing back")
 
 		return ctrl.Result{RequeueAfter: time.Second}, nil
 	}
diff --git a/controllers/kamajicontrolplane_controller_cluster_patch.go b/controllers/kamajicontrolplane_controller_cluster_patch.go
@@ -12,9 +12,9 @@ import (
 
 	"github.com/pkg/errors"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
-	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/util/retry"
-	capiv1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	capiv1beta2 "sigs.k8s.io/cluster-api/api/core/v1beta2"
+	"sigs.k8s.io/cluster-api/controllers/external"
 	"sigs.k8s.io/cluster-api/util/patch"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
@@ -60,7 +60,7 @@ func (r *KamajiControlPlaneReconciler) patchControlPlaneEndpoint(ctx context.Con
 			return errors.Wrap(scopedErr, "cannot retrieve *v1alpha1.KamajiControlPlane")
 		}
 
-		controlPlane.Spec.ControlPlaneEndpoint = capiv1beta1.APIEndpoint{
+		controlPlane.Spec.ControlPlaneEndpoint = capiv1beta2.APIEndpoint{
 			Host: endpoint,
 			Port: int32(port), //nolint:gosec
 		}
@@ -73,10 +73,12 @@ func (r *KamajiControlPlaneReconciler) patchControlPlaneEndpoint(ctx context.Con
 	return nil
 }
 
+//+kubebuilder:rbac:groups=apiextensions.k8s.io,resources=customresourcedefinitions,verbs=get;list;watch
+
 //nolint:cyclop
-func (r *KamajiControlPlaneReconciler) patchCluster(ctx context.Context, cluster capiv1beta1.Cluster, controlPlane *v1alpha1.KamajiControlPlane, hostPort string) error {
-	if cluster.Spec.InfrastructureRef == nil {
-		return errors.New("capiv1beta1.Cluster has no InfrastructureRef")
+func (r *KamajiControlPlaneReconciler) patchCluster(ctx context.Context, cluster capiv1beta2.Cluster, controlPlane *v1alpha1.KamajiControlPlane, hostPort string) error {
+	if !cluster.Spec.InfrastructureRef.IsDefined() {
+		return errors.New("capiv1beta2.Cluster has no InfrastructureRef")
 	}
 
 	endpoint, port, err := r.controlPlaneEndpoint(controlPlane, hostPort)
@@ -121,7 +123,7 @@ func (r *KamajiControlPlaneReconciler) patchCluster(ctx context.Context, cluster
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=proxmoxclusters;vsphereclusters;tinkerbellclusters,verbs=get;list;watch
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=proxmoxclusters;vsphereclusters;tinkerbellclusters,verbs=patch
 
-func (r *KamajiControlPlaneReconciler) checkOrPatchGenericCluster(ctx context.Context, cluster capiv1beta1.Cluster, endpoint string, port int64) error {
+func (r *KamajiControlPlaneReconciler) checkOrPatchGenericCluster(ctx context.Context, cluster capiv1beta2.Cluster, endpoint string, port int64) error {
 	if err := r.checkGenericCluster(ctx, cluster, endpoint, port); err != nil {
 		if errors.As(err, &UnmanagedControlPlaneAddressError{}) {
 			return r.patchGenericCluster(ctx, cluster, endpoint, port, false)
@@ -136,18 +138,13 @@ func (r *KamajiControlPlaneReconciler) checkOrPatchGenericCluster(ctx context.Co
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=awsclusters;azureclusters;hetznerclusters;kubevirtclusters;nutanixclusters;packetclusters;ionoscloudclusters,verbs=patch;get;list;watch
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=kubevirtclusters/status;nutanixclusters/status;packetclusters/status,verbs=patch
 
-func (r *KamajiControlPlaneReconciler) patchGenericCluster(ctx context.Context, cluster capiv1beta1.Cluster, endpoint string, port int64, patchStatus bool) error {
-	infraCluster := unstructured.Unstructured{}
-
-	infraCluster.SetGroupVersionKind(cluster.Spec.InfrastructureRef.GroupVersionKind())
-	infraCluster.SetName(cluster.Spec.InfrastructureRef.Name)
-	infraCluster.SetNamespace(cluster.Spec.InfrastructureRef.Namespace)
-
-	if err := r.client.Get(ctx, types.NamespacedName{Name: infraCluster.GetName(), Namespace: infraCluster.GetNamespace()}, &infraCluster); err != nil {
-		return errors.Wrap(err, fmt.Sprintf("cannot retrieve the %s resource", infraCluster.GetKind()))
+func (r *KamajiControlPlaneReconciler) patchGenericCluster(ctx context.Context, cluster capiv1beta2.Cluster, endpoint string, port int64, patchStatus bool) error {
+	infraCluster, err := external.GetObjectFromContractVersionedRef(ctx, r.client, cluster.Spec.InfrastructureRef, cluster.GetNamespace())
+	if err != nil {
+		return errors.Wrap(err, fmt.Sprintf("cannot get infrastructure reference %s", cluster.Spec.InfrastructureRef.Name))
 	}
 
-	patchHelper, err := patch.NewHelper(&infraCluster, r.client)
+	patchHelper, err := patch.NewHelper(infraCluster, r.client)
 	if err != nil {
 		return errors.Wrap(err, "unable to create patch helper")
 	}
@@ -165,7 +162,7 @@ func (r *KamajiControlPlaneReconciler) patchGenericCluster(ctx context.Context,
 		}
 	}
 
-	if err = patchHelper.Patch(ctx, &infraCluster); err != nil {
+	if err = patchHelper.Patch(ctx, infraCluster); err != nil {
 		return errors.Wrap(err, fmt.Sprintf("cannot perform PATCH update for the %s resource", infraCluster.GetKind()))
 	}
 
@@ -174,15 +171,10 @@ func (r *KamajiControlPlaneReconciler) patchGenericCluster(ctx context.Context,
 
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=metal3clusters,verbs=get;list;watch
 
-func (r *KamajiControlPlaneReconciler) checkGenericCluster(ctx context.Context, cluster capiv1beta1.Cluster, endpoint string, port int64) error {
-	gkc := unstructured.Unstructured{}
-
-	gkc.SetGroupVersionKind(cluster.Spec.InfrastructureRef.GroupVersionKind())
-	gkc.SetName(cluster.Spec.InfrastructureRef.Name)
-	gkc.SetNamespace(cluster.Spec.InfrastructureRef.Namespace)
-
-	if err := r.client.Get(ctx, types.NamespacedName{Name: gkc.GetName(), Namespace: gkc.GetNamespace()}, &gkc); err != nil {
-		return errors.Wrap(err, fmt.Sprintf("cannot retrieve the %s resource", gkc.GetKind()))
+func (r *KamajiControlPlaneReconciler) checkGenericCluster(ctx context.Context, cluster capiv1beta2.Cluster, endpoint string, port int64) error {
+	gkc, err := external.GetObjectFromContractVersionedRef(ctx, r.client, cluster.Spec.InfrastructureRef, cluster.GetNamespace())
+	if err != nil {
+		return errors.Wrap(err, fmt.Sprintf("cannot get infrastructure reference %s", cluster.Spec.InfrastructureRef.Name))
 	}
 
 	cpHost, _, err := unstructured.NestedString(gkc.Object, "spec", "controlPlaneEndpoint", "host")
@@ -204,30 +196,25 @@ func (r *KamajiControlPlaneReconciler) checkGenericCluster(ctx context.Context,
 	}
 
 	if cpHost != endpoint {
-		return fmt.Errorf("the %s cluster has been provisioned with a mismatching host", gkc.GetKind())
+		return fmt.Errorf("the %s cluster has been provisioned with a mismatching host %s instead of %s", gkc.GetKind(), cpHost, endpoint)
 	}
 
 	if cpPort != port {
-		return fmt.Errorf("the %s cluster has been provisioned with a mismatching port", gkc.GetKind())
+		return fmt.Errorf("the %s cluster has been provisioned with a mismatching port %d instead of %d", gkc.GetKind(), cpPort, port)
 	}
 
 	return nil
 }
 
 //+kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=openstackclusters,verbs=patch;get;list;watch
 
-func (r *KamajiControlPlaneReconciler) patchOpenStackCluster(ctx context.Context, cluster capiv1beta1.Cluster, endpoint string, port int64) error {
-	osc := unstructured.Unstructured{}
-
-	osc.SetGroupVersionKind(cluster.Spec.InfrastructureRef.GroupVersionKind())
-	osc.SetName(cluster.Spec.InfrastructureRef.Name)
-	osc.SetNamespace(cluster.Spec.InfrastructureRef.Namespace)
-
-	if err := r.client.Get(ctx, types.NamespacedName{Name: osc.GetName(), Namespace: osc.GetNamespace()}, &osc); err != nil {
-		return errors.Wrap(err, fmt.Sprintf("cannot retrieve the %s resource", osc.GetKind()))
+func (r *KamajiControlPlaneReconciler) patchOpenStackCluster(ctx context.Context, cluster capiv1beta2.Cluster, endpoint string, port int64) error {
+	osc, err := external.GetObjectFromContractVersionedRef(ctx, r.client, cluster.Spec.InfrastructureRef, cluster.GetNamespace())
+	if err != nil {
+		return errors.Wrap(err, fmt.Sprintf("cannot get infrastructure reference %s", cluster.Spec.InfrastructureRef.Name))
 	}
 
-	patchHelper, err := patch.NewHelper(&osc, r.client)
+	patchHelper, err := patch.NewHelper(osc, r.client)
 	if err != nil {
 		return errors.Wrap(err, "unable to create patch helper")
 	}
@@ -240,7 +227,7 @@ func (r *KamajiControlPlaneReconciler) patchOpenStackCluster(ctx context.Context
 		return errors.Wrap(err, fmt.Sprintf("unable to set unstructured %s spec apiServerPort", osc.GetKind()))
 	}
 
-	if err = patchHelper.Patch(ctx, &osc); err != nil {
+	if err = patchHelper.Patch(ctx, osc); err != nil {
 		return errors.Wrap(err, "cannot perform PATCH update for the OpenStackCluster resource")
 	}
 
diff --git a/controllers/kamajicontrolplane_controller_resources.go b/controllers/kamajicontrolplane_controller_resources.go
@@ -12,7 +12,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/util/retry"
-	capiv1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	capiv1beta2 "sigs.k8s.io/cluster-api/api/core/v1beta2"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	ctrllog "sigs.k8s.io/controller-runtime/pkg/log"
@@ -24,7 +24,7 @@ var ErrEnqueueBack = errors.New("enqueue back")
 
 //+kubebuilder:rbac:groups="",resources="secrets",verbs=get;list;watch;create;update;patch
 
-func (r *KamajiControlPlaneReconciler) createRequiredResources(ctx context.Context, remoteClient client.Client, cluster capiv1beta1.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
+func (r *KamajiControlPlaneReconciler) createRequiredResources(ctx context.Context, remoteClient client.Client, cluster capiv1beta2.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
 	log := ctrllog.FromContext(ctx)
 	// Creating a kubeconfig secret for the workload cluster.
 	if secretName := tcp.Status.KubeConfig.Admin.SecretName; len(secretName) == 0 {
@@ -64,7 +64,7 @@ func (r *KamajiControlPlaneReconciler) createRequiredResources(ctx context.Conte
 // also in regard to the naming conventions according to the Cluster API contracts about Kubeconfig.
 //
 // more info: https://cluster-api.sigs.k8s.io/developer/architecture/controllers/cluster.html#secrets
-func (r *KamajiControlPlaneReconciler) createOrUpdateCertificateAuthority(ctx context.Context, reader client.Client, cluster capiv1beta1.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
+func (r *KamajiControlPlaneReconciler) createOrUpdateCertificateAuthority(ctx context.Context, reader client.Client, cluster capiv1beta2.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
 	capiCA := &corev1.Secret{}
 	capiCA.Name = cluster.Name + "-ca"
 	capiCA.Namespace = cluster.Namespace
@@ -99,7 +99,7 @@ func (r *KamajiControlPlaneReconciler) createOrUpdateCertificateAuthority(ctx co
 				labels = map[string]string{}
 			}
 
-			labels[capiv1beta1.ClusterNameLabel] = cluster.Name
+			labels[capiv1beta2.ClusterNameLabel] = cluster.Name
 			labels["kamaji.clastix.io/component"] = "capi"
 			labels["kamaji.clastix.io/secret"] = "ca"
 			labels["kamaji.clastix.io/cluster"] = cluster.Name
@@ -111,7 +111,7 @@ func (r *KamajiControlPlaneReconciler) createOrUpdateCertificateAuthority(ctx co
 				corev1.TLSCertKey:       crt,
 				corev1.TLSPrivateKeyKey: key,
 			}
-			capiCA.Type = capiv1beta1.ClusterSecretType
+			capiCA.Type = capiv1beta2.ClusterSecretType
 
 			return controllerutil.SetControllerReference(&kcp, capiCA, r.client.Scheme())
 		})
@@ -129,7 +129,7 @@ func (r *KamajiControlPlaneReconciler) createOrUpdateCertificateAuthority(ctx co
 // also in regard to the naming conventions according to the Cluster API contracts about kubeconfig.
 //
 // more info: https://cluster-api.sigs.k8s.io/developer/architecture/controllers/cluster.html#secrets
-func (r *KamajiControlPlaneReconciler) createOrUpdateKubeconfig(ctx context.Context, reader client.Client, cluster capiv1beta1.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
+func (r *KamajiControlPlaneReconciler) createOrUpdateKubeconfig(ctx context.Context, reader client.Client, cluster capiv1beta2.Cluster, kcp v1alpha1.KamajiControlPlane, tcp *kamajiv1alpha1.TenantControlPlane) error {
 	capiAdminKubeconfig := &corev1.Secret{}
 	capiAdminKubeconfig.Name = cluster.Name + "-kubeconfig"
 	capiAdminKubeconfig.Namespace = cluster.Namespace
@@ -149,7 +149,7 @@ func (r *KamajiControlPlaneReconciler) createOrUpdateKubeconfig(ctx context.Cont
 				labels = map[string]string{}
 			}
 
-			labels[capiv1beta1.ClusterNameLabel] = cluster.Name
+			labels[capiv1beta2.ClusterNameLabel] = cluster.Name
 			labels["kamaji.clastix.io/component"] = "capi"
 			labels["kamaji.clastix.io/secret"] = "kubeconfig"
 			labels["kamaji.clastix.io/cluster"] = cluster.Name
@@ -170,7 +170,7 @@ func (r *KamajiControlPlaneReconciler) createOrUpdateKubeconfig(ctx context.Cont
 			capiAdminKubeconfig.Data = map[string][]byte{
 				"value": value,
 			}
-			capiAdminKubeconfig.Type = capiv1beta1.ClusterSecretType
+			capiAdminKubeconfig.Type = capiv1beta2.ClusterSecretType
 
 			return controllerutil.SetControllerReference(&kcp, capiAdminKubeconfig, r.client.Scheme())
 		})
diff --git a/controllers/kamajicontrolplane_controller_tcp.go b/controllers/kamajicontrolplane_controller_tcp.go
diff --git a/go.mod b/go.mod
diff --git a/go.sum b/go.sum
diff --git a/main.go b/main.go

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ package v1alpha1`
`5`	`5`
`6`	`6`	`import (`
`7`	`7`	`metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"`
`8`		`- clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"`
	`8`	`+ clusterv1 "sigs.k8s.io/cluster-api/api/core/v1beta1"`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`// KamajiControlPlaneTemplateSpec defines the desired state of KamajiControlPlaneTemplate.`