From 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 08 十月 2023 11:24:37 +0800
Subject: [PATCH] 修复集群同步功能
---
sysinfo-service/main.go | 28 +++++++++++++++-------------
1 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/sysinfo-service/main.go b/sysinfo-service/main.go
index 23e3e25..7e56ff0 100644
--- a/sysinfo-service/main.go
+++ b/sysinfo-service/main.go
@@ -18,10 +18,10 @@
var (
procName = service.ProcName
- proc = &bhomeclient.ProcInfo{
+ proc = &bhomeclient.ProcInfo{
Name: procName, //杩涚▼鍚嶇О
- ID: procName, //杩涚▼id
- Info: "", //杩涚▼鐨勬弿杩颁俊鎭紝鐢ㄤ簬鍖哄垎鍚屼竴杩涚▼鍚嶇О涓嬪涓繘绋�
+ ID: procName, //杩涚▼id
+ Info: "", //杩涚▼鐨勬弿杩颁俊鎭紝鐢ㄤ簬鍖哄垎鍚屼竴杩涚▼鍚嶇О涓嬪涓繘绋�
}
env = flag.String("e", "pro", "")
)
@@ -33,24 +33,24 @@
config.Init(*env)
// 鏃ュ織鍒濆鍖�
- var logFile = config.LogConf.Path + "vamicro-"+procName+".log"
+ var logFile = config.LogConf.Path + "vamicro-" + procName + ".log"
logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
logger.Info("log init success !")
}
-func main(){
+func main() {
// pprof 鐢ㄤ簬鍒嗘瀽鎬ц兘
//go func() {
// logger.Info(http.ListenAndServe("0.0.0.0:6079", nil))
//}()
- fm,pubTopics := initFuncMap()
+ fm, pubTopics := initFuncMap()
ctx, cancel := context.WithCancel(context.Background())
- var reg = &bhomeclient.RegisterInfo {
- Proc: *proc,
- Channel: nil,
- PubTopic: pubTopics,
- SubTopic: []string{},
+ var reg = &bhomeclient.RegisterInfo{
+ Proc: *proc,
+ Channel: nil,
+ PubTopic: pubTopics,
+ SubTopic: []string{},
SubNetTopic: []string{},
}
@@ -58,7 +58,7 @@
signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)
ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug)
- if err !=nil {
+ if err != nil {
return
}
@@ -76,6 +76,7 @@
}
const urlPrefix = "/data/api-v"
+
func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
funcMap := make(map[string]bhomeclient.MicroFunc)
@@ -84,8 +85,9 @@
funcMap[urlPrefix+"/sysinfo/showProcesses"] = controllers.ShowVasystemProcesses
var pubTopics []string
- for key,_ := range funcMap {
+ for key, _ := range funcMap {
pubTopics = append(pubTopics, key)
}
+
return funcMap, pubTopics
}
--
Gitblit v1.8.0