test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-12-03 04:07:51 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix bugs, user ansibleHostGroup.Name split all and etcd and other;get configpath and hostspath from environment

Browse Source
This commit is contained in:
凡羊羊 2019-08-06 22:34:13 +08:00
parent 32b7f10128
commit eb2d2e6b46
2 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
node/core/service/node_service.go
View File

@ -134,8 +134,16 @@ func (n *NodeService) writeHostsFile() error {
if err != nil { if err != nil {
return err.Err return err.Err
} }
// use default hosts file path and default install config file path // use the value of environment if it is empty use default value
erro := ansibleUtil.WriteHostsFile("/opt/rainbond/rainbond-ansible/inventory/hosts", "/opt/rainbond/rainbond-ansible/scripts/installer/global.sh", hosts) hostsFilePath := os.Getenv("HOSTS_FILE_PATH")
if hostsFilePath == "" {
hostsFilePath = "/opt/rainbond/rainbond-ansible/inventory/hosts"
}
installConfPath := os.Getenv("INSTALL_CONF_PATH")
if installConfPath == "" {
installConfPath = "/opt/rainbond/rainbond-ansible/scripts/installer/global.sh"
}
erro := ansibleUtil.WriteHostsFile(hostsFilePath, installConfPath, hosts)
if erro != nil { if erro != nil {
return err return err
} }

9
util/ansible/ansible.go
View File

@ -37,13 +37,7 @@ type AnsibleHost struct {
} }
func (a *AnsibleHost) String() string { func (a *AnsibleHost) String() string {
if a.Role.HasRule("all") {
return fmt.Sprintf("%s ansible_host=%s ansible_port=%d ip=%s port=%d role=%s", a.HostID, a.AnsibleHostIP, a.AnsibleHostPort, a.AnsibleHostIP, a.AnsibleHostPort, a.Role) return fmt.Sprintf("%s ansible_host=%s ansible_port=%d ip=%s port=%d role=%s", a.HostID, a.AnsibleHostIP, a.AnsibleHostPort, a.AnsibleHostIP, a.AnsibleHostPort, a.Role)
} else if a.Role.HasRule("etcd") {
return fmt.Sprintf("%s ansible_host=%s NODE_NAME=etcd1", a.HostID, a.AnsibleHostIP)
} else {
return fmt.Sprintf("%s ansible_host=%s", a.HostID, a.AnsibleHostIP)
}
} }
type HostsList []*AnsibleHost type HostsList []*AnsibleHost
@ -82,6 +76,8 @@ func (a *AnsibleHostGroup) String() string {
for i := range a.HostList { for i := range a.HostList {
if a.Name == "all" { if a.Name == "all" {
rebuffer.WriteString(a.HostList[i].String() + "\n") rebuffer.WriteString(a.HostList[i].String() + "\n")
} else if a.Name == "etcd" {
rebuffer.WriteString(a.HostList[i].HostID + " NODE_NAME=etcd1" + "\n")
} else { } else {
rebuffer.WriteString(a.HostList[i].HostID + "\n") rebuffer.WriteString(a.HostList[i].HostID + "\n")
} }
@ -108,6 +104,7 @@ func GetAnsibleHostConfig(name string) *AnsibleHostConfig {
"new-gateway": &AnsibleHostGroup{Name: "new-gateway"}, "new-gateway": &AnsibleHostGroup{Name: "new-gateway"},
"compute": &AnsibleHostGroup{Name: "compute"}, "compute": &AnsibleHostGroup{Name: "compute"},
"new-compute": &AnsibleHostGroup{Name: "new-compute"}, "new-compute": &AnsibleHostGroup{Name: "new-compute"},
"etcd": &AnsibleHostGroup{Name: "etcd"},
}, },
} }
} }