package controllers
|
|
import (
|
"basic.com/pubsub/esutil.git"
|
"basic.com/valib/bhomeclient.git"
|
"vamicro/config"
|
"vamicro/system-service/sys"
|
)
|
|
type SyncEsNodeController struct {
|
}
|
|
type HostInfo struct {
|
BinPath string `json:"binPath"`
|
ConfigPath string `json:"configPath"`
|
Hosts []string `json:"hosts"`
|
}
|
|
//同步Hosts
|
func (sen *SyncEsNodeController) SynchronizeHosts(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var hi HostInfo
|
c.BindJSON(&hi)
|
localIp, _, _ := sys.GetLocalIP(config.Server.NetworkAdapter)
|
localPort := "9200"
|
sp := esutil.StopServer(hi.BinPath, localIp, localPort)
|
if sp == false {
|
return &bhomeclient.Reply{Msg: "配置文件错误，本机ip获取失败"}
|
}
|
_, errS := esutil.SetDiscoveryZenPingUnicastHosts(hi.ConfigPath, hi.Hosts)
|
if errS != nil {
|
return &bhomeclient.Reply{Msg: errS.Error()}
|
}
|
st := esutil.StartServer(hi.BinPath, localIp, localPort)
|
if st == false {
|
return &bhomeclient.Reply{Msg: "服务启动超时"}
|
}
|
return &bhomeclient.Reply{Success: true, Msg: "修改成功"}
|
}
|
