| | |
| | | } |
| | | |
| | | //启动服务 |
| | | func StartServer(binPath string, ip string) bool { |
| | | resultMsg := CMDSC("sh " + binPath + "/elasticsearch -d") |
| | | func StartServer(binPath string, ip string, port string) bool { |
| | | resultMsg := CMDSC("sh " + binPath + "/es_start.sh") |
| | | if resultMsg == "运行失败" { |
| | | return false |
| | | } |
| | | bool := VerifyNodeServer(ip, "9200") |
| | | return bool |
| | | b := VerifyNodeServer(ip, port) |
| | | return b |
| | | } |
| | | |
| | | //关闭服务 |
| | | func StopServer(binPath string) { |
| | | |
| | | func StopServer(binPath string, ip string, port string) bool { |
| | | b := VerifyShortNodeServer(ip, port) |
| | | if b == true { |
| | | resultMsg := CMDSC("sh " + binPath + "/es_stop.sh") |
| | | if resultMsg == "运行失败" { |
| | | return false |
| | | } |
| | | } |
| | | return b |
| | | } |
| | | |
| | | //更换节点角色 |
| | |
| | | if err := v.WriteConfig(); err != nil { |
| | | return false, err |
| | | } |
| | | return true,nil |
| | | return true, nil |
| | | } |
| | | |
| | | //更新组播列表 |