feat: splitting metric query, adding query param key for query metric api to support single metric query (#7)

* feat: support query es cluster metrics with special key
* feat: adding context param to control metric request timeout
* feat: splitting metric query, adding query param `key` for query metric  api to support single metric query
* chore: clean unused code
* fix: wrong metric key

Author: silenceqi

modules/elastic/api/cluster_overview.go

@@ -24,6 +24,7 @@
 package api
 
 import (
+	"context"
 	"fmt"
 	"infini.sh/framework/modules/elastic/adapter"
 	"net/http"
@@ -254,7 +255,7 @@ func (h *APIHandler) FetchClusterInfo(w http.ResponseWriter, req *http.Request,
 			},
 		},
 	}
-	indexMetrics := h.getMetrics(query, indexMetricItems, bucketSize)
+	indexMetrics := h.getMetrics(context.Background(), query, indexMetricItems, bucketSize)
 	indexingMetricData := util.MapStr{}
 	for _, line := range indexMetrics["cluster_indexing"].Lines {
 		// remove first metric dot

modules/elastic/api/host.go

@@ -28,6 +28,7 @@
 package api
 
 import (
+	"context"
 	"fmt"
 	log "github.com/cihub/seelog"
 	httprouter "infini.sh/framework/core/api/router"
@@ -604,10 +605,10 @@ func (h *APIHandler) getSingleHostMetric(agentID string, min, max int64, bucketS
 			},
 		},
 	}
-	return h.getSingleMetrics(metricItems, query, bucketSize)
+	return h.getSingleMetrics(context.Background(), metricItems, query, bucketSize)
 }
 
-func (h *APIHandler) getSingleHostMetricFromNode(nodeID string, min, max int64, bucketSize int) map[string]*common.MetricItem {
+func (h *APIHandler) getSingleHostMetricFromNode(ctx context.Context, nodeID string, min, max int64, bucketSize int) map[string]*common.MetricItem {
 	var must = []util.MapStr{
 		{
 			"term": util.MapStr{
@@ -669,7 +670,7 @@ func (h *APIHandler) getSingleHostMetricFromNode(nodeID string, min, max int64,
 		return 100 - value*100/value2
 	}
 	metricItems = append(metricItems, metricItem)
-	return h.getSingleMetrics(metricItems, query, bucketSize)
+	return h.getSingleMetrics(ctx, metricItems, query, bucketSize)
 }
 
 func (h *APIHandler) GetSingleHostMetrics(w http.ResponseWriter, req *http.Request, ps httprouter.Params) {
@@ -696,7 +697,7 @@ func (h *APIHandler) GetSingleHostMetrics(w http.ResponseWriter, req *http.Reque
 		return
 	}
 	if hostInfo.AgentID == "" {
-		resBody["metrics"] = h.getSingleHostMetricFromNode(hostInfo.NodeID, min, max, bucketSize)
+		resBody["metrics"] = h.getSingleHostMetricFromNode(context.Background(), hostInfo.NodeID, min, max, bucketSize)
 		h.WriteJSON(w, resBody, http.StatusOK)
 		return
 	}
@@ -866,7 +867,7 @@ func (h *APIHandler) getGroupHostMetric(agentIDs []string, min, max int64, bucke
 			},
 		},
 	}
-	return h.getMetrics(query, hostMetricItems, bucketSize)
+	return h.getMetrics(context.Background(), query, hostMetricItems, bucketSize)
 }
 
 func getHost(hostID string) (*host.HostInfo, error) {