fix: create new context for bare-metal deployer (#148)

* create new context for bare-metal deployer

Signed-off-by: sh2 <shawnhxh@outlook.com>

* rm the useless stop func

Signed-off-by: sh2 <shawnhxh@outlook.com>

---------

Signed-off-by: sh2 <shawnhxh@outlook.com>

Author: shawnh2

pkg/cmd/gtctl/cluster/create/create.go

@@ -128,7 +128,7 @@ func NewCluster(args []string, options ClusterCliOptions, l logger.Logger) error
 		ctx, cancel = context.WithTimeout(ctx, time.Duration(options.Timeout)*time.Second)
 		defer cancel()
 	}
-	ctx, stop := signal.NotifyContext(ctx, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
+	ctx, stop := signal.NotifyContext(ctx, syscall.SIGINT, syscall.SIGTERM)
 	defer stop()
 
 	clusterDeployer, err := newDeployer(l, clusterName, &options)

pkg/deployer/baremetal/deployer.go

@@ -19,9 +19,11 @@ import (
 	"fmt"
 	"os"
 	"os/exec"
+	"os/signal"
 	"path"
 	"strings"
 	"sync"
+	"syscall"
 	"time"
 
 	"gopkg.in/yaml.v3"
@@ -39,6 +41,7 @@ type Deployer struct {
 	am     *ArtifactManager
 	wg     sync.WaitGroup
 	bm     *component.BareMetalCluster
+	ctx    context.Context
 
 	createNoDirs      bool
 	workingDirs       component.WorkingDirs
@@ -54,9 +57,12 @@ var _ Interface = &Deployer{}
 type Option func(*Deployer)
 
 func NewDeployer(l logger.Logger, clusterName string, opts ...Option) (Interface, error) {
+	ctx, _ := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+
 	d := &Deployer{
 		logger: l,
 		config: config.DefaultConfig(),
+		ctx:    ctx,
 	}
 
 	for _, opt := range opts {
@@ -258,15 +264,15 @@ func (d *Deployer) CreateGreptimeDBCluster(ctx context.Context, clusterName stri
 		return err
 	}
 
-	if err := d.bm.MetaSrv.Start(ctx, binary); err != nil {
+	if err := d.bm.MetaSrv.Start(d.ctx, binary); err != nil {
 		return err
 	}
 
-	if err := d.bm.Datanode.Start(ctx, binary); err != nil {
+	if err := d.bm.Datanode.Start(d.ctx, binary); err != nil {
 		return err
 	}
 
-	if err := d.bm.Frontend.Start(ctx, binary); err != nil {
+	if err := d.bm.Frontend.Start(d.ctx, binary); err != nil {
 		return err
 	}
 
@@ -318,7 +324,7 @@ func (d *Deployer) CreateEtcdCluster(ctx context.Context, clusterName string, op
 		return err
 	}
 
-	if err = d.bm.Etcd.Start(ctx, bin); err != nil {
+	if err = d.bm.Etcd.Start(d.ctx, bin); err != nil {
 		return err
 	}
 
@@ -392,7 +398,7 @@ func (d *Deployer) Wait(ctx context.Context, option component.DeleteOptions) err
 
 	d.logger.V(3).Info("Cluster shutting down. Cleaning allocated resources.")
 
-	<-ctx.Done()
+	<-d.ctx.Done()
 	// Delete cluster after closing, which can only happens in the foreground.
 	if err := d.deleteGreptimeDBClusterForeground(ctx, option); err != nil {
 		return err