| | |
| | | "strings" |
| | | "time" |
| | | ) |
| | | |
| | | //初始化配置文件 |
| | | func InitYml(configPath string) (bool, error) { |
| | | v := viper.New() |
| | |
| | | if err := v.WriteConfig(); err != nil { |
| | | return false, err |
| | | } |
| | | return true,nil |
| | | return true, nil |
| | | } |
| | | |
| | | |
| | | //验证该节点是否被创建过 |
| | | func VerifyCreated(configPath string, ip string) (bool, error) { |
| | |
| | | v.AddConfigPath(configPath) |
| | | err := v.ReadInConfig() |
| | | if err != nil { |
| | | return false, err |
| | | return true, err |
| | | } |
| | | hosts := v.GetStringSlice("discovery.zen.ping.unicast.hosts") |
| | | for _, pick := range hosts { |
| | |
| | | } |
| | | } |
| | | return b |
| | | } |
| | | |
| | | //验证节点服务是否正常启动(短验证) |
| | | func VerifyShortNodeServer(ip string, port string) bool { |
| | | url := "http://" + ip + ":" + port |
| | | _, err := HttpRC("GET", url, nil) |
| | | if err != nil { |
| | | return false |
| | | } |
| | | return true |
| | | } |
| | | |
| | | //验证节点角色 |
| | |
| | | } |
| | | return flag, nil |
| | | } |
| | | |
| | | |
| | | func CMDSC(scriptStr string) string { |
| | | cmd := exec.Command("sh", "-c", scriptStr) |