fix3

tests/e2e/greptimedbcluster_test.go

@@ -72,6 +72,12 @@ var _ = Describe("Basic test of greptimedb cluster", func() {
 		err = getCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to get cluster")
 
+		err = createClusterinBaremetal()
+		Expect(err).NotTo(HaveOccurred(), "failed to create cluster in baremetal")
+
+		err = getClusterinBaremetal()
+		Expect(err).NotTo(HaveOccurred(), "failed to get cluster in baremetal")
+
 		err = listCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to list cluster")
 
@@ -138,6 +144,9 @@ var _ = Describe("Basic test of greptimedb cluster", func() {
 
 		err = deleteCluster()
 		Expect(err).NotTo(HaveOccurred(), "failed to delete cluster")
+
+		err = deleteClusterinBaremetal()
+		Expect(err).NotTo(HaveOccurred(), "failed to delete cluster in baremetal")
 	})
 })
 
@@ -151,6 +160,16 @@ func createCluster() error {
 	return nil
 }
 
+func createClusterinBaremetal() error {
+	cmd := exec.Command("../../bin/gtctl", "cluster", "create", "mydb", "--timeout", "300", "--bare-metal")
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	if err := cmd.Run(); err != nil {
+		return err
+	}
+	return nil
+}
+
 func getCluster() error {
 	cmd := exec.Command("../../bin/gtctl", "cluster", "get", "mydb")
 	cmd.Stdout = os.Stdout
@@ -161,6 +180,16 @@ func getCluster() error {
 	return nil
 }
 
+func getClusterinBaremetal() error {
+	cmd := exec.Command("../../bin/gtctl", "cluster", "get", "mydb", "--bare-metal")
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	if err := cmd.Run(); err != nil {
+		return err
+	}
+	return nil
+}
+
 func listCluster() error {
 	cmd := exec.Command("../../bin/gtctl", "cluster", "list")
 	cmd.Stdout = os.Stdout
@@ -181,6 +210,16 @@ func deleteCluster() error {
 	return nil
 }
 
+func deleteClusterinBaremetal() error {
+	cmd := exec.Command("../../bin/gtctl", "cluster", "delete", "mydb", "--tear-down-etcd", "--bare-metal")
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	if err := cmd.Run(); err != nil {
+		return err
+	}
+	return nil
+}
+
 func forwardRequest() {
 	for {
 		cmd := exec.Command("kubectl", "port-forward", "svc/mydb-frontend", "4002:4002")