| | |
| | | if resultMsg == "运行失败" { |
| | | return false |
| | | } |
| | | b := VerifyNodeServer(ip, port) |
| | | return b |
| | | return true |
| | | } |
| | | |
| | | //关闭服务 |
| | |
| | | } |
| | | |
| | | //验证该节点是否被使用过 |
| | | func VerifyCreated(configPath string, ip string) (bool, error) { |
| | | func VerifyCreated(configPath string) (bool, error) { |
| | | v := viper.New() |
| | | v.SetConfigType("yml") |
| | | v.SetConfigName("elasticsearch") |
| | |
| | | return true, err |
| | | } |
| | | hosts := v.GetStringSlice("discovery.zen.ping.unicast.hosts") |
| | | for _, pick := range hosts { |
| | | if pick == ip { |
| | | return true, errors.New("该节点已经被执行“创建集群”") |
| | | } |
| | | } |
| | | if len(hosts) > 1 { |
| | | return true, errors.New("该节点已经被执行“加入集群”") |
| | | return true, errors.New("该节点已经被使用") |
| | | } |
| | | return false, nil |
| | | } |