Add integration test

Signed-off-by: Lubron Zhan <[email protected]>

Author: lubronzhan

controllers/cluster/cluster_intg_test.go

@@ -23,7 +23,6 @@ import (
 )
 
 func intgTestEnsureClusterHAProvider() {
-
 	Context("EnsureHAService", func() {
 		var (
 			ctx           *builder.IntegrationTestContext
@@ -104,7 +103,6 @@ func intgTestEnsureClusterHAProvider() {
 						Name:      serviceName,
 						Namespace: ctx.Namespace,
 					}, &corev1.Endpoints{}, testutil.EXIST)
-
 				})
 			})
 
@@ -143,9 +141,22 @@ func intgTestEnsureClusterHAProvider() {
 					err := ctx.Client.Get(ctx, client.ObjectKey{Name: serviceName, Namespace: ctx.Namespace}, service)
 					Expect(err).ShouldNot(HaveOccurred())
 					Expect(service.Annotations[akoov1alpha1.AkoPreferredIPAnnotation]).Should(Equal("10.1.2.1"))
+					// make sure the service has ip as ingress, not fqdn
+					Consistently(func() bool {
+						err := ctx.Client.Get(ctx, client.ObjectKey{Name: serviceName, Namespace: ctx.Namespace}, service)
+						if err != nil {
+							return false
+						}
+						if len(service.Status.LoadBalancer.Ingress) < 0 {
+							return false
+						}
+						if service.Status.LoadBalancer.Ingress[0].IP != "10.1.2.1" {
+							return false
+						}
+						return true
+					}, "30s").Should(BeTrue())
 				})
 			})
 		})
-
 	})
 }

pkg/test/util/utils.go

@@ -128,7 +128,7 @@ func EnsureClusterAviLabelMatchExpectation(ctx *builder.IntegrationTestContext,
 
 func UpdateObjectLabels(ctx *builder.IntegrationTestContext, key client.ObjectKey, labels map[string]string) {
 	Eventually(func() error {
-		var cluster = new(clusterv1.Cluster)
+		cluster := new(clusterv1.Cluster)
 
 		if err := ctx.Client.Get(ctx, client.ObjectKey{
 			Name:      key.Name,