floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add alert ignored message count

This commit is contained in:
liugq 2022-06-08 14:33:28 +08:00
parent dc73947c1c
commit e07e40774b
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
plugin/api/alerting/message.go
View File

@ -114,8 +114,8 @@ func (h *AlertAPI) getAlertMessageStats(w http.ResponseWriter, req *http.Request
}, },
}, },
} }
indexName := orm.GetWildcardIndexName(alerting.AlertMessage{})
searchRes, err := esClient.SearchWithRawQueryDSL(orm.GetWildcardIndexName(alerting.AlertMessage{}), util.MustToJSONBytes(queryDsl) ) searchRes, err := esClient.SearchWithRawQueryDSL(indexName, util.MustToJSONBytes(queryDsl) )
if err != nil { if err != nil {
h.WriteJSON(w, util.MapStr{ h.WriteJSON(w, util.MapStr{
"error": err.Error(), "error": err.Error(),
@ -135,6 +135,28 @@ func (h *AlertAPI) getAlertMessageStats(w http.ResponseWriter, req *http.Request
statusCounts[status] = 0 statusCounts[status] = 0
} }
} }
must[0] = util.MapStr{
"term": util.MapStr{
"status": util.MapStr{
"value": alerting.MessageStateIgnored,
},
},
}
queryDsl = util.MapStr{
"query": util.MapStr{
"bool": util.MapStr{
"must": must,
},
},
}
countRes, err := esClient.Count(indexName, util.MustToJSONBytes(queryDsl))
if err != nil {
h.WriteJSON(w, util.MapStr{
"error": err.Error(),
}, http.StatusInternalServerError)
return
}
statusCounts[alerting.MessageStateIgnored] = countRes.Count
h.WriteJSON(w, util.MapStr{ h.WriteJSON(w, util.MapStr{
"alert": util.MapStr{ "alert": util.MapStr{
"current": statusCounts, "current": statusCounts,