feat:Add baremetal cluster e2e test

pkg/cluster/baremetal/create.go

@@ -52,7 +52,7 @@ func (c *Cluster) Create(ctx context.Context, options *opt.CreateOptions) error
  return nil
  }
 
- if c.useMemoryMeta {
+ if !c.useMemoryMeta {
  if err := withSpinner("Etcd Cluster", c.createEtcdCluster); err != nil {
  return err
  }

tests/e2e/greptimedbcluster_test.go

@@ -75,6 +75,21 @@ var _ = Describe("Basic test of greptimedb cluster", func() {
  err = listCluster()
  Expect(err).NotTo(HaveOccurred(), "failed to list cluster")
 
+ go func() {
+ err = createClusterinBaremetal()
+ Expect(err).NotTo(HaveOccurred(), "failed to create cluster in baremetal")
+ }()
+
+ go func() {
+ time.Sleep(100 * time.Second)
+
+ err = getClusterinBaremetal()
+ Expect(err).NotTo(HaveOccurred(), "failed to get cluster in baremetal")
+
+ err = deleteClusterinBaremetal()
+ Expect(err).NotTo(HaveOccurred(), "failed to delete cluster in baremetal")
+ }()
+
  go func() {
  forwardRequest()
  }()
@@ -151,6 +166,16 @@ func createCluster() error {
  return nil
 }
 
+func createClusterinBaremetal() error {
+ cmd := exec.Command("../../bin/gtctl", "cluster", "create", "mydb", "--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 +186,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 +216,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")