From 0f6b62488c7e09280d8c0682087cf5ba3781f8eb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BA=84=E6=B6=A6=E6=A2=93?= <528185299@qq.com>
Date: Mon, 1 Jul 2024 18:48:55 +0800
Subject: [PATCH] test

---
 tests/e2e/greptimedbcluster_test.go | 25 ++++++++++++-------------
 1 file changed, 12 insertions(+), 13 deletions(-)

diff --git a/tests/e2e/greptimedbcluster_test.go b/tests/e2e/greptimedbcluster_test.go
index 31df8bde..c373249f 100644
--- a/tests/e2e/greptimedbcluster_test.go
+++ b/tests/e2e/greptimedbcluster_test.go
@@ -27,6 +27,7 @@ import (
 	"github.com/go-sql-driver/mysql"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
+	"k8s.io/klog/v2"
 )
 
 const (
@@ -65,7 +66,7 @@ type TestData struct {
 var _ = Describe("Basic test of greptimedb cluster", Ordered, func() {
 	It("Bootstrap cluster", func() {
 		var err error
-		//		sig := true
+		sig := true
 		err = createCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to create cluster")
 
@@ -74,11 +75,11 @@ var _ = Describe("Basic test of greptimedb cluster", Ordered, func() {
 
 		err = listCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to list cluster")
-		/*
-			go func() {
-				forwardRequest(sig)
-			}()
-		*/
+
+		go func() {
+			forwardRequest(&sig)
+		}()
+
 		By("Connecting GreptimeDB")
 		var db *sql.DB
 		var conn *sql.Conn
@@ -86,7 +87,7 @@ var _ = Describe("Basic test of greptimedb cluster", Ordered, func() {
 		Eventually(func() error {
 			cfg := mysql.Config{
 				Net:                  "tcp",
-				Addr:                 "127.0.0.1:4005",
+				Addr:                 "127.0.0.1:4002",
 				User:                 "",
 				Passwd:               "",
 				DBName:               "",
@@ -139,7 +140,7 @@ var _ = Describe("Basic test of greptimedb cluster", Ordered, func() {
 		err = deleteCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to delete cluster")
 
-		//		sig = false
+		sig = false
 	})
 })
 
@@ -183,11 +184,10 @@ func deleteCluster() error {
 	return nil
 }
 
-/*
-func forwardRequest(sig bool) {
+func forwardRequest(sig *bool) {
 	for {
-		if sig {
-			cmd := exec.Command("kubectl", "port-forward", "svc/mydb-frontend", "4002:4005")
+		if *sig {
+			cmd := exec.Command("kubectl", "port-forward", "svc/mydb-frontend", "4002:4002")
 			if err := cmd.Run(); err != nil {
 				klog.Errorf("Failed to port forward: %v", err)
 				return
@@ -197,4 +197,3 @@ func forwardRequest(sig bool) {
 		}
 	}
 }
-*/