From 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 08 十月 2023 11:24:37 +0800
Subject: [PATCH] 修复集群同步功能
---
system-service/main.go | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/system-service/main.go b/system-service/main.go
index 168e931..8e6fd0a 100644
--- a/system-service/main.go
+++ b/system-service/main.go
@@ -3,6 +3,7 @@
import (
"context"
"flag"
+ "fmt"
_ "net/http/pprof"
"os"
"os/signal"
@@ -60,7 +61,7 @@
Proc: *proc,
Channel: nil,
PubTopic: pubTopics,
- SubTopic: []string{versionControlS.AuthorizationUpdateTopic},
+ SubTopic: []string{versionControlS.AuthorizationUpdateTopic, "sync-proc-message-to-serf"},
SubNetTopic: []string{},
}
@@ -74,7 +75,7 @@
bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic)
bhomedbapi.InitDoReq(ms.RequestOnly)
- //bhomedbapi.InitLog(logger.Debug)
+ bhomedbapi.InitLog(logger.Debug)
//util.AuthCheck(ctx) //鎺堟潈妫�鏌�
@@ -178,6 +179,7 @@
funcMap[urlPrefix+"/cluster/updateClusterName"] = clusterController.UpdateClusterName
funcMap[urlPrefix+"/cluster/leave"] = clusterController.Leave
funcMap[urlPrefix+"/cluster/findIpByNode"] = clusterController.FindIpByNode
+ funcMap[urlPrefix+"/cluster/status"] = clusterController.GetClusterStat
sysMenuC := new(controllers.SysMenuController)
funcMap["/data/api-u/sysmenus/tree"] = sysMenuC.MenuTree
@@ -271,11 +273,13 @@
for key, _ := range funcMap {
pubTopics = append(pubTopics, key)
}
+
return funcMap, pubTopics
}
// 娴嬭瘯鎺ユ敹鍏ㄧ綉娑堟伅
func dealSubMsg(ctx context.Context, ms *bhomeclient.MicroNode) {
+ fmt.Println("dealSubMsg")
for {
select {
case <-ctx.Done():
--
Gitblit v1.8.0