From 8a415b25377a63c638eea4875a0791667421ba9a Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期一, 19 十月 2020 10:19:14 +0800
Subject: [PATCH] add info
---
ClusterApi.go | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 deletions(-)
diff --git a/ClusterApi.go b/ClusterApi.go
index 6c3c8dc..d1e0dc4 100644
--- a/ClusterApi.go
+++ b/ClusterApi.go
@@ -12,7 +12,7 @@
"strings"
"time"
)
-
+//鍒濆鍖栭厤缃枃浠�
func InitYml(configPath string) (bool, error) {
v := viper.New()
v.SetConfigType("yml")
@@ -28,6 +28,7 @@
return true, nil
}
+//鍚姩鏈嶅姟
func StartServer(binPath string, ip string) bool {
resultMsg := CMDSC("sh " + binPath + "/elasticsearch -d")
if resultMsg == "杩愯澶辫触" {
@@ -37,10 +38,12 @@
return bool
}
+//鍏抽棴鏈嶅姟
func StopServer(binPath string) {
}
+//鏇存崲鑺傜偣瑙掕壊
func UpdateNodeRole(configPath string, role string) (bool, error) {
v := viper.New()
v.SetConfigType("yml")
@@ -61,6 +64,8 @@
return true,nil
}
+
+//楠岃瘉璇ヨ妭鐐规槸鍚﹁鍒涘缓杩�
func VerifyCreated(configPath string, ip string) (bool, error) {
v := viper.New()
v.SetConfigType("yml")
@@ -82,6 +87,7 @@
return false, nil
}
+//楠岃瘉鑺傜偣鏈嶅姟鏄惁姝ｅ父鍚姩
func VerifyNodeServer(ip string, port string) bool {
b := false
url := "http://" + ip + ":" + port
@@ -101,6 +107,7 @@
return b
}
+//楠岃瘉鑺傜偣瑙掕壊
func VerifyNodeRole(configPath string, ) (string, error) {
role := "slave"
v := viper.New()
@@ -118,6 +125,7 @@
return role, nil
}
+//鏇存柊缁勬挱鍒楄〃
func UpdateDiscoveryZenPingUnicastHosts(configPath string, oldIp string, newIp string) (bool, error) {
v := viper.New()
v.SetConfigType("yml")
@@ -145,6 +153,7 @@
return true, nil
}
+//娣诲姞缁勬挱鎴愬憳
func AddDiscoveryZenPingUnicastHosts(configPath string, ip string) []string {
v := viper.New()
v.SetConfigType("yml")
@@ -166,6 +175,7 @@
NodeName string `json:"nodeName"`
}
+//鏌ヨ闆嗙兢淇℃伅
func GetClusterInfo(ip string, port string) ([]NodeInfo, error) {
url := "http://" + ip + ":" + port + "/_cat/nodes?v"
buf, err := HttpRC("GET", url, nil)
@@ -198,6 +208,7 @@
return inf, nil
}
+//鎺掗櫎鍗冲皢閫�鍑洪泦缇ょ殑鑺傜偣
func ExcludeNode(ip string, port string) (bool, error) {
flag := false
url := "http://" + ip + ":" + port + "/_cluster/settings"
@@ -218,6 +229,7 @@
return flag, nil
}
+
func CMDSC(scriptStr string) string {
cmd := exec.Command("sh", "-c", scriptStr)
var out bytes.Buffer
--
Gitblit v1.8.0