forked from TencentBlueKing/blueking-dbm
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(mysql): 部署周边子流程 TencentBlueKing#7639
- Loading branch information
Showing
98 changed files
with
3,586 additions
and
3,390 deletions.
There are no files selected for viewing
213 changes: 107 additions & 106 deletions
213
dbm-services/mysql/db-tools/dbactuator/internal/subcmd/mysqlcmd/deploy_mysql_crond.go
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 |
|---|---|---|
| @@ -1,108 +1,109 @@ | ||
| package mysqlcmd | ||
|
|
||
| import ( | ||
| "dbm-services/mysql/db-tools/dbactuator/pkg/components/peripheraltools/crond" | ||
| "fmt" | ||
|
|
||
| "dbm-services/common/go-pubpkg/logger" | ||
| "dbm-services/mysql/db-tools/dbactuator/internal/subcmd" | ||
| "dbm-services/mysql/db-tools/dbactuator/pkg/util" | ||
|
|
||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| // DeployMysqlCrondAct 部署 | ||
| type DeployMysqlCrondAct struct { | ||
| *subcmd.BaseOptions | ||
| Service crond.MySQLCrondComp | ||
| } | ||
|
|
||
| // DeployMySQLCrond 命令常量 | ||
| const DeployMySQLCrond = "deploy-mysql-crond" | ||
|
|
||
| // NewDeployMySQLCrondCommand 实现 | ||
| func NewDeployMySQLCrondCommand() *cobra.Command { | ||
| act := DeployMysqlCrondAct{ | ||
| BaseOptions: subcmd.GBaseOptions, | ||
| } | ||
| cmd := &cobra.Command{ | ||
| Use: DeployMySQLCrond, | ||
| Short: "部署 mysql-crond", | ||
| Example: fmt.Sprintf( | ||
| `dbactuator mysql %s %s %s`, | ||
| DeployMySQLCrond, | ||
| subcmd.CmdBaseExampleStr, | ||
| subcmd.ToPrettyJson(act.Service.Example()), | ||
| ), | ||
| Run: func(cmd *cobra.Command, args []string) { | ||
| util.CheckErr(act.Validate()) | ||
| util.CheckErr(act.Init()) | ||
| util.CheckErr(act.Run()) | ||
| }, | ||
| } | ||
| return cmd | ||
| } | ||
|
|
||
| // Validate 校验参数 | ||
| func (c *DeployMysqlCrondAct) Validate() (err error) { | ||
| return c.BaseOptions.Validate() | ||
| } | ||
|
|
||
| // Init 初始化 | ||
| func (c *DeployMysqlCrondAct) Init() (err error) { | ||
| if err = c.Deserialize(&c.Service.Params); err != nil { | ||
| logger.Error("DeserializeAndValidate err %s", err.Error()) | ||
| return err | ||
| } | ||
| c.Service.GeneralParam = subcmd.GeneralRuntimeParam | ||
| logger.Info("extend params: %s", c.Service.Params) | ||
| return nil | ||
| } | ||
|
|
||
| // Run 执行 | ||
| func (c *DeployMysqlCrondAct) Run() (err error) { | ||
| steps := subcmd.Steps{ | ||
| { | ||
| FunName: "初始化", | ||
| Func: c.Service.Init, | ||
| }, | ||
| { | ||
| FunName: "部署二进制", | ||
| Func: c.Service.DeployBinary, | ||
| }, | ||
| { | ||
| FunName: "生成配置文件", | ||
| Func: c.Service.GenerateRuntimeConfig, | ||
| }, | ||
| { | ||
| FunName: "生成空任务配置", | ||
| Func: c.Service.TouchJobsConfig, | ||
| }, | ||
| { | ||
| FunName: "移除保活监控", | ||
| Func: c.Service.RemoveKeepAlive, | ||
| }, | ||
| { | ||
| FunName: "停止进程", | ||
| Func: c.Service.Stop, | ||
| }, | ||
| { | ||
| FunName: "启动进程", | ||
| Func: c.Service.Start, | ||
| }, | ||
| { | ||
| FunName: "启动后检查", | ||
| Func: c.Service.CheckStart, | ||
| }, | ||
| { | ||
| FunName: "添加保活监控", | ||
| Func: c.Service.AddKeepAlive, | ||
| }, | ||
| } | ||
| if err := steps.Run(); err != nil { | ||
| logger.Error("部署 mysql-crond 失败: %s", err.Error()) | ||
| return err | ||
| } | ||
| logger.Info("部署 mysql-crond 完成") | ||
| return nil | ||
| } | ||
| // | ||
| //import ( | ||
| // "dbm-services/mysql/db-tools/dbactuator/pkg/components/peripheraltools/crond" | ||
| // "fmt" | ||
| // | ||
| // "dbm-services/common/go-pubpkg/logger" | ||
| // "dbm-services/mysql/db-tools/dbactuator/internal/subcmd" | ||
| // "dbm-services/mysql/db-tools/dbactuator/pkg/util" | ||
| // | ||
| // "github.com/spf13/cobra" | ||
| //) | ||
| // | ||
| //// DeployMysqlCrondAct 部署 | ||
| //type DeployMysqlCrondAct struct { | ||
| // *subcmd.BaseOptions | ||
| // Service crond.MySQLCrondComp | ||
| //} | ||
| // | ||
| //// DeployMySQLCrond 命令常量 | ||
| //const DeployMySQLCrond = "deploy-mysql-crond" | ||
| // | ||
| //// NewDeployMySQLCrondCommand 实现 | ||
| //func NewDeployMySQLCrondCommand() *cobra.Command { | ||
| // act := DeployMysqlCrondAct{ | ||
| // BaseOptions: subcmd.GBaseOptions, | ||
| // } | ||
| // cmd := &cobra.Command{ | ||
| // Use: DeployMySQLCrond, | ||
| // Short: "部署 mysql-crond", | ||
| // Example: fmt.Sprintf( | ||
| // `dbactuator mysql %s %s %s`, | ||
| // DeployMySQLCrond, | ||
| // subcmd.CmdBaseExampleStr, | ||
| // subcmd.ToPrettyJson(act.Service.Example()), | ||
| // ), | ||
| // Run: func(cmd *cobra.Command, args []string) { | ||
| // util.CheckErr(act.Validate()) | ||
| // util.CheckErr(act.Init()) | ||
| // util.CheckErr(act.Run()) | ||
| // }, | ||
| // } | ||
| // return cmd | ||
| //} | ||
| // | ||
| //// Validate 校验参数 | ||
| //func (c *DeployMysqlCrondAct) Validate() (err error) { | ||
| // return c.BaseOptions.Validate() | ||
| //} | ||
| // | ||
| //// Init 初始化 | ||
| //func (c *DeployMysqlCrondAct) Init() (err error) { | ||
| // if err = c.Deserialize(&c.Service.Params); err != nil { | ||
| // logger.Error("DeserializeAndValidate err %s", err.Error()) | ||
| // return err | ||
| // } | ||
| // c.Service.GeneralParam = subcmd.GeneralRuntimeParam | ||
| // logger.Info("extend params: %s", c.Service.Params) | ||
| // return nil | ||
| //} | ||
| // | ||
| //// Run 执行 | ||
| //func (c *DeployMysqlCrondAct) Run() (err error) { | ||
| // steps := subcmd.Steps{ | ||
| // { | ||
| // FunName: "初始化", | ||
| // Func: c.Service.Init, | ||
| // }, | ||
| // { | ||
| // FunName: "部署二进制", | ||
| // Func: c.Service.DeployBinary, | ||
| // }, | ||
| // { | ||
| // FunName: "生成配置文件", | ||
| // Func: c.Service.GenerateRuntimeConfig, | ||
| // }, | ||
| // { | ||
| // FunName: "生成空任务配置", | ||
| // Func: c.Service.TouchJobsConfig, | ||
| // }, | ||
| // { | ||
| // FunName: "移除保活监控", | ||
| // Func: c.Service.RemoveKeepAlive, | ||
| // }, | ||
| // { | ||
| // FunName: "停止进程", | ||
| // Func: c.Service.Stop, | ||
| // }, | ||
| // { | ||
| // FunName: "启动进程", | ||
| // Func: c.Service.Start, | ||
| // }, | ||
| // { | ||
| // FunName: "启动后检查", | ||
| // Func: c.Service.CheckStart, | ||
| // }, | ||
| // { | ||
| // FunName: "添加保活监控", | ||
| // Func: c.Service.AddKeepAlive, | ||
| // }, | ||
| // } | ||
| // if err := steps.Run(); err != nil { | ||
| // logger.Error("部署 mysql-crond 失败: %s", err.Error()) | ||
| // return err | ||
| // } | ||
| // logger.Info("部署 mysql-crond 完成") | ||
| // return nil | ||
| //} |
Oops, something went wrong.