fix: lbagent master fixes (#15331)

Co-authored-by: Qiu Jian <qiujian@yunionyun.com>
This commit is contained in:
Jian Qiu
2022-11-28 13:08:52 +08:00
committed by GitHub
co-authored by Qiu Jian
parent 36e0f56a07
commit 5a1c786650
2 changed files with 18 additions and 19 deletions
+14 -19
View File
@@ -138,11 +138,13 @@ func (lbagent *SLoadbalancerAgent) deploy(ctx context.Context, userCred mcclient
case compute_apis.DeployMethodCopy:
// glob for rpms
basenames := []string{
"packages/telegraf",
"packages/gobetween",
"packages/keepalived",
"packages/haproxy",
"updates/yunion-lbagent",
"telegraf",
"gobetween",
"keepalived",
"haproxy",
"openvswitch",
"openvswitch-ovn-host",
"yunion-lbagent",
}
mods := []ansible.Module{}
for _, basename := range basenames {
@@ -287,11 +289,12 @@ func (lbagent *SLoadbalancerAgent) validateHost(ctx context.Context, userCred mc
return nil
}
func (lbagent *SLoadbalancerAgent) PerformDeploy(ctx context.Context, userCred mcclient.TokenCredential, query jsonutils.JSONObject, data *jsonutils.JSONDict) (*jsonutils.JSONDict, error) {
input := &compute_apis.LoadbalancerAgentDeployInput{}
if err := data.Unmarshal(input); err != nil {
return nil, httperrors.NewBadRequestError("unmarshal input: %v", err)
}
func (lbagent *SLoadbalancerAgent) PerformDeploy(
ctx context.Context,
userCred mcclient.TokenCredential,
query jsonutils.JSONObject,
input *compute_apis.LoadbalancerAgentDeployInput,
) (*compute_apis.LoadbalancerAgentDeployInput, error) {
host := input.Host
for _, k := range []string{"user", "pass", "proj"} {
if v, ok := host.GetVar(k); !ok {
@@ -423,15 +426,7 @@ api_list_batch_size = 2048
yunionRepoTmpl = `
[yunion]
name=Packages for Yunion- $basearch
baseurl={{ repo_base_url }}/updates
failovermethod=priority
enabled=1
gpgcheck=0
sslverify={{ repo_sslverify }}
[yunion-extra]
name=Extra Packages for Yunion - $basearch
baseurl={{ repo_base_url }}/packages
baseurl={{ repo_base_url }}
failovermethod=priority
enabled=1
gpgcheck=0
+4
View File
@@ -502,6 +502,10 @@ func (h *HaproxyHelper) reloadKeepalived(ctx context.Context) error {
"--vrrp_pid", vrrpPidFile.Path,
"--checkers_pid", checkersPidFile.Path,
"--use-file", h.keepalivedConf(),
"-D",
"-d",
"-S",
"0",
}
return h.runCmd(args)
}