Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
jobily
Nightingale
提交
9c9fe800
N
Nightingale
项目概览
jobily
/
Nightingale
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
N
Nightingale
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
9c9fe800
编写于
1月 29, 2023
作者:
Y
Yening Qin
提交者:
GitHub
1月 29, 2023
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
optimize heartbeat and rule sync (#1362)
上级
9aeeaa19
变更
5
隐藏空白更改
内联
并排
Showing
5 changed file
with
7 addition
and
49 deletion
+7
-49
src/server/memsto/alert_mute_cache.go
src/server/memsto/alert_mute_cache.go
+0
-8
src/server/memsto/alert_rule_cache.go
src/server/memsto/alert_rule_cache.go
+0
-9
src/server/memsto/alert_subsribe_cache.go
src/server/memsto/alert_subsribe_cache.go
+0
-9
src/server/memsto/recording_rule_cache.go
src/server/memsto/recording_rule_cache.go
+2
-16
src/server/naming/heartbeat.go
src/server/naming/heartbeat.go
+5
-7
未找到文件。
src/server/memsto/alert_mute_cache.go
浏览文件 @
9c9fe800
...
...
@@ -9,7 +9,6 @@ import (
"github.com/toolkits/pkg/logger"
"github.com/didi/nightingale/v5/src/models"
"github.com/didi/nightingale/v5/src/server/config"
promstat
"github.com/didi/nightingale/v5/src/server/stat"
)
...
...
@@ -99,13 +98,6 @@ func loopSyncAlertMutes() {
func
syncAlertMutes
()
error
{
start
:=
time
.
Now
()
clusterNames
:=
config
.
ReaderClients
.
GetClusterNames
()
if
len
(
clusterNames
)
==
0
{
AlertRuleCache
.
Reset
()
logger
.
Warning
(
"cluster is blank"
)
return
nil
}
stat
,
err
:=
models
.
AlertMuteStatistics
(
""
)
if
err
!=
nil
{
return
errors
.
WithMessage
(
err
,
"failed to exec AlertMuteStatistics"
)
...
...
src/server/memsto/alert_rule_cache.go
浏览文件 @
9c9fe800
...
...
@@ -9,7 +9,6 @@ import (
"github.com/toolkits/pkg/logger"
"github.com/didi/nightingale/v5/src/models"
"github.com/didi/nightingale/v5/src/server/config"
promstat
"github.com/didi/nightingale/v5/src/server/stat"
)
...
...
@@ -95,14 +94,6 @@ func loopSyncAlertRules() {
func
syncAlertRules
()
error
{
start
:=
time
.
Now
()
clusterNames
:=
config
.
ReaderClients
.
GetClusterNames
()
if
len
(
clusterNames
)
==
0
{
AlertRuleCache
.
Reset
()
logger
.
Warning
(
"cluster is blank"
)
return
nil
}
stat
,
err
:=
models
.
AlertRuleStatistics
(
""
)
if
err
!=
nil
{
return
errors
.
WithMessage
(
err
,
"failed to exec AlertRuleStatistics"
)
...
...
src/server/memsto/alert_subsribe_cache.go
浏览文件 @
9c9fe800
...
...
@@ -9,7 +9,6 @@ import (
"github.com/toolkits/pkg/logger"
"github.com/didi/nightingale/v5/src/models"
"github.com/didi/nightingale/v5/src/server/config"
promstat
"github.com/didi/nightingale/v5/src/server/stat"
)
...
...
@@ -101,14 +100,6 @@ func loopSyncAlertSubscribes() {
func
syncAlertSubscribes
()
error
{
start
:=
time
.
Now
()
clusterNames
:=
config
.
ReaderClients
.
GetClusterNames
()
if
len
(
clusterNames
)
==
0
{
AlertSubscribeCache
.
Reset
()
logger
.
Warning
(
"cluster is blank"
)
return
nil
}
stat
,
err
:=
models
.
AlertSubscribeStatistics
(
""
)
if
err
!=
nil
{
return
errors
.
WithMessage
(
err
,
"failed to exec AlertSubscribeStatistics"
)
...
...
src/server/memsto/recording_rule_cache.go
浏览文件 @
9c9fe800
...
...
@@ -6,7 +6,6 @@ import (
"time"
"github.com/didi/nightingale/v5/src/models"
"github.com/didi/nightingale/v5/src/server/config"
promstat
"github.com/didi/nightingale/v5/src/server/stat"
"github.com/pkg/errors"
"github.com/toolkits/pkg/logger"
...
...
@@ -95,20 +94,7 @@ func loopSyncRecordingRules() {
func
syncRecordingRules
()
error
{
start
:=
time
.
Now
()
clusterNames
:=
config
.
ReaderClients
.
GetClusterNames
()
if
len
(
clusterNames
)
==
0
{
RecordingRuleCache
.
Reset
()
logger
.
Warning
(
"cluster is blank"
)
return
nil
}
var
clusterName
string
// 只有一个集群,使用单集群模式,如果大于1个集群,则获取全部的规则
if
len
(
clusterNames
)
==
1
{
clusterName
=
clusterNames
[
0
]
}
stat
,
err
:=
models
.
RecordingRuleStatistics
(
clusterName
)
stat
,
err
:=
models
.
RecordingRuleStatistics
(
""
)
if
err
!=
nil
{
return
errors
.
WithMessage
(
err
,
"failed to exec RecordingRuleStatistics"
)
}
...
...
@@ -120,7 +106,7 @@ func syncRecordingRules() error {
return
nil
}
lst
,
err
:=
models
.
RecordingRuleGetsByCluster
(
clusterName
)
lst
,
err
:=
models
.
RecordingRuleGetsByCluster
(
""
)
if
err
!=
nil
{
return
errors
.
WithMessage
(
err
,
"failed to exec RecordingRuleGetsByCluster"
)
}
...
...
src/server/naming/heartbeat.go
浏览文件 @
9c9fe800
...
...
@@ -57,14 +57,12 @@ func heartbeat() error {
return
err
}
if
len
(
clusters
)
==
0
{
// 实例刚刚部署,还没有在页面配置 cluster 的情况,先使用配置文件中的 cluster 上报心跳
for
i
:=
0
;
i
<
len
(
config
.
C
.
Readers
);
i
++
{
err
:=
models
.
AlertingEngineHeartbeatWithCluster
(
config
.
C
.
Heartbeat
.
Endpoint
,
config
.
C
.
Readers
[
i
]
.
ClusterName
)
if
err
!=
nil
{
logger
.
Warningf
(
"heartbeat with cluster %s err:%v"
,
config
.
C
.
Readers
[
i
]
.
ClusterName
,
err
)
continue
}
// 告警引擎页面还没有配置集群,先上报一个空的集群,让 n9e-server 实例在页面上显示出来
err
:=
models
.
AlertingEngineHeartbeatWithCluster
(
config
.
C
.
Heartbeat
.
Endpoint
,
""
)
if
err
!=
nil
{
logger
.
Warningf
(
"heartbeat with cluster %s err:%v"
,
""
,
err
)
}
logger
.
Warningf
(
"heartbeat %s no cluster"
,
config
.
C
.
Heartbeat
.
Endpoint
)
}
err
:=
models
.
AlertingEngineHeartbeat
(
config
.
C
.
Heartbeat
.
Endpoint
)
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录