e2e

Author: amuraru

tests/e2e/test_istio_kafka_cluster.go

@@ -56,17 +56,85 @@ func testValidateIstioResources() bool {
 			gomega.Expect(err).NotTo(gomega.HaveOccurred())
 		})
 
+		ginkgo.It("Checking Kafka cluster status", func() {
+			// Check if the Kafka cluster exists and is ready
+			clusterStatus, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "kafkaclusters.kafka.banzaicloud.io", "kafka", "-o", "jsonpath={.status.state}")
+			if err != nil {
+				ginkgo.By(fmt.Sprintf("Error getting Kafka cluster status: %v", err))
+			} else {
+				ginkgo.By(fmt.Sprintf("Kafka cluster status: %s", clusterStatus))
+			}
+
+			// Check if the Kafka cluster has external listeners configured
+			externalListeners, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "kafkaclusters.kafka.banzaicloud.io", "kafka", "-o", "jsonpath={.spec.listenersConfig.externalListeners}")
+			if err != nil {
+				ginkgo.By(fmt.Sprintf("Error getting external listeners: %v", err))
+			} else {
+				ginkgo.By(fmt.Sprintf("External listeners: %s", externalListeners))
+			}
+
+			// Check the ingress controller setting
+			ingressController, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "kafkaclusters.kafka.banzaicloud.io", "kafka", "-o", "jsonpath={.spec.ingressController}")
+			if err != nil {
+				ginkgo.By(fmt.Sprintf("Error getting ingress controller: %v", err))
+			} else {
+				ginkgo.By(fmt.Sprintf("Ingress controller: %s", ingressController))
+			}
+		})
+
+		ginkgo.It("Checking Istio ingress gateway status", func() {
+			// Check if the standard Istio ingress gateway is running
+			gatewayPods, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "pods", "--all-namespaces", "-l", "app=istio-ingressgateway", "-o", "jsonpath={.items[*].status.phase}")
+			if err != nil {
+				ginkgo.By(fmt.Sprintf("Error getting Istio ingress gateway pods: %v", err))
+			} else {
+				ginkgo.By(fmt.Sprintf("Istio ingress gateway pod statuses: %s", gatewayPods))
+			}
+
+			// Check if there are any Istio Gateway resources at all (including system ones)
+			allGateways, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "gateways.networking.istio.io", "--all-namespaces", "-o", "name")
+			if err != nil {
+				ginkgo.By(fmt.Sprintf("Error getting all Gateway resources: %v", err))
+			} else {
+				ginkgo.By(fmt.Sprintf("All Istio Gateway resources: %s", allGateways))
+			}
+		})
+
 		ginkgo.It("Validating Istio Gateway resources", func() {
-			// Check for Istio Gateway resources
-			gateways, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "gateways.networking.istio.io", "--all-namespaces", "-o", "name")
+			// Check for Istio Gateway resources with retry logic
+			var gateways string
+			var err error
+
+			// Wait up to 2 minutes for Gateway resources to be created
+			for i := 0; i < 24; i++ {
+				gateways, err = k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "gateways.networking.istio.io", "--all-namespaces", "-o", "name")
+				if err == nil && gateways != "" {
+					break
+				}
+				ginkgo.By(fmt.Sprintf("Waiting for Istio Gateway resources... (attempt %d/24)", i+1))
+				time.Sleep(5 * time.Second)
+			}
+
 			gomega.Expect(err).NotTo(gomega.HaveOccurred())
 			gomega.Expect(gateways).NotTo(gomega.BeEmpty())
 			ginkgo.By(fmt.Sprintf("Found Istio Gateways: %s", gateways))
 		})
 
 		ginkgo.It("Validating Istio VirtualService resources", func() {
-			// Check for Istio VirtualService resources
-			virtualServices, err := k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "virtualservices.networking.istio.io", "--all-namespaces", "-o", "name")
+			// Check for Istio VirtualService resources with retry logic
+			var virtualServices string
+			var err error
+
+			// Wait up to 2 minutes for VirtualService resources to be created
+			for i := 0; i < 24; i++ {
+				virtualServices, err = k8s.RunKubectlAndGetOutputE(ginkgo.GinkgoT(), &kubectlOptions, "get", "virtualservices.networking.istio.io", "--all-namespaces", "-o", "name")
+				if err == nil && virtualServices != "" {
+					break
+				}
+				ginkgo.By(fmt.Sprintf("Waiting for Istio VirtualService resources... (attempt %d/24)", i+1))
+				time.Sleep(5 * time.Second)
+			}
+
 			gomega.Expect(err).NotTo(gomega.HaveOccurred())
 			gomega.Expect(virtualServices).NotTo(gomega.BeEmpty())
 			ginkgo.By(fmt.Sprintf("Found Istio VirtualServices: %s", virtualServices))