diff --git a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/clean_data.go b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/clean_data.go new file mode 100644 index 0000000000..7f6474ba30 --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/clean_data.go @@ -0,0 +1,98 @@ +package vmcmd + +import ( + "encoding/json" + "fmt" + + "dbm-services/bigdata/db-tools/dbactuator/internal/subcmd" + "dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util" + "dbm-services/common/go-pubpkg/logger" + + "github.com/spf13/cobra" +) + +// CleanDataAct 是一个结构体,用于清理VictoriaMetrics的数据目录。 +type CleanDataAct struct { + *subcmd.BaseOptions // BaseOptions 是基础选项,可能包含了一些全局设置或配置。 + Service victoriametrics.CleanDataComp // Service 是用于清理数据的组件。 +} + +// CleanDataCommand 是一个函数,返回一个cobra.Command对象,该对象定义了一个命令行命令,用于清理VictoriaMetrics的数据目录。 +func CleanDataCommand() *cobra.Command { + act := CleanDataAct{ + BaseOptions: subcmd.GBaseOptions, + } + cmd := &cobra.Command{ + Use: "clean_data", + Short: "清理vm目录", + Example: fmt.Sprintf(`dbactuator vm clean_data %s`, subcmd.CmdBaseExapmleStr), + Run: func(cmd *cobra.Command, args []string) { + util.CheckErr(act.Validate()) // 验证参数 + if act.RollBack { // 如果需要回滚,则执行回滚操作 + util.CheckErr(act.Rollback()) + return + } + util.CheckErr(act.Init()) // 初始化 + util.CheckErr(act.Run()) // 运行 + }, + } + return cmd +} + +// Validate 是 CleanDataAct 的验证函数,用于验证参数是否有效。 +func (d *CleanDataAct) Validate() (err error) { + return d.BaseOptions.Validate() +} + +// Init 是 CleanDataAct 的初始化函数,用于初始化操作。 +func (d *CleanDataAct) Init() (err error) { + logger.Info("CleanDataAct Init") + if err = d.Deserialize(&d.Service.Params); err != nil { // 反序列化参数 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + d.Service.GeneralParam = subcmd.GeneralRuntimeParam // 设置通用运行时参数 + return d.Service.Init() // 初始化服务 +} + +// Rollback TODO +// +// @receiver d +// @return err +func (d *CleanDataAct) Rollback() (err error) { + var r rollback.RollBackObjects + if err = d.DeserializeAndValidate(&r); err != nil { + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + err = r.RollBack() + if err != nil { + logger.Error("roll back failed %s", err.Error()) + } + return +} + +// Run 是 CleanDataAct 的运行函数,用于执行清理VictoriaMetrics数据目录的操作。 +func (d *CleanDataAct) Run() (err error) { + steps := subcmd.Steps{ + { + FunName: "清理数据目录", + Func: d.Service.CleanData, // 清理数据的函数 + }, + } + + if err := steps.Run(); err != nil { // 执行步骤 + rollbackCtxb, rerr := json.Marshal(d.Service.RollBackContext) // 序列化回滚上下文 + if rerr != nil { + logger.Error("json Marshal %s", err.Error()) + fmt.Printf("Can't RollBack\n") + } + fmt.Printf("%s\n", string(rollbackCtxb)) + return err + } + + logger.Info("clean_data successfully") // 打印成功信息 + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/restart_process.go b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/restart_process.go new file mode 100644 index 0000000000..399d16dce6 --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/restart_process.go @@ -0,0 +1,95 @@ +package vmcmd + +import ( + "encoding/json" + "fmt" + + "dbm-services/bigdata/db-tools/dbactuator/internal/subcmd" + "dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util" + "dbm-services/common/go-pubpkg/logger" + + "github.com/spf13/cobra" +) + +// RestartProcessAct 是一个结构体,用于重启VictoriaMetrics进程。 +type RestartProcessAct struct { + *subcmd.BaseOptions // BaseOptions 是基础选项,可能包含了一些全局设置或配置。 + Service victoriametrics.StartStopProcessComp // Service 是用于启动和停止VictoriaMetrics进程的组件。 +} + +// RestartProcessCommand 是一个函数,返回一个cobra.Command对象,该对象定义了一个命令行命令,用于重启VictoriaMetrics进程。 +func RestartProcessCommand() *cobra.Command { + act := RestartProcessAct{ + BaseOptions: subcmd.GBaseOptions, + } + cmd := &cobra.Command{ + Use: "restart_process", + Short: "重启vm进程", + Example: fmt.Sprintf(`dbactuator vm restart_process %s`, subcmd.CmdBaseExapmleStr), + Run: func(cmd *cobra.Command, args []string) { + util.CheckErr(act.Validate()) // 验证参数 + if act.RollBack { // 如果需要回滚,则执行回滚操作 + util.CheckErr(act.Rollback()) + return + } + util.CheckErr(act.Init()) // 初始化 + util.CheckErr(act.Run()) // 运行 + }, + } + return cmd +} + +// Validate 是 RestartProcessAct 的验证函数,用于验证参数是否有效。 +func (d *RestartProcessAct) Validate() (err error) { + return d.BaseOptions.Validate() +} + +// Init 是 RestartProcessAct 的初始化函数,用于初始化操作。 +func (d *RestartProcessAct) Init() (err error) { + logger.Info("RestartProcessAct Init") + if err = d.Deserialize(&d.Service.Params); err != nil { // 反序列化参数 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + d.Service.GeneralParam = subcmd.GeneralRuntimeParam // 设置通用运行时参数 + return d.Service.Init() // 初始化服务 +} + +// Rollback 是 RestartProcessAct 的回滚函数,用于在操作失败时进行回滚。 +func (d *RestartProcessAct) Rollback() (err error) { + var r rollback.RollBackObjects + if err = d.DeserializeAndValidate(&r); err != nil { // 反序列化并验证回滚对象 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + err = r.RollBack() // 执行回滚 + if err != nil { + logger.Error("roll back failed %s", err.Error()) + } + return +} + +// Run 是 RestartProcessAct 的运行函数,用于执行重启VictoriaMetrics进程的操作。 +func (d *RestartProcessAct) Run() (err error) { + steps := subcmd.Steps{ + { + FunName: "重启vm进程", + Func: d.Service.RestartProcess, // 重启进程的函数 + }, + } + + if err := steps.Run(); err != nil { // 执行步骤 + rollbackCtxb, rerr := json.Marshal(d.Service.RollBackContext) // 序列化回滚上下文 + if rerr != nil { + logger.Error("json Marshal %s", err.Error()) + fmt.Printf("Can't RollBack\n") + } + fmt.Printf("%s\n", string(rollbackCtxb)) + return err + } + + logger.Info("restart_process successfully") // 打印成功信息 + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/start_process.go b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/start_process.go new file mode 100644 index 0000000000..5f185aa6f0 --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/start_process.go @@ -0,0 +1,95 @@ +package vmcmd + +import ( + "encoding/json" + "fmt" + + "dbm-services/bigdata/db-tools/dbactuator/internal/subcmd" + "dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util" + "dbm-services/common/go-pubpkg/logger" + + "github.com/spf13/cobra" +) + +// StartProcessAct 是一个结构体,用于启动VictoriaMetrics进程。 +type StartProcessAct struct { + *subcmd.BaseOptions // BaseOptions 是基础选项,可能包含了一些全局设置或配置。 + Service victoriametrics.StartStopProcessComp // Service 是用于启动和停止VictoriaMetrics进程的组件。 +} + +// StartProcessCommand 是一个函数,返回一个cobra.Command对象,该对象定义了一个命令行命令,用于启动VictoriaMetrics进程。 +func StartProcessCommand() *cobra.Command { + act := StartProcessAct{ + BaseOptions: subcmd.GBaseOptions, + } + cmd := &cobra.Command{ + Use: "start_process", + Short: "启动vm进程", + Example: fmt.Sprintf(`dbactuator vm start_process %s`, subcmd.CmdBaseExapmleStr), + Run: func(cmd *cobra.Command, args []string) { + util.CheckErr(act.Validate()) // 验证参数 + if act.RollBack { // 如果需要回滚,则执行回滚操作 + util.CheckErr(act.Rollback()) + return + } + util.CheckErr(act.Init()) // 初始化 + util.CheckErr(act.Run()) // 运行 + }, + } + return cmd +} + +// Validate 是 StartProcessAct 的验证函数,用于验证参数是否有效。 +func (d *StartProcessAct) Validate() (err error) { + return d.BaseOptions.Validate() +} + +// Init 是 StartProcessAct 的初始化函数,用于初始化操作。 +func (d *StartProcessAct) Init() (err error) { + logger.Info("StartProcessAct Init") + if err = d.Deserialize(&d.Service.Params); err != nil { // 反序列化参数 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + d.Service.GeneralParam = subcmd.GeneralRuntimeParam // 设置通用运行时参数 + return d.Service.Init() // 初始化服务 +} + +// Rollback 是 StartProcessAct 的回滚函数,用于在操作失败时进行回滚。 +func (d *StartProcessAct) Rollback() (err error) { + var r rollback.RollBackObjects + if err = d.DeserializeAndValidate(&r); err != nil { // 反序列化并验证回滚对象 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + err = r.RollBack() // 执行回滚 + if err != nil { + logger.Error("roll back failed %s", err.Error()) + } + return +} + +// Run 是 StartProcessAct 的运行函数,用于执行启动VictoriaMetrics进程的操作。 +func (d *StartProcessAct) Run() (err error) { + steps := subcmd.Steps{ + { + FunName: "启动vm进程", + Func: d.Service.StartProcess, // 启动进程的函数 + }, + } + + if err := steps.Run(); err != nil { // 执行步骤 + rollbackCtxb, rerr := json.Marshal(d.Service.RollBackContext) // 序列化回滚上下文 + if rerr != nil { + logger.Error("json Marshal %s", err.Error()) + fmt.Printf("Can't RollBack\n") + } + fmt.Printf("%s\n", string(rollbackCtxb)) + return err + } + + logger.Info("start_process successfully") // 打印成功信息 + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/stop_process.go b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/stop_process.go new file mode 100644 index 0000000000..22c5dd5b7d --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/stop_process.go @@ -0,0 +1,95 @@ +package vmcmd + +import ( + "encoding/json" + "fmt" + + "dbm-services/bigdata/db-tools/dbactuator/internal/subcmd" + "dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util" + "dbm-services/common/go-pubpkg/logger" + + "github.com/spf13/cobra" +) + +// StopProcessAct 是一个结构体,用于停止VictoriaMetrics进程。 +type StopProcessAct struct { + *subcmd.BaseOptions // BaseOptions 是基础选项,可能包含了一些全局设置或配置。 + Service victoriametrics.StartStopProcessComp // Service 是用于启动和停止VictoriaMetrics进程的组件。 +} + +// StopProcessCommand 是一个函数,返回一个cobra.Command对象,该对象定义了一个命令行命令,用于停止VictoriaMetrics进程。 +func StopProcessCommand() *cobra.Command { + act := StopProcessAct{ + BaseOptions: subcmd.GBaseOptions, + } + cmd := &cobra.Command{ + Use: "stop_process", + Short: "停止vm进程", + Example: fmt.Sprintf(`dbactuator vm stop_process %s`, subcmd.CmdBaseExapmleStr), + Run: func(cmd *cobra.Command, args []string) { + util.CheckErr(act.Validate()) // 验证参数 + if act.RollBack { // 如果需要回滚,则执行回滚操作 + util.CheckErr(act.Rollback()) + return + } + util.CheckErr(act.Init()) // 初始化 + util.CheckErr(act.Run()) // 运行 + }, + } + return cmd +} + +// Validate 是 StopProcessAct 的验证函数,用于验证参数是否有效。 +func (d *StopProcessAct) Validate() (err error) { + return d.BaseOptions.Validate() +} + +// Init 是 StopProcessAct 的初始化函数,用于初始化操作。 +func (d *StopProcessAct) Init() (err error) { + logger.Info("StopProcessAct Init") + if err = d.Deserialize(&d.Service.Params); err != nil { // 反序列化参数 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + d.Service.GeneralParam = subcmd.GeneralRuntimeParam // 设置通用运行时参数 + return d.Service.Init() // 初始化服务 +} + +// Rollback 是 StopProcessAct 的回滚函数,用于在操作失败时进行回滚。 +func (d *StopProcessAct) Rollback() (err error) { + var r rollback.RollBackObjects + if err = d.DeserializeAndValidate(&r); err != nil { // 反序列化并验证回滚对象 + logger.Error("DeserializeAndValidate failed, %v", err) + return err + } + err = r.RollBack() // 执行回滚 + if err != nil { + logger.Error("roll back failed %s", err.Error()) + } + return +} + +// Run 是 StopProcessAct 的运行函数,用于执行停止VictoriaMetrics进程的操作。 +func (d *StopProcessAct) Run() (err error) { + steps := subcmd.Steps{ + { + FunName: "停止vm进程", + Func: d.Service.StopProcess, // 停止进程的函数 + }, + } + + if err := steps.Run(); err != nil { // 执行步骤 + rollbackCtxb, rerr := json.Marshal(d.Service.RollBackContext) // 序列化回滚上下文 + if rerr != nil { + logger.Error("json Marshal %s", err.Error()) + fmt.Printf("Can't RollBack\n") + } + fmt.Printf("%s\n", string(rollbackCtxb)) + return err + } + + logger.Info("stop_process successfully") // 打印成功信息 + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/vmcmd.go b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/vmcmd.go index c1a0c45b71..a78ec84e46 100644 --- a/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/vmcmd.go +++ b/dbm-services/bigdata/db-tools/dbactuator/internal/subcmd/vmcmd/vmcmd.go @@ -1,3 +1,4 @@ +// Package vmcmd TODO package vmcmd // 引入了一些必要的包,包括内部的子命令处理包,模板工具包,以及第三方的cobra包。 @@ -34,6 +35,14 @@ func VMCommand() *cobra.Command { InitCommand(), // 解压VMPkg的命令 DecompressVMPkgCommand(), + // 停止进程命令 + StopProcessCommand(), + // 启动进程命令 + StartProcessCommand(), + // 重启进程命令 + RestartProcessCommand(), + // 清理目录命令 + CleanDataCommand(), }, }, } diff --git a/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/clean_data.go b/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/clean_data.go new file mode 100644 index 0000000000..adb3796840 --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/clean_data.go @@ -0,0 +1,104 @@ +package victoriametrics + +import ( + "dbm-services/bigdata/db-tools/dbactuator/pkg/components" + "dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util/osutil" + "dbm-services/common/go-pubpkg/logger" + "fmt" +) + +// CleanDataComp 是一个结构体,用于清理数据和相关进程。 +type CleanDataComp struct { + GeneralParam *components.GeneralParam // GeneralParam 是通用参数,可能包含了一些全局设置或配置。 + Params *CleanDataParams // Params 是清理数据的参数,目前看起来是空的,可能在后续的开发中会添加具体的参数。 + RollBackContext rollback.RollBackObjects // RollBackContext 是回滚上下文,用于在操作失败时进行回滚。 +} + +// CleanDataParams 是一个空的结构体,可能在后续的开发中会添加具体的参数。 +type CleanDataParams struct{} + +// Init 是 CleanDataComp 的初始化函数,目前只是打印一条日志,没有实际操作。 +func (d *CleanDataComp) Init() (err error) { + logger.Info("Clean data fake init") + return nil +} + +// CleanData 是清理数据和相关进程的函数,它执行了以下操作: +// 1. 清除crontab +// 2. 强杀进程 +// 3. 删除软链 +// 4. 清理profile +// 5. 删除vmenv +// 6. 删除数据目录 +// 7. 删除日志目录 +func (d *CleanDataComp) CleanData() (err error) { + // 清除crontab + logger.Info("获取crontab") + out, err := osutil.ListCrontb(cst.DefaultExecUser) + if err != nil { + logger.Error("获取crontab失败", err) + return err + } + logger.Debug("crontab: ", out) + if len(out) > 0 { + extraCmd := fmt.Sprintf("crontab -u %s -r", cst.DefaultExecUser) + logger.Info("清除crontab, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + } + + // 强杀进程 + extraCmd := + `ps -ef | egrep 'supervisord|node_exporter|telegraf|vminsert|vmstorage|vmselect'| ` + + `grep -v grep |awk {'print "kill -9 " $2'}|sh` + logger.Info("强杀进程, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + // 删除软链 + extraCmd = `rm -f /etc/supervisord.conf /usr/local/bin/supervisorctl /usr/local/bin/supervisord /usr/bin/java` + logger.Info("删除软链, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + // 清理profile + extraCmd = `rm -f /etc/profile.d/vm.sh` + logger.Info("清理profile, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + } + + // 删除vmenv + extraCmd = `rm -rf /data/vmenv*` + logger.Info("删除vmenv, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + // 删除数据目录 + extraCmd = `rm -rf /data*/vmd*` + logger.Info("删除数据目录, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + // 删除日志目录 + extraCmd = `rm -rf /data*/vm*` + logger.Info("删除日志目录, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/startstop_process.go b/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/startstop_process.go new file mode 100644 index 0000000000..bdb472b0b9 --- /dev/null +++ b/dbm-services/bigdata/db-tools/dbactuator/pkg/components/victoriametrics/startstop_process.go @@ -0,0 +1,64 @@ +package victoriametrics + +import ( + "dbm-services/bigdata/db-tools/dbactuator/pkg/components" + "dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst" + "dbm-services/bigdata/db-tools/dbactuator/pkg/rollback" + "dbm-services/bigdata/db-tools/dbactuator/pkg/util/osutil" + "dbm-services/common/go-pubpkg/logger" +) + +// StartStopProcessComp 是一个结构体,用于管理进程的启动、停止和重启。 +type StartStopProcessComp struct { + GeneralParam *components.GeneralParam // GeneralParam 是通用参数,可能包含了一些全局设置或配置。 + Params *StartStopParams // Params 是清理数据的参数,目前看起来是空的,可能在后续的开发中会添加具体的参数。 + RollBackContext rollback.RollBackObjects // RollBackContext 是回滚上下文,用于在操作失败时进行回滚。 +} + +// StartStopParams 是一个空的结构体,可能在后续的开发中会添加具体的参数。 +type StartStopParams struct{} + +// Init 是 StartStopProcessComp 的初始化函数,目前只是打印一条日志,没有实际操作。 +func (d *StartStopProcessComp) Init() (err error) { + logger.Info("Fake init") + return nil +} + +// StopProcess 是停止所有进程的函数,它通过执行 "supervisorctl stop all" 命令来实现。 +func (d *StartStopProcessComp) StopProcess() (err error) { + extraCmd := cst.StopCommand + logger.Info("停止所有进程, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + return nil +} + +// StartProcess 是启动所有进程的函数,它通过执行 "supervisorctl start all" 命令来实现。 +func (d *StartStopProcessComp) StartProcess() (err error) { + extraCmd := cst.StartCommand + logger.Info("启动所有进程, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + return nil +} + +// RestartProcess 是重启所有进程的函数,它先停止所有进程,然后再启动所有进程。 +func (d *StartStopProcessComp) RestartProcess() (err error) { + extraCmd := cst.StopCommand + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + + extraCmd = cst.StartCommand + logger.Info("启动所有进程, [%s]", extraCmd) + if _, err = osutil.ExecShellCommand(false, extraCmd); err != nil { + logger.Error("[%s] execute failed, %v", extraCmd, err) + return err + } + return nil +} diff --git a/dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst/vm.go b/dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst/vm.go index 7c4c5c13f3..c20d8a93a5 100644 --- a/dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst/vm.go +++ b/dbm-services/bigdata/db-tools/dbactuator/pkg/core/cst/vm.go @@ -15,4 +15,10 @@ const ( VMSelect = "vmselect" // VMInsert TODO VMInsert = "vminsert" + + // StartCommand TODO + StartCommand = "supervisorctl start all" + + // StopCommand TODO + StopCommand = "supervisorctl stop all" )