chore: adapter node metrics query with cluster_id or cluster uuid (

#28)
infinilabs · Dec 13, 2024 · 9cb54a3 · 9cb54a3
1 parent 5a02966
commit 9cb54a3
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 6 deletions.
diff --git a/modules/elastic/api/cluster_overview.go b/modules/elastic/api/cluster_overview.go
@@ -566,9 +566,23 @@ func (h *APIHandler) GetClusterNodes(w http.ResponseWriter, req *http.Request, p
 						},
 					},
 					{
-						"term": util.MapStr{
-							"metadata.labels.cluster_uuid": util.MapStr{
-								"value": clusterUUID,
+						"bool": util.MapStr{
+							"minimum_should_match": 1,
+							"should": []util.MapStr{
+								{
+									"term": util.MapStr{
+										"metadata.labels.cluster_id": util.MapStr{
+											"value": id,
+										},
+									},
+								},
+								{
+									"term": util.MapStr{
+										"metadata.labels.cluster_uuid": util.MapStr{
+											"value": clusterUUID,
+										},
+									},
+								},
 							},
 						},
 					},

diff --git a/modules/elastic/api/node_metrics.go b/modules/elastic/api/node_metrics.go
@@ -117,9 +117,23 @@ func (h *APIHandler) getNodeMetrics(ctx context.Context, clusterID string, bucke
 
 	var must = []util.MapStr{
 		{
-			"term":util.MapStr{
-				"metadata.labels.cluster_uuid":util.MapStr{
-					"value": clusterUUID,
+			"bool": util.MapStr{
+				"minimum_should_match": 1,
+				"should": []util.MapStr{
+					{
+						"term": util.MapStr{
+							"metadata.labels.cluster_id": util.MapStr{
+								"value": clusterID,
+							},
+						},
+					},
+					{
+						"term": util.MapStr{
+							"metadata.labels.cluster_uuid": util.MapStr{
+								"value": clusterUUID,
+							},
+						},
+					},
 				},
 			},
 		},