add set hosts

sunty

2020-10-19 c5301a614f367854d9548179fd4a4b6b9964bf34

add set hosts

 ClusterApi.go

@@ -65,7 +65,7 @@
    return true, nil
}

//验证该节点是否被创建过
//验证该节点是否被使用过
func VerifyCreated(configPath string, ip string) (bool, error) {
    v := viper.New()
    v.SetConfigType("yml")
@@ -135,6 +135,22 @@
    return role, nil
}

func SetDiscoveryZenPingUnicastHosts(configPath string, hosts []string) (bool, error) {
    v := viper.New()
    v.SetConfigType("yml")
    v.SetConfigName("elasticsearch")
    v.AddConfigPath(configPath)
    err := v.ReadInConfig()
    if err != nil {
        return false, err
    }
    v.Set("discovery.zen.ping.unicast.hosts", hosts)
    if err := v.WriteConfig(); err != nil {
        return false, err
    }
    return true,nil
}

//更新组播列表
func UpdateDiscoveryZenPingUnicastHosts(configPath string, oldIp string, newIp string) (bool, error) {
    v := viper.New()
@@ -164,18 +180,22 @@
}

//添加组播成员
func AddDiscoveryZenPingUnicastHosts(configPath string, ip string) []string {
func AddDiscoveryZenPingUnicastHosts(configPath string, ip string) (bool, error) {
    v := viper.New()
    v.SetConfigType("yml")
    v.SetConfigName("elasticsearch")
    v.AddConfigPath(configPath)
    err := v.ReadInConfig()
    if err != nil {

    errR := v.ReadInConfig()
    if errR != nil {
        return false, errR
    }
    hosts := v.GetStringSlice("discovery.zen.ping.unicast.hosts")
    hosts = append(hosts, ip)
    return hosts
    v.Set("discovery.zen.ping.unicast.hosts", hosts)
    if errW := v.WriteConfig(); errW != nil {
        return false, errW
    }
    return true, nil
}

type NodeInfo struct {