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

Merge branch 'master' of ssh://git.infini.ltd:64221/infini/console

This commit is contained in:
medcl 2022-03-25 16:21:30 +08:00
parent cfc2f4c9e8 06c86dab11
commit 7101dc3b2f
1 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
plugin/api/index_management/elasticsearch.go
View File

@ -17,13 +17,26 @@ func (handler APIHandler) ElasticsearchOverviewAction(w http.ResponseWriter, req
totalStoreSize int
clusterIDs []interface{}
)
elastic.WalkConfigs(func(key, value interface{})bool{
if handler.Config.Elasticsearch == key {
return true
}
clusterIDs = append(clusterIDs, key)
return true
})
//elastic.WalkConfigs(func(key, value interface{})bool{
// if handler.Config.Elasticsearch == key {
// return true
// }
// clusterIDs = append(clusterIDs, key)
// return true
//})
esClient := elastic.GetClient(handler.Config.Elasticsearch)
searchRes, err := esClient.SearchWithRawQueryDSL(orm.GetIndexName(elastic.ElasticsearchConfig{}), nil)
if err != nil {
log.Error(err)
handler.WriteJSON(w, util.MapStr{
"error": err.Error(),
}, http.StatusInternalServerError)
return
}
for _, hit := range searchRes.Hits.Hits {
clusterIDs = append(clusterIDs, hit.ID)
}
res, err := handler.getLatestClusterMonitorData(clusterIDs)
if err != nil {