test: set control plane ip for nutanix e2e tests

Author: supershal

.github/workflows/e2e.yml

@@ -64,6 +64,7 @@ jobs:
             ${{ runner.os }}-go-
 
       - name: Login to Internal Container Registry
+        if: inputs.focus == 'Self-hosted'
         uses: docker/login-action@v3
         with:
           registry: ${{ secrets.LOCAL_IMAGE_REGISTRY }}
@@ -101,7 +102,7 @@ jobs:
           NUTANIX_MACHINE_TEMPLATE_IMAGE_NAME: ${{ inputs.os-image }}
           KINDEST_IMAGE_TAG: ${{ inputs.kubernetes-version }}
           E2E_KUBERNETES_VERSION: ${{ inputs.kubernetes-version }}
-          LOCAL_IMAGE_REGISTRY: ${{ secrets.LOCAL_IMAGE_REGISTRY }}
+          LOCAL_IMAGE_REGISTRY: ${{ inputs.focus == 'Self-hosted' && secrets.LOCAL_IMAGE_REGISTRY || 'ko.local' }}
 
       - if: success() || failure() # always run even if the previous step fails
         name: Publish e2e test report

test/e2e/framework/self_hosted.go

@@ -28,6 +28,8 @@ import (
 	"sigs.k8s.io/cluster-api/test/framework/clusterctl"
 	"sigs.k8s.io/cluster-api/util"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/test/e2e/framework/nutanix"
 )
 
 // SelfHostedSpecInput is the input for SelfHostedSpec.
@@ -180,6 +182,30 @@ func SelfHostedSpec(ctx context.Context, inputGetter func() SelfHostedSpecInput)
 		if input.InfrastructureProvider != nil {
 			infrastructureProvider = *input.InfrastructureProvider
 		}
+
+		// For Nutanix provider, reserve an IP address for the workload cluster control plane endpoint -
+		// remember to unreserve it!
+		if infrastructureProvider == "nutanix" {
+			By(
+				"Reserving an IP address for the workload cluster control plane endpoint",
+			)
+			nutanixClient, err := nutanix.NewV4Client(
+				nutanix.CredentialsFromCAPIE2EConfig(input.E2EConfig),
+			)
+			Expect(err).ToNot(HaveOccurred())
+			//nolint:contextcheck // ReserverIP function does not accept context. Its okay to ignore the context check in tests.
+			controlPlaneEndpointIP, unreserveControlPlaneEndpointIP, err := nutanix.ReserveIP(
+				input.E2EConfig.GetVariable("NUTANIX_SUBNET_NAME"),
+				input.E2EConfig.GetVariable(
+					"NUTANIX_PRISM_ELEMENT_CLUSTER_NAME",
+				),
+				nutanixClient,
+			)
+			Expect(err).ToNot(HaveOccurred())
+			DeferCleanup(unreserveControlPlaneEndpointIP)
+			clusterctlVariables["CONTROL_PLANE_ENDPOINT_IP"] = controlPlaneEndpointIP
+		}
+
 		clusterctl.ApplyClusterTemplateAndWait(ctx, clusterctl.ApplyClusterTemplateAndWaitInput{
 			ClusterProxy: input.BootstrapClusterProxy,
 			ConfigCluster: clusterctl.ConfigClusterInput{