-
Notifications
You must be signed in to change notification settings - Fork 15
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add foreground deletion and refactor deployer for cluster in ba…
…re-metal mode (#106) * refactor bare-metal deployer and add foreground delete for it Signed-off-by: sh2 <[email protected]> * add timeout for bare-metal mode deployment Signed-off-by: sh2 <[email protected]> * optimize msg of foreground deletion and add ctx for download process Signed-off-by: sh2 <[email protected]> * refactor: update some naming nits Signed-off-by: sh2 <[email protected]> * refactor: aggregate some commonly used dirs Signed-off-by: sh2 <[email protected]> --------- Signed-off-by: sh2 <[email protected]>
- Loading branch information
Showing
16 changed files
with
966 additions
and
459 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,120 @@ | ||
| // Copyright 2023 Greptime Team | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package component | ||
|
|
||
| import ( | ||
| "bufio" | ||
| "context" | ||
| "os" | ||
| "os/exec" | ||
| "path" | ||
| "strconv" | ||
| "sync" | ||
| "syscall" | ||
|
|
||
| "github.com/GreptimeTeam/gtctl/pkg/deployer/baremetal/config" | ||
| "github.com/GreptimeTeam/gtctl/pkg/logger" | ||
| ) | ||
|
|
||
| // WorkDirs include all the dirs used in bare-metal mode. | ||
| type WorkDirs struct { | ||
| DataDir string | ||
| LogsDir string | ||
| PidsDir string | ||
| } | ||
|
|
||
| // BareMetalCluster describes all the components need to be deployed under bare-metal mode. | ||
| type BareMetalCluster struct { | ||
| MetaSrv BareMetalClusterComponent | ||
| Datanode BareMetalClusterComponent | ||
| Frontend BareMetalClusterComponent | ||
| Etcd BareMetalClusterComponent | ||
| } | ||
|
|
||
| // BareMetalClusterComponent is the basic unit of running GreptimeDB Cluster in bare-metal mode. | ||
| type BareMetalClusterComponent interface { | ||
| // Start starts cluster component by executing binary. | ||
| Start(ctx context.Context, binary string) error | ||
|
|
||
| // BuildArgs build up args for cluster component. | ||
| BuildArgs(ctx context.Context, params ...interface{}) []string | ||
|
|
||
| // IsRunning returns the status of current cluster component. | ||
| IsRunning(ctx context.Context) bool | ||
|
|
||
| // Delete deletes resources that allocated in the system for current component. | ||
| Delete(ctx context.Context) error | ||
| } | ||
|
|
||
| func NewGreptimeDBCluster(config *config.Cluster, workDirs WorkDirs, wg *sync.WaitGroup, logger logger.Logger) *BareMetalCluster { | ||
| return &BareMetalCluster{ | ||
| MetaSrv: newMetaSrv(config.MetaSrv, workDirs, wg, logger), | ||
| Datanode: newDataNodes(config.Datanode, config.MetaSrv.ServerAddr, workDirs, wg, logger), | ||
| Frontend: newFrontend(config.Frontend, config.MetaSrv.ServerAddr, workDirs, wg, logger), | ||
| Etcd: newEtcd(workDirs, wg, logger), | ||
| } | ||
| } | ||
|
|
||
| func runBinary(ctx context.Context, binary string, args []string, logDir string, pidDir string, | ||
| wg *sync.WaitGroup, logger logger.Logger) error { | ||
| cmd := exec.CommandContext(ctx, binary, args...) | ||
|
|
||
| // output to binary. | ||
| logFile := path.Join(logDir, "log") | ||
| outputFile, err := os.Create(logFile) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| outputFileWriter := bufio.NewWriter(outputFile) | ||
| cmd.Stdout = outputFileWriter | ||
| cmd.Stderr = outputFileWriter | ||
|
|
||
| logger.V(3).Infof("run binary '%s' with args: '%v', log: '%s', pid: '%s'", binary, args, logDir, pidDir) | ||
|
|
||
| if err := cmd.Start(); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| pidFile := path.Join(pidDir, "pid") | ||
| f, err := os.Create(pidFile) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| _, err = f.Write([]byte(strconv.Itoa(cmd.Process.Pid))) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| go func() { | ||
| defer wg.Done() | ||
| wg.Add(1) | ||
| if err := cmd.Wait(); err != nil { | ||
| // Caught signal kill and interrupt error then ignore. | ||
| if exit, ok := err.(*exec.ExitError); ok { | ||
| if status, ok := exit.Sys().(syscall.WaitStatus); ok { | ||
| if status.Signaled() && | ||
| (status.Signal() == syscall.SIGKILL || status.Signal() == syscall.SIGINT) { | ||
| return | ||
| } | ||
| } | ||
| } | ||
| logger.Errorf("binary '%s' exited with error: %v", binary, err) | ||
| } | ||
| }() | ||
|
|
||
| return nil | ||
| } |
Oops, something went wrong.