wip of running e2e tests locally 5

Author: nawazkh

test/e2e/azure_apiserver_ilb.go

@@ -88,6 +88,7 @@ import (
 	"bytes"
 	"context"
 	"fmt"
+	"io"
 	"os"
 	"os/exec"
 	"strings"
@@ -465,8 +466,6 @@ func AzureAPIServerILBSpec(ctx context.Context, inputGetter func() AzureAPIServe
 }
 
 func PeerVnets(ctx context.Context, inputGetter func() AzureAPIServerILBSpecInput) {
-	// TODO: shall I have this shell commands in this func instead ?
-	Logf("In PeerVnets func")
 	var (
 		specName = "azure-apiserver-ilb"
 		input    AzureAPIServerILBSpecInput
@@ -483,15 +482,24 @@ func PeerVnets(ctx context.Context, inputGetter func() AzureAPIServerILBSpecInpu
 	peer_command := "CLUSTER_NAME=" + input.ClusterName + " source " + peer_vnets_script + " && peer_vnets"
 	cmd := exec.Command("sh", "-c", peer_command)
 	Logf("cmd to be run %v", cmd)
-	output, err := cmd.Output()
 
+	// ------------------------ //
+	// output, err := cmd.Output()
+	// if err != nil {
+	// 	Logf("Error running peer-vnets.sh: %v", err)
+	// }
+	// Logf("Output of peer-vnets.sh: %v", string(output))
+
+	/*
+		// Replace the below block with the above block when debugging the peering VNets script
+		// The below code suppresses the StdOut and StdErr
+	*/
+
+	cmd.Stdout = io.Discard
+	cmd.Stderr = io.Discard
+	err := cmd.Run()
 	if err != nil {
 		Logf("Error running peer-vnets.sh: %v", err)
-		Logf("Output: %v", string(output))
-		Logf("Error: %v", err)
 	}
-	Expect(err).NotTo(HaveOccurred())
-
-	fmt.Println(string(output))
-
+	// ------------------------ //
 }

test/e2e/azure_test.go

@@ -1265,5 +1265,64 @@ var _ = Describe("Workload cluster creation", func() {
 		})
 	})
 
+	Context("Local test: Creating a self-managed VM based cluster using API Server ILB feature gate and fully spec-ed out APIServer ILB template [OPTIONAL][API-Server-ILB][LOCAL]", func() {
+		It("with three controlplane node and three worker nodes", func() {
+			clusterName = getClusterName(clusterNamePrefix, "apiserver-ilb")
+
+			// Set the environment variables required for the API Server ILB feature gate
+			Expect(os.Setenv("EXP_APISERVER_ILB", "true")).To(Succeed())
+			Expect(os.Setenv("AZURE_INTERNAL_LB_PRIVATE_IP", "40.0.0.100")).To(Succeed())
+			Expect(os.Setenv("AZURE_VNET_CIDR", "40.0.0.0/8")).To(Succeed())
+			Expect(os.Setenv("AZURE_CP_SUBNET_CIDR", "40.0.0.0/16")).To(Succeed())
+			Expect(os.Setenv("AZURE_NODE_SUBNET_CIDR", "40.1.0.0/16")).To(Succeed())
+
+			clusterctl.ApplyClusterTemplateAndWait(ctx, createApplyClusterTemplateInput(
+				specName,
+				withFlavor("apiserver-ilb"),
+				withNamespace(namespace.Name),
+				withClusterName(clusterName),
+				withControlPlaneMachineCount(3),
+				withWorkerMachineCount(2),
+				withControlPlaneInterval(specName, "wait-control-plane-ha"),
+				withControlPlaneWaiters(clusterctl.ControlPlaneWaiters{
+					WaitForControlPlaneInitialized: EnsureControlPlaneInitializedNoAddons,
+				}),
+				withPostMachinesProvisioned(func() {
+					PeerVnets(ctx, func() AzureAPIServerILBSpecInput {
+						return AzureAPIServerILBSpecInput{
+							BootstrapClusterProxy:                   bootstrapClusterProxy,
+							Cluster:                                 result.Cluster,
+							Namespace:                               namespace,
+							ClusterName:                             clusterName,
+							WaitIntervals:                           e2eConfig.GetIntervals(specName, "wait-worker-nodes"),
+							TemplateHasPrivateIPCustomDNSResolution: true,
+						}
+					})
+				}),
+				// withPreWaitForCluster(func() {
+				// 	// TODO: only invoke this in local runs
+				// 	// Peer VNets of the mgmt cluster and workload cluster
+				//
+				// }),
+			), result)
+
+			By("Probing workload cluster with APIServerILB feature gate", func() {
+				AzureAPIServerILBSpec(ctx, func() AzureAPIServerILBSpecInput {
+					return AzureAPIServerILBSpecInput{
+						BootstrapClusterProxy:                   bootstrapClusterProxy,
+						Cluster:                                 result.Cluster,
+						Namespace:                               namespace,
+						ClusterName:                             clusterName,
+						ExpectedWorkerNodes:                     result.ExpectedWorkerNodes(),
+						WaitIntervals:                           e2eConfig.GetIntervals(specName, "wait-worker-nodes"),
+						TemplateHasPrivateIPCustomDNSResolution: true,
+					}
+				})
+			})
+
+			By("PASSED!")
+		})
+	})
+
 	// TODO: add a same test as above for a windows cluster
 })