crontask/cron_task.go
@@ -9,6 +9,7 @@ "apsClient/pkg/logx" "apsClient/serf" "apsClient/service" "apsClient/service/problem" "fmt" "github.com/go-co-op/gocron" "github.com/spf13/cast" @@ -82,6 +83,7 @@ } s.Every(10).Seconds().Do(QueryClusterStatus) //查询集群节点数量 s.Every(30).Seconds().Do(ProblemCheck) //问题诊断 s.StartAsync() return nil @@ -162,3 +164,7 @@ conf.Conf.SerfClusterStatus = clusterStatus conf.Conf.ClusterNodeQuantity = nodeQuantity } func ProblemCheck() { problem.Check() }