fix(dbm-services): enhance perfomance of dbha redis detect #2189

TencentBlueKing · Nov 29, 2023 · 63ca8f0 · 63ca8f0
1 parent b20de46
commit 63ca8f0
Show file tree

Hide file tree

Showing 2 changed files with 40 additions and 20 deletions.
diff --git a/dbm-services/common/dbha/ha-module/dbmodule/redis/rediscluster_callback.go b/dbm-services/common/dbha/ha-module/dbmodule/redis/rediscluster_callback.go
@@ -37,24 +37,36 @@ func RedisClusterNewIns(instances []interface{},
 		// create detect instance by machine_type
 		if uIns.MetaType == constvar.RedisMetaType {
 			redisIns = append(redisIns, NewRedisDetectInstance(uIns, conf))
-			count, _ := GetInstancePass(constvar.RedisMetaType, redisIns, conf)
-			if count != len(redisIns) {
-				log.Logger.Errorf("RedisCluster redis passwd part failed,succ:%d,total:%d",
-					count, len(redisIns))
-			}
 		} else if uIns.MetaType == constvar.TwemproxyMetaType {
 			twemIns = append(twemIns, NewTwemproxyDetectInstance(uIns, conf))
-			count, _ := GetInstancePass(constvar.TwemproxyMetaType, twemIns, conf)
-			if count != len(twemIns) {
-				log.Logger.Errorf("RedisCluster twemproxy passwd part failed,succ:%d,total:%d",
-					count, len(twemIns))
-			}
 		} else {
 			log.Logger.Errorf("RedisCluster cluster is %s but meta type is invalid",
 				constvar.RedisCluster)
 		}
 	}
 
+	// get redis instance passwd
+	if len(redisIns) > 0 {
+		count, _ := GetInstancePass(constvar.RedisMetaType, redisIns, conf)
+		if count != len(redisIns) {
+			log.Logger.Errorf("RedisCluster redis passwd part failed,succ:%d,total:%d",
+			count, len(redisIns))
+		} else {
+			log.Logger.Infof("RedisCluster redis passwd all get, count:%d", count)
+		}
+	}
+
+	// get twemproxy instance passwd
+	if len(twemIns) > 0 {
+		count, _ := GetInstancePass(constvar.TwemproxyMetaType, twemIns, conf)
+		if count != len(twemIns) {
+			log.Logger.Errorf("RedisCluster twemproxy passwd part failed,succ:%d,total:%d",
+			count, len(twemIns))
+		} else {
+			log.Logger.Infof("RedisCluster twemproxy passwd all get, count:%d", count)
+		}
+	}
+
 	ret = append(ret, redisIns...)
 	ret = append(ret, twemIns...)
 	return ret, err

diff --git a/dbm-services/common/dbha/ha-module/dbmodule/redis/tendiscluster_callback.go b/dbm-services/common/dbha/ha-module/dbmodule/redis/tendiscluster_callback.go
@@ -36,24 +36,32 @@ func TendisClusterNewIns(instances []interface{},
 		// create detect instance by machine_type
 		if uIns.MetaType == constvar.TendisplusMetaType {
 			tendisIns = append(tendisIns, NewTendisplusDetectInstance(uIns, conf))
-			count, _ := GetInstancePass(constvar.TendisplusMetaType, tendisIns, conf)
-			if count != len(tendisIns) {
-				log.Logger.Errorf("TendisCluster tendisplus passwd part failed,succ:%d,total:%d",
-					count, len(tendisIns))
-			}
 		} else if uIns.MetaType == constvar.PredixyMetaType {
 			predixyIns = append(predixyIns, NewPredixyDetectInstance(uIns, conf))
-			count, _ := GetInstancePass(constvar.PredixyMetaType, predixyIns, conf)
-			if count != len(predixyIns) {
-				log.Logger.Errorf("TendisCluster predixy passwd part failed,succ:%d,total:%d",
-					count, len(predixyIns))
-			}
 		} else {
 			log.Logger.Errorf("TendisCluster cluster is %s but meta type is invalid",
 				constvar.TendisplusCluster)
 		}
 	}
 
+	// get tendisplus passwd
+	if len(tendisIns) > 0 {
+		count, _ := GetInstancePass(constvar.TendisplusMetaType, tendisIns, conf)
+		if count != len(tendisIns) {
+			log.Logger.Errorf("TendisCluster tendisplus passwd part failed,succ:%d,total:%d",
+			count, len(tendisIns))
+		}
+	}
+
+	// get predixy passwd
+	if len(predixyIns) > 0 {
+		count, _ := GetInstancePass(constvar.PredixyMetaType, predixyIns, conf)
+		if count != len(predixyIns) {
+			log.Logger.Errorf("TendisCluster predixy passwd part failed,succ:%d,total:%d",
+				count, len(predixyIns))
+		}
+	}
+
 	ret = append(ret, tendisIns...)
 	ret = append(ret, predixyIns...)
 	return ret, err