1390 lines
27 KiB
Go
1390 lines
27 KiB
Go
package executor
|
||
|
||
import (
|
||
"agent-go/g"
|
||
"agent-go/register"
|
||
"fmt"
|
||
"strings"
|
||
)
|
||
|
||
type BaseFunc interface {
|
||
|
||
// Command 返回基础函数的命令行
|
||
Command(baseFuncName string, funcArgs ...string) []string
|
||
|
||
// Exec 执行命令行，只返回正确结果 || 错误，日志
|
||
Exec(baseFuncName string, funcArgs ...string) (bool, []string)
|
||
}
|
||
|
||
type AgentOsOperator struct {
|
||
InstallCommandPrefix []string `json:"install_command_prefix",comment:"apt-get install or yum install"`
|
||
|
||
RemoveCommandPrefix []string `json:"remove_command_prefix",comment:"apt-get remove or yum remove"`
|
||
|
||
CanAccessInternet bool `json:"can_access_internet",comment:"是否可以访问公网"`
|
||
|
||
IsOsTypeUbuntu bool `json:"is_os_type_ubuntu",comment:"主机操作系统是否为ubuntu系列"`
|
||
|
||
IsAgentInnerWall bool `json:"is_agent_inner_wall",comment:"主机是否身处国内"`
|
||
|
||
AgentArch string `json:"agent_arch",comment:"主机的CPU架构，可选为amd64 arm64"`
|
||
|
||
AgentOSReleaseCode string `json:"agent_os_release_code",comment:"主机操作系统的发行版代号， focal之类的"`
|
||
|
||
AgentServerInfo *register.AgentServerInfo `json:"agent_server_info"`
|
||
|
||
// 离线下载URL地址
|
||
OssOfflinePrefix string `comment:"必须要用 / 结尾"`
|
||
}
|
||
|
||
func (op *AgentOsOperator) Exec(baseFuncName string, funcArgs ...string) (bool, []string) {
|
||
|
||
resultOk := false
|
||
var errorLog []string
|
||
|
||
switch baseFuncName {
|
||
|
||
case "shutdownFirewall":
|
||
resultOk, errorLog = op.shutdownFirewallExec()
|
||
break
|
||
case "modifyHostname":
|
||
resultOk, errorLog = op.modifyHostnameExec(funcArgs)
|
||
break
|
||
case "enableSwap":
|
||
resultOk, errorLog = op.enableSwapExec()
|
||
break
|
||
case "disableSwap":
|
||
resultOk, errorLog = op.disableSwapExec()
|
||
break
|
||
case "installDocker":
|
||
resultOk, errorLog = op.installDockerExec(funcArgs)
|
||
break
|
||
case "removeDocker":
|
||
resultOk, errorLog = op.removeDockerExec()
|
||
break
|
||
case "removeDockerCompose":
|
||
resultOk, errorLog = op.removeDockerComposeExec()
|
||
break
|
||
case "installDockerCompose":
|
||
resultOk, errorLog = op.installDockerComposeExec()
|
||
break
|
||
case "modifyDockerConfig":
|
||
resultOk, errorLog = op.modifyDockerConfigExec(funcArgs)
|
||
break
|
||
case "installHelm":
|
||
resultOk, errorLog = op.installHelmExec()
|
||
break
|
||
case "installHarbor":
|
||
resultOk, errorLog = op.installHarborExec()
|
||
break
|
||
case "chronyToPublicNTP":
|
||
resultOk, errorLog = op.chronyToPublicNTPExec()
|
||
break
|
||
case "chronyToMaster":
|
||
resultOk, errorLog = op.chronyToMasterExec(funcArgs)
|
||
break
|
||
case "installZSH":
|
||
resultOk, errorLog = op.installZSHExec()
|
||
break
|
||
case "modifySshPort":
|
||
resultOk, errorLog = op.modifySshPortExec(funcArgs)
|
||
break
|
||
case "openBBR":
|
||
resultOk, errorLog = op.openBBRExec()
|
||
break
|
||
default:
|
||
resultOk, errorLog = op.okExec(funcArgs)
|
||
}
|
||
|
||
return resultOk, errorLog
|
||
}
|
||
|
||
func (op *AgentOsOperator) Command(baseFuncName string, funcArgs ...string) []string {
|
||
|
||
var multiLineCommand [][]string
|
||
|
||
switch baseFuncName {
|
||
|
||
case "shutdownFirewall":
|
||
multiLineCommand = op.shutdownFirewall()
|
||
break
|
||
case "modifyHostname":
|
||
multiLineCommand = op.modifyHostname(funcArgs)
|
||
break
|
||
case "enableSwap":
|
||
multiLineCommand = op.enableSwap()
|
||
break
|
||
case "disableSwap":
|
||
multiLineCommand = op.disableSwap()
|
||
break
|
||
case "installDocker":
|
||
multiLineCommand = op.installDocker(funcArgs)
|
||
break
|
||
case "removeDocker":
|
||
multiLineCommand = op.removeDocker()
|
||
break
|
||
case "removeDockerCompose":
|
||
multiLineCommand = op.removeDockerCompose()
|
||
break
|
||
case "installDockerCompose":
|
||
multiLineCommand = op.installDockerCompose()
|
||
break
|
||
case "modifyDockerConfig":
|
||
multiLineCommand = op.modifyDockerConfig(funcArgs)
|
||
break
|
||
case "installHelm":
|
||
multiLineCommand = op.installHelm()
|
||
break
|
||
case "installHarbor":
|
||
multiLineCommand = op.installHarbor()
|
||
break
|
||
case "chronyToPublicNTP":
|
||
multiLineCommand = op.chronyToPublicNTP()
|
||
break
|
||
case "chronyToMaster":
|
||
multiLineCommand = op.chronyToMaster(funcArgs)
|
||
break
|
||
case "installZSH":
|
||
multiLineCommand = op.installZSH()
|
||
break
|
||
case "modifySshPort":
|
||
multiLineCommand = op.modifySshPort(funcArgs)
|
||
break
|
||
case "openBBR":
|
||
multiLineCommand = op.openBBR()
|
||
break
|
||
default:
|
||
multiLineCommand = op.ok(funcArgs)
|
||
}
|
||
|
||
log.DebugF("multiLineCommand are => %v", multiLineCommand)
|
||
|
||
var result []string
|
||
|
||
// exec the command here
|
||
for _, singleLineCommand := range multiLineCommand {
|
||
singleCommandResult, _ := FormatAllCommandExecutor(singleLineCommand)
|
||
|
||
result = append(result, "")
|
||
result = append(result, singleCommandResult...)
|
||
|
||
// debug usage
|
||
log.DebugF("exec result are => %v", result)
|
||
for _, logLine := range result {
|
||
fmt.Println(logLine)
|
||
}
|
||
|
||
}
|
||
|
||
// 归一化处理
|
||
return result
|
||
}
|
||
|
||
func (op *AgentOsOperator) shutdownFirewall() [][]string {
|
||
|
||
shutdownFunc := [][]string{
|
||
{"systemctl", "stop", "firewalld"},
|
||
{"systemctl", "disable", "firewalld"},
|
||
}
|
||
|
||
if !op.IsOsTypeUbuntu {
|
||
shutdownFunc = append(shutdownFunc,
|
||
[]string{
|
||
"sed",
|
||
"-i",
|
||
"s/SELINUX=enforcing/SELINUX=disabled/g",
|
||
"/etc/selinux/config",
|
||
},
|
||
)
|
||
}
|
||
|
||
return shutdownFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) shutdownFirewallExec() (bool, []string) {
|
||
|
||
shutdownFunc := [][]string{
|
||
{"systemctl", "stop", "firewalld"},
|
||
{"systemctl", "disable", "firewalld"},
|
||
{"systemctl", "stop", "ufw"},
|
||
{"systemctl", "disable", "ufw"},
|
||
{"iptables", "-F"},
|
||
}
|
||
// 忽略错误
|
||
_, resultLog := AllCompleteExecutor(shutdownFunc)
|
||
|
||
// centos
|
||
|
||
return true, resultLog
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifyHostname(args []string) [][]string {
|
||
|
||
return [][]string{}
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifyHostnameExec(args []string) (bool, []string) {
|
||
|
||
ok, resultLog := AllCommandExecutor(
|
||
[]string{
|
||
"hostnamectl",
|
||
"set-hostname",
|
||
args[0],
|
||
})
|
||
|
||
return ok, resultLog
|
||
}
|
||
|
||
func (op *AgentOsOperator) enableSwap() [][]string {
|
||
|
||
enableSwapFunc := [][]string{
|
||
{
|
||
"cp",
|
||
"-f",
|
||
"/etc/fstab_back",
|
||
"/etc/fstab",
|
||
},
|
||
{
|
||
"cat",
|
||
"/etc/fstab",
|
||
},
|
||
}
|
||
|
||
return enableSwapFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) enableSwapExec() (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) disableSwap() [][]string {
|
||
|
||
disableSwapFunc := [][]string{
|
||
{
|
||
"swapoff",
|
||
"-a",
|
||
},
|
||
{
|
||
"cp",
|
||
"-f",
|
||
"/etc/fstab",
|
||
"/etc/fstab_back",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"/swap/d",
|
||
"/etc/fstab",
|
||
},
|
||
}
|
||
|
||
return disableSwapFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) disableSwapExec() (bool, []string) {
|
||
|
||
var resultLog []string
|
||
|
||
// 备份文件存在，pass
|
||
if !BasicFileExists("/etc/fstab_back_wdd") {
|
||
AllCommandExecutor([]string{
|
||
"cp",
|
||
"-f",
|
||
"/etc/fstab",
|
||
"/etc/fstab_back_wdd",
|
||
})
|
||
}
|
||
// 执行关闭操作
|
||
_, lre := AllCompleteExecutor(
|
||
[][]string{
|
||
{
|
||
"swapoff",
|
||
"-a",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"/swap/d",
|
||
"/etc/fstab",
|
||
},
|
||
})
|
||
|
||
resultLog = append(resultLog, lre...)
|
||
|
||
return true, resultLog
|
||
}
|
||
|
||
func (op *AgentOsOperator) removeDocker() [][]string {
|
||
|
||
removeDockerLine := append(op.RemoveCommandPrefix, []string{
|
||
"docker-ce",
|
||
"docker.io",
|
||
"docker-ce-cli",
|
||
//"docker",
|
||
//"docker-common",
|
||
//"docker-latest",
|
||
//"docker-latest-logrotate",
|
||
//"docker-logrotate",
|
||
//"docker-selinux",
|
||
//"docker-engine-selinux",
|
||
//"docker-engine",
|
||
//"kubelet",
|
||
//"kubeadm",
|
||
//"kubectl",
|
||
//"docker-client",
|
||
//"docker-client-latest",
|
||
}...)
|
||
|
||
removeDockerFunc := [][]string{
|
||
removeDockerLine,
|
||
}
|
||
|
||
return removeDockerFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) removeDockerExec() (bool, []string) {
|
||
var resultLog []string
|
||
|
||
dockerServiceStopCommand := [][]string{
|
||
{
|
||
"systemctl",
|
||
"stop",
|
||
"docker.service",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"stop",
|
||
"docker.socket",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"disable",
|
||
"docker.service",
|
||
},
|
||
}
|
||
|
||
ok, l := AllCompleteExecutor(dockerServiceStopCommand)
|
||
if !ok {
|
||
resultLog = append(resultLog, l...)
|
||
}
|
||
|
||
dockerStaff := []string{
|
||
"docker-ce",
|
||
"docker.io",
|
||
"docker-ce-cli",
|
||
"docker",
|
||
"docker-common",
|
||
"docker-latest",
|
||
"docker-latest-logrotate",
|
||
"docker-logrotate",
|
||
"docker-selinux",
|
||
"docker-engine-selinux",
|
||
"docker-engine",
|
||
"kubelet",
|
||
"kubeadm",
|
||
"kubectl",
|
||
"docker-client",
|
||
"docker-client-latest",
|
||
}
|
||
|
||
for _, staff := range dockerStaff {
|
||
removeCommand := append(op.RemoveCommandPrefix, staff)
|
||
|
||
ok, result := AllCommandExecutor(removeCommand)
|
||
if !ok {
|
||
resultLog = append(resultLog, result...)
|
||
}
|
||
}
|
||
|
||
return true, resultLog
|
||
}
|
||
|
||
func (op *AgentOsOperator) installDocker(args []string) [][]string {
|
||
|
||
// remove docker all staff
|
||
installDockerFunc := op.removeDocker()
|
||
|
||
if op.IsOsTypeUbuntu {
|
||
//
|
||
installFirstLine := append(op.InstallCommandPrefix, []string{
|
||
"apt-transport-https",
|
||
"ca-certificates",
|
||
"curl",
|
||
"gnupg-agent",
|
||
"software-properties-common",
|
||
}...)
|
||
|
||
if op.IsAgentInnerWall {
|
||
// inner gfw
|
||
installDockerFunc = append(installDockerFunc, [][]string{
|
||
installFirstLine,
|
||
{
|
||
"curl",
|
||
"-o",
|
||
"/etc/apt/keyrings/docker-utsc.gpg",
|
||
"https://mirrors.ustc.edu.cn/docker-ce/linux/ubuntu/gpg",
|
||
},
|
||
{
|
||
"apt-key",
|
||
"add",
|
||
"/etc/apt/keyrings/docker-utsc.gpg",
|
||
},
|
||
{
|
||
"add-apt-repository",
|
||
"deb [arch=" + op.AgentArch + "] https://mirrors.ustc.edu.cn/docker-ce/linux/ubuntu " + op.AgentOSReleaseCode + " stable",
|
||
},
|
||
}...)
|
||
} else {
|
||
// outside world
|
||
installDockerFunc = append(installDockerFunc, [][]string{
|
||
installFirstLine,
|
||
{
|
||
"curl",
|
||
"-o",
|
||
"/etc/apt/keyrings/docker.gpg",
|
||
"https://download.docker.com/linux/ubuntu/gpg ",
|
||
},
|
||
{
|
||
"apt-key",
|
||
"add",
|
||
"/etc/apt/keyrings/docker.gpg",
|
||
},
|
||
{
|
||
"add-apt-repository",
|
||
"deb [arch=" + op.AgentArch + "] https://download.docker.com/linux/ubuntu " + op.AgentOSReleaseCode + " stable",
|
||
},
|
||
}...)
|
||
}
|
||
|
||
// look for specific docker-version to install
|
||
installDockerFunc = append(installDockerFunc, []string{"apt-get", "update"})
|
||
|
||
var specificDockerVersion string
|
||
// hard code here 5:20.10.10~3-0~ubuntu-focal
|
||
if strings.HasPrefix(args[0], "19") {
|
||
specificDockerVersion = "5:19.03.15~3-0~ubuntu-" + op.AgentOSReleaseCode
|
||
} else {
|
||
specificDockerVersion = "5:20.10.10~3-0~ubuntu-" + op.AgentOSReleaseCode
|
||
}
|
||
|
||
installDockerFunc = append(installDockerFunc,
|
||
append(
|
||
op.InstallCommandPrefix,
|
||
"docker-ce="+specificDockerVersion,
|
||
"docker-ce-cli="+specificDockerVersion,
|
||
"containerd.io",
|
||
"docker-compose-plugin",
|
||
),
|
||
)
|
||
|
||
} else {
|
||
installFirstLine := append(op.InstallCommandPrefix,
|
||
[]string{
|
||
"yum-utils",
|
||
"device-mapper-persistent-data",
|
||
"lvm2",
|
||
}...,
|
||
)
|
||
|
||
if op.IsAgentInnerWall {
|
||
// inner gfw
|
||
installDockerFunc = append(installDockerFunc, [][]string{
|
||
installFirstLine,
|
||
{
|
||
"yum-config-manager",
|
||
"--add-repo",
|
||
"https://mirrors.ustc.edu.cn/docker-ce/linux/centos/docker-ce.repo",
|
||
},
|
||
{
|
||
"sed ",
|
||
"-i ",
|
||
"'s/download.docker.com/mirrors.ustc.edu.cn\\/docker-ce/g' ",
|
||
"/etc/yum.repos.d/docker-ce.repo",
|
||
},
|
||
{},
|
||
}...)
|
||
} else {
|
||
// outside world
|
||
}
|
||
|
||
}
|
||
|
||
return installDockerFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) installDockerExec(args []string) (bool, []string) {
|
||
|
||
if op.IsOsTypeUbuntu {
|
||
|
||
installDependencyCommand := append(op.InstallCommandPrefix, []string{
|
||
"apt-transport-https",
|
||
"ca-certificates",
|
||
"curl",
|
||
"gnupg",
|
||
"software-properties-common",
|
||
}...)
|
||
|
||
ok, l := AllCommandExecutor(installDependencyCommand)
|
||
if !ok {
|
||
//
|
||
return false, l
|
||
}
|
||
|
||
dockerGPGFilePath := "/etc/apt/keyrings/docker.gpg"
|
||
dockerAPTFilePath := "/etc/apt/sources.list.d/docker.list"
|
||
dockerGPGSource := "https://mirrors.ustc.edu.cn/docker-ce/linux/ubuntu/gpg"
|
||
dockerAPTSource := "https://mirrors.ustc.edu.cn/docker-ce/linux/ubuntu"
|
||
|
||
executor, resultLog := AllCompleteExecutor([][]string{
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
dockerGPGFilePath,
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
dockerAPTFilePath,
|
||
},
|
||
{
|
||
"mkdir",
|
||
"-p",
|
||
"/etc/apt/keyrings",
|
||
},
|
||
{
|
||
"install",
|
||
"-m",
|
||
"0755",
|
||
"-d",
|
||
"/etc/apt/keyrings",
|
||
},
|
||
})
|
||
if !executor {
|
||
return false, append(resultLog, "创建docker-key gpg文件失败！")
|
||
}
|
||
|
||
// 安装镜像的证书
|
||
if !op.IsAgentInnerWall {
|
||
// outside world
|
||
dockerGPGSource = "https://download.docker.com/linux/ubuntu/gpg"
|
||
dockerAPTSource = "https://download.docker.com/linux/ubuntu"
|
||
}
|
||
|
||
ok, l2 := PipelineCommandExecutor([][]string{
|
||
{
|
||
"curl",
|
||
"-fsSL",
|
||
dockerGPGSource,
|
||
},
|
||
{
|
||
"gpg",
|
||
"--dearmor",
|
||
"-o",
|
||
dockerGPGFilePath,
|
||
},
|
||
})
|
||
if !ok {
|
||
return false, append(l2, "下载docker gpg文件失败", dockerGPGSource, dockerAPTSource)
|
||
}
|
||
if !BasicFileExistAndNotNull(dockerGPGFilePath) {
|
||
return false, []string{"添加gpg失败！"}
|
||
}
|
||
|
||
resultOk, log2 := AllCompleteExecutor([][]string{
|
||
{
|
||
"chmod",
|
||
"a+r",
|
||
dockerGPGFilePath,
|
||
},
|
||
//{
|
||
// "add-apt-repository",
|
||
// "deb [arch=" + op.AgentArch + " signed-by=" + dockerGPGFilePath + " ] " + dockerAPTSource + " " + op.AgentOSReleaseCode + " stable",
|
||
//},
|
||
})
|
||
if !resultOk {
|
||
return false, append(log2, "添加APT源失败！")
|
||
}
|
||
dockerAPTSourceCommand := "deb [arch=" + op.AgentArch + " signed-by=" + dockerGPGFilePath + "] " + dockerAPTSource + " " + op.AgentOSReleaseCode + " stable"
|
||
|
||
log.InfoF("dockerAPTSourceCommand is => %s ", dockerAPTSourceCommand)
|
||
|
||
ok, log3 := PipelineCommandExecutor([][]string{
|
||
{
|
||
"echo",
|
||
dockerAPTSourceCommand,
|
||
},
|
||
{
|
||
"tee",
|
||
dockerAPTFilePath,
|
||
},
|
||
})
|
||
if !ok {
|
||
return false, append(log3, "添加APT源失败！")
|
||
}
|
||
|
||
// look for specific docker-version to install
|
||
ok, log4 := AllCommandExecutor([]string{"apt-get", "update"})
|
||
if !ok {
|
||
return false, append(log4, "apt-get update 失败！")
|
||
}
|
||
|
||
// ubuntu 内部
|
||
var specificDockerVersion string
|
||
// hard code here 5:20.10.10~3-0~ubuntu-focal
|
||
if strings.HasPrefix(args[0], "19") {
|
||
specificDockerVersion = "5:19.03.15~3-0~ubuntu-" + op.AgentOSReleaseCode
|
||
} else {
|
||
specificDockerVersion = "5:20.10.10~3-0~ubuntu-" + op.AgentOSReleaseCode
|
||
}
|
||
|
||
log.InfoF("需要安装的docker版本为 => %s", specificDockerVersion)
|
||
|
||
dockerStaffList := []string{
|
||
"docker-ce=" + specificDockerVersion,
|
||
"docker-ce-cli=" + specificDockerVersion,
|
||
"containerd.io",
|
||
"docker-compose-plugin",
|
||
}
|
||
|
||
for _, s := range dockerStaffList {
|
||
resultOk, log2 = AllCommandExecutor(
|
||
append(op.InstallCommandPrefix, s))
|
||
if !resultOk {
|
||
return false, append(log2, s, "安装失败！")
|
||
}
|
||
}
|
||
|
||
// 启动docker服务
|
||
completeExecutor, log5 := AllCompleteExecutor([][]string{
|
||
{
|
||
"systemctl",
|
||
"stop",
|
||
"docker.service",
|
||
},
|
||
{
|
||
"sleep",
|
||
"2",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"start",
|
||
"docker.service",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"enable",
|
||
"docker.service",
|
||
},
|
||
})
|
||
if !completeExecutor {
|
||
return false, append(log5, "启动docker.service失败，请查明原因！", "journalctl -u docker -n 100 -f")
|
||
}
|
||
}
|
||
|
||
return true, []string{
|
||
"docker安装成功！",
|
||
}
|
||
}
|
||
|
||
func (op *AgentOsOperator) removeDockerCompose() [][]string {
|
||
|
||
installDockerComposeFunc := [][]string{
|
||
append(
|
||
op.RemoveCommandPrefix,
|
||
"docker-compose",
|
||
),
|
||
}
|
||
|
||
return installDockerComposeFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) removeDockerComposeExec() (bool, []string) {
|
||
|
||
commandName := "docker-compose"
|
||
if !BasicCommandExists(commandName) {
|
||
return true, []string{
|
||
commandName + " 卸载成功！",
|
||
}
|
||
}
|
||
possibleDockerComposeFilePath := []string{
|
||
"/usr/local/bin/" + commandName,
|
||
"/usr/bin/" + commandName,
|
||
}
|
||
|
||
for _, s := range possibleDockerComposeFilePath {
|
||
removeDockerCommand := append(RemoveForcePrefix, s)
|
||
AllCommandExecutor(removeDockerCommand)
|
||
}
|
||
|
||
return true, []string{
|
||
commandName + " 卸载成功！",
|
||
}
|
||
}
|
||
|
||
func (op *AgentOsOperator) installDockerCompose() [][]string {
|
||
|
||
installDockerComposeFunc := [][]string{
|
||
append(
|
||
op.InstallCommandPrefix,
|
||
"docker-compose",
|
||
),
|
||
}
|
||
|
||
return installDockerComposeFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) installDockerComposeExec() (bool, []string) {
|
||
log.Info("准备安装docker-compose!")
|
||
|
||
// 安装特定版本的 docker-compose 2.18.0
|
||
if op.OssOfflinePrefix == "" {
|
||
return false, []string{"离线下载OSS地址不存在！ 无法安装 docker-compose"}
|
||
}
|
||
|
||
DockerComposeFile := op.OssOfflinePrefix + "docker-compose-linux-x86_64-v2.18.0"
|
||
log.InfoF("需要安装的docker版本为 => %s", DockerComposeFile)
|
||
|
||
ok, resultLog := AllCommandExecutor([]string{
|
||
"curl",
|
||
"--connect-timeout",
|
||
"10",
|
||
DockerComposeFile,
|
||
"-o",
|
||
"/usr/local/bin/docker-compose",
|
||
})
|
||
if !ok {
|
||
return false, resultLog
|
||
}
|
||
|
||
log.Debug("docker-compose下载成功!")
|
||
if !BasicFileExistAndNotNull("/usr/local/bin/docker-compose") {
|
||
return false, []string{"docker-compose 下载失败！"}
|
||
}
|
||
|
||
AllCompleteExecutor([][]string{
|
||
{
|
||
"chmod", "+x", "/usr/local/bin/docker-compose",
|
||
},
|
||
{
|
||
"ln", "-s", "/usr/local/bin/docker-compose", "/usr/bin/docker-compose",
|
||
},
|
||
})
|
||
log.Info("docker-compose安装成功！")
|
||
return true, []string{"docker-compose安装成功！"}
|
||
}
|
||
func (op *AgentOsOperator) installHelm() [][]string {
|
||
installHelmFunc := [][]string{
|
||
{
|
||
"mkdir",
|
||
"-p",
|
||
"/root/wdd/",
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/wdd/helm-v*",
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/wdd/linux-amd64",
|
||
},
|
||
{
|
||
"wget",
|
||
"--no-check-certificate",
|
||
g.BaseFuncOssUrlPrefix + "helm-v3.12.1-linux-amd64.tar.gz",
|
||
"-O",
|
||
"/root/wdd/helm-v3.12.1-linux-amd64.tar.gz",
|
||
},
|
||
{
|
||
"tar",
|
||
"-zvxf",
|
||
"/root/wdd/helm-v3.12.1-linux-amd64.tar.gz",
|
||
},
|
||
{
|
||
"chmod",
|
||
"+x",
|
||
"/root/wdd/linux-amd64/helm",
|
||
},
|
||
{
|
||
"mv",
|
||
"/root/wdd/linux-amd64/helm",
|
||
"/usr/local/bin/helm",
|
||
},
|
||
{
|
||
"helm",
|
||
"version",
|
||
},
|
||
}
|
||
|
||
/*if op.IsOsTypeUbuntu {
|
||
installHelmFunc = [][]string{
|
||
{
|
||
"curl",
|
||
"-o",
|
||
"/etc/apt/keyrings/helm.gpg",
|
||
"https://baltocdn.com/helm/signing.asc",
|
||
},
|
||
{
|
||
"apt-key",
|
||
"add",
|
||
"/etc/apt/keyrings/helm.gpg",
|
||
},
|
||
{
|
||
"add-apt-repository",
|
||
"https://baltocdn.com/helm/stable/debian/ all main",
|
||
},
|
||
{
|
||
"apt-get",
|
||
"update",
|
||
},
|
||
append(op.InstallCommandPrefix, "helm"),
|
||
}
|
||
} else {
|
||
log.ErrorF("Operation OS is CentOS, Helm not installed!")
|
||
}*/
|
||
|
||
return installHelmFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) installHelmExec() (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifyDockerConfig(args []string) [][]string {
|
||
|
||
harborIPAddr := args[0] + ":8033"
|
||
|
||
modifyDockerConfigFunc := [][]string{
|
||
{
|
||
"mv",
|
||
"/etc/docker/daemon.json",
|
||
"/etc/docker/daemon.backup.json",
|
||
},
|
||
{
|
||
"wget",
|
||
g.BaseFuncOssUrlPrefix + "daemon-config.json",
|
||
"-O",
|
||
"/etc/docker/daemon.json",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/$DockerRegisterDomain/" + harborIPAddr + "/g",
|
||
"/etc/docker/daemon.json",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"restart",
|
||
"docker.service",
|
||
},
|
||
}
|
||
|
||
return modifyDockerConfigFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifyDockerConfigExec(args []string) (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) installHarbor() [][]string {
|
||
|
||
installHarborFunc := [][]string{
|
||
//{
|
||
// "mkdir",
|
||
// "-p",
|
||
// "/root/wdd/",
|
||
//},
|
||
//{
|
||
// "rm",
|
||
// "-rf",
|
||
// "/root/wdd/harbor-offline-installer-v2.1.0.tgz",
|
||
//},
|
||
//{
|
||
// "wget",
|
||
// "--no-check-certificate",
|
||
// g.BaseFuncOssUrlPrefix + "harbor-offline-installer-v2.1.0.tgz",
|
||
// "-O",
|
||
// "/root/wdd/harbor-offline-installer-v2.1.0.tgz",
|
||
//},
|
||
{
|
||
"tar",
|
||
"-zvxf",
|
||
"/root/wdd/harbor-offline-installer-v2.1.0.tgz",
|
||
"-C",
|
||
"/root/wdd/",
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/wdd/harbor/harbor.yml",
|
||
},
|
||
{
|
||
"wget",
|
||
"--no-check-certificate",
|
||
g.BaseFuncOssUrlPrefix + "harbor-config-template.yml",
|
||
"-O",
|
||
"/root/wdd/harbor/harbor.yml",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/$HarborHostName/" + op.AgentServerInfo.ServerIPInV4 + "/g",
|
||
"/root/wdd/harbor/harbor.yml",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/$HarborHostPort/8033/g",
|
||
"/root/wdd/harbor/harbor.yml",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/$HarborHostPort/V2ryStr@ngPss/g",
|
||
"/root/wdd/harbor/harbor.yml",
|
||
},
|
||
{
|
||
"/root/wdd/harbor/install.sh",
|
||
"--with-chartmuseum",
|
||
},
|
||
}
|
||
|
||
return installHarborFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) installHarborExec() (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) chronyToPublicNTP() [][]string {
|
||
|
||
serverIPInV4 := op.AgentServerInfo.ServerIPInV4
|
||
internalIPCIDR := strings.Join(strings.Split(serverIPInV4, ".")[:2], ".") + ".0.0/16"
|
||
|
||
chronyToPublicNTPFunc := [][]string{
|
||
append(
|
||
op.InstallCommandPrefix,
|
||
"chrony",
|
||
),
|
||
{
|
||
"systemctl",
|
||
"enable",
|
||
"chronyd",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"start",
|
||
"chronyd",
|
||
},
|
||
}
|
||
|
||
var chronyFile string
|
||
if op.IsOsTypeUbuntu {
|
||
chronyFile = "/etc/chrony/chrony.conf"
|
||
} else {
|
||
chronyFile = "/etc/chrony.conf"
|
||
}
|
||
|
||
chronyToPublicNTPFunc = append(chronyToPublicNTPFunc,
|
||
[][]string{
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"$ a allow " + internalIPCIDR,
|
||
chronyFile,
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/pool ntp.ubuntu.com iburst/server ntp2.aliyun.com iburst/g",
|
||
chronyFile,
|
||
},
|
||
{
|
||
"systemctl",
|
||
"restart",
|
||
"chronyd",
|
||
},
|
||
{
|
||
"sleep",
|
||
"2",
|
||
},
|
||
{
|
||
"chronyc",
|
||
"-n",
|
||
"sources",
|
||
"-v",
|
||
},
|
||
{
|
||
"chronyc",
|
||
"tracking",
|
||
},
|
||
{
|
||
"timedatectl",
|
||
"set-timezone",
|
||
"Asia/Shanghai",
|
||
},
|
||
{
|
||
"timedatectl",
|
||
"set-ntp",
|
||
"true",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"restart",
|
||
"rsyslog",
|
||
},
|
||
}...,
|
||
)
|
||
|
||
return chronyToPublicNTPFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) chronyToPublicNTPExec() (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) chronyToMaster(args []string) [][]string {
|
||
masterInnerIP := args[0]
|
||
|
||
chronyToMasterFunc := [][]string{
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"$ a NTP=" + masterInnerIP,
|
||
"/etc/systemd/timesyncd.conf",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"daemon-reload",
|
||
},
|
||
{
|
||
"systemctl",
|
||
"restart",
|
||
"systemd-timesyncd.service",
|
||
},
|
||
{
|
||
"sleep",
|
||
"3",
|
||
},
|
||
{
|
||
"timedatectl",
|
||
"show-timesync",
|
||
"--all",
|
||
},
|
||
{
|
||
"timedatectl",
|
||
"status",
|
||
},
|
||
}
|
||
|
||
return chronyToMasterFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) chronyToMasterExec(args []string) (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) installZSH() [][]string {
|
||
|
||
installZSHFunc := [][]string{
|
||
{
|
||
"mkdir",
|
||
"-p",
|
||
"/root/wdd/",
|
||
},
|
||
append(
|
||
op.InstallCommandPrefix,
|
||
"zsh",
|
||
"git",
|
||
),
|
||
}
|
||
|
||
if op.IsAgentInnerWall {
|
||
installZSHFunc = append(
|
||
installZSHFunc,
|
||
[][]string{
|
||
{
|
||
"wget",
|
||
"https://cdn.jsdelivr.net/gh/robbyrussell/oh-my-zsh@master/tools/install.sh",
|
||
"-O",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
}...,
|
||
)
|
||
|
||
} else {
|
||
installZSHFunc = append(
|
||
installZSHFunc,
|
||
[][]string{
|
||
{
|
||
"wget",
|
||
"https://raw.githubusercontent.com/ohmyzsh/ohmyzsh/master/tools/install.sh",
|
||
"-O",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
}...,
|
||
)
|
||
}
|
||
|
||
// install
|
||
installZSHFunc = append(
|
||
installZSHFunc,
|
||
[][]string{
|
||
{
|
||
"chmod",
|
||
"+x",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
{
|
||
"sh",
|
||
"-c",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
}...,
|
||
)
|
||
|
||
// modify ZSH
|
||
if !op.IsAgentInnerWall {
|
||
installZSHFunc = append(
|
||
installZSHFunc,
|
||
[][]string{
|
||
{
|
||
"git",
|
||
"clone",
|
||
"https://github.com/zsh-users/zsh-autosuggestions",
|
||
"/root/.oh-my-zsh/plugins/zsh-autosuggestions",
|
||
},
|
||
{
|
||
"git",
|
||
"clone",
|
||
"https://github.com/zsh-users/zsh-syntax-highlighting.git",
|
||
"/root/.oh-my-zsh/plugins/zsh-syntax-highlighting",
|
||
},
|
||
{
|
||
"wget",
|
||
"https://b2.107421.xyz/oh-my-zsh-plugins-list.txt",
|
||
"-O",
|
||
"oh-my-zsh-plugins-list.txt",
|
||
},
|
||
{
|
||
"wget",
|
||
"-c",
|
||
"-i",
|
||
"./oh-my-zsh-plugins-list.txt",
|
||
"-P",
|
||
"/root/.oh-my-zsh/plugins/",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/robbyrussell/agnoster/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/^# DISABLE_AUTO_UPDATE=\"true\"/DISABLE_AUTO_UPDATE=\"true\"/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/plugins=(git)/plugins=(git zsh-autosuggestions zsh-syntax-highlighting command-not-found z themes)/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"source",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"chsh",
|
||
"-s",
|
||
"/bin/zsh",
|
||
},
|
||
{
|
||
"zsh",
|
||
},
|
||
}...,
|
||
)
|
||
}
|
||
|
||
return installZSHFunc
|
||
}
|
||
|
||
func (op *AgentOsOperator) installZSHExec() (bool, []string) {
|
||
|
||
log.Info("开始安装ZSH!")
|
||
ok, resultLog := AllCompleteExecutor([][]string{
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/.oh-my-zsh",
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
{
|
||
"rm",
|
||
"-rf",
|
||
"/root/wdd/oh-my-zsh-plugins-list.txt",
|
||
},
|
||
{
|
||
"mkdir",
|
||
"-p",
|
||
"/root/wdd/",
|
||
},
|
||
append(
|
||
op.InstallCommandPrefix,
|
||
"zsh",
|
||
"git",
|
||
),
|
||
})
|
||
if !ok {
|
||
return false, resultLog
|
||
}
|
||
log.InfoF("ZSH环境已经清理, 完成基础安装! 开始安装oh-my-zsh!")
|
||
|
||
var zshRemoteGitUrl string
|
||
if op.IsAgentInnerWall {
|
||
zshRemoteGitUrl = "https://gitee.com/mirrors/oh-my-zsh/raw/master/tools/install.sh"
|
||
} else {
|
||
zshRemoteGitUrl = "https://gitee.com/mirrors/oh-my-zsh/raw/master/tools/install.sh"
|
||
}
|
||
log.InfoF("开始下载zsh的安装脚本 => %s", zshRemoteGitUrl)
|
||
resultOk, l := AllCommandExecutor([]string{
|
||
"wget",
|
||
"--timeout=5",
|
||
zshRemoteGitUrl,
|
||
"-qO",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
)
|
||
if !resultOk {
|
||
l = append(l, "zsh-install.sh 下载失败！ 安装终止")
|
||
return false, l
|
||
}
|
||
|
||
executor, log2 := AllCompleteExecutor([][]string{
|
||
{
|
||
"chmod",
|
||
"+x",
|
||
"/root/wdd/zsh-install.sh",
|
||
},
|
||
{
|
||
"/bin/bash",
|
||
"/root/wdd/zsh-install.sh",
|
||
"REMOTE=https://gitee.com/mirrors/oh-my-zsh.git",
|
||
},
|
||
},
|
||
)
|
||
if !executor {
|
||
return false, log2
|
||
}
|
||
|
||
log.Info("zsh安装完成! 开始进行zsh的配置!")
|
||
zshAutoSourcePath := "https://github.com/zsh-users/zsh-autosuggestions"
|
||
zshHighLightingSourcePath := "https://github.com/zsh-users/zsh-syntax-highlighting.git"
|
||
if op.IsAgentInnerWall {
|
||
zshAutoSourcePath = "https://gitee.com/wangl-cc/zsh-autosuggestions.git"
|
||
zshHighLightingSourcePath = "https://gitee.com/xiaoqqya/zsh-syntax-highlighting.git"
|
||
}
|
||
|
||
modifyZSHOK, log3 := AllCompleteExecutor(
|
||
[][]string{
|
||
{
|
||
"git",
|
||
"clone",
|
||
zshAutoSourcePath,
|
||
"/root/.oh-my-zsh/plugins/zsh-autosuggestions",
|
||
},
|
||
{
|
||
"git",
|
||
"clone",
|
||
zshHighLightingSourcePath,
|
||
"/root/.oh-my-zsh/plugins/zsh-syntax-highlighting",
|
||
},
|
||
{
|
||
"wget",
|
||
op.OssOfflinePrefix + "oh-my-zsh-plugins-list.txt",
|
||
"-O",
|
||
"/root/wdd/oh-my-zsh-plugins-list.txt",
|
||
},
|
||
{
|
||
"wget",
|
||
"-c",
|
||
"-i",
|
||
"/root/wdd/oh-my-zsh-plugins-list.txt",
|
||
"-P",
|
||
"/root/.oh-my-zsh/plugins/",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/robbyrussell/agnoster/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/^# DISABLE_AUTO_UPDATE=\"true\"/DISABLE_AUTO_UPDATE=\"true\"/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"sed",
|
||
"-i",
|
||
"s/plugins=(git)/plugins=(git zsh-autosuggestions zsh-syntax-highlighting command-not-found z themes)/g",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
".",
|
||
"/root/.zshrc",
|
||
},
|
||
{
|
||
"chsh",
|
||
"-s",
|
||
"/bin/zsh",
|
||
},
|
||
{
|
||
"zsh",
|
||
},
|
||
})
|
||
if !modifyZSHOK {
|
||
log.Warn("ZSH 安装成功，但是配置修改失败！")
|
||
return true, log3
|
||
}
|
||
|
||
return true, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifySshPort(args []string) [][]string {
|
||
|
||
return [][]string{}
|
||
}
|
||
|
||
func (op *AgentOsOperator) modifySshPortExec(args []string) (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) openBBR() [][]string {
|
||
|
||
return [][]string{}
|
||
}
|
||
|
||
func (op *AgentOsOperator) openBBRExec() (bool, []string) {
|
||
return false, nil
|
||
}
|
||
|
||
func (op *AgentOsOperator) ok(args []string) [][]string {
|
||
log.InfoF("base function is ok , args are => " + strings.Join(args, " "))
|
||
return [][]string{
|
||
{"ifconfig"},
|
||
}
|
||
}
|
||
|
||
func (op *AgentOsOperator) okExec(args []string) (bool, []string) {
|
||
return true, nil
|
||
}
|