From 55aa27a6ad0e012d62dcea2db37528a1b18836fb Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期四, 07 九月 2023 16:44:09 +0800
Subject: [PATCH] 裁剪集群操作的无关动作
---
system-service/main.go | 19 +++++++++++--------
1 files changed, 11 insertions(+), 8 deletions(-)
diff --git a/system-service/main.go b/system-service/main.go
index eebb524..f95fe17 100644
--- a/system-service/main.go
+++ b/system-service/main.go
@@ -3,13 +3,12 @@
import (
"context"
"flag"
- "net/http"
_ "net/http/pprof"
"os"
"os/signal"
"syscall"
"vamicro/config"
- "vamicro/extend/util"
+ //"vamicro/extend/util"
"vamicro/system-service/broadcast"
"vamicro/system-service/controllers"
"vamicro/system-service/models"
@@ -68,29 +67,33 @@
q := make(chan os.Signal, 1)
signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)
- ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug)
+ ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, nil)
if err != nil {
return
}
bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic)
bhomedbapi.InitDoReq(ms.RequestOnly)
- bhomedbapi.InitLog(logger.Debug)
+ //bhomedbapi.InitLog(logger.Debug)
- util.AuthCheck(ctx) //鎺堟潈妫�鏌�
+ //util.AuthCheck(ctx) //鎺堟潈妫�鏌�
+
go ms.StartServer(fm)
go dealSubMsg(ctx, ms)
+
serf.InitBusH(ms)
serf.InitAgent(ctx)
- go service.WatchEsAndWeedfsIp(ms)
+ //go service.WatchEsAndWeedfsIp(ms)
go serf.StartSyncSqlToSerf()
- go service.StartSyncDev()
+ //go service.StartSyncDev()
+
go broadcast.StartServer() //璁惧鍙互琚箍鎾悳绱�
+
//go service.CollectDeviceInfo(ctx, ms)
- go service.WatchAuthSetChange(ms) //鏍规嵁鎺堟潈鏂囦欢鐩戣閫氶亾鏁伴噺鍙樺寲
+ //go service.WatchAuthSetChange(ms) //鏍规嵁鎺堟潈鏂囦欢鐩戣閫氶亾鏁伴噺鍙樺寲
//缁熻绯荤粺杩愯鐘舵��
go sys.GatherStat()
--
Gitblit v1.8.0