[kibana] pass unique service.address value (elastic#37178)

* unique service.address * fix stats metricset
Scholar-Li · Feb 5, 2024 · 6d9d12d · 6d9d12d
1 parent 32531c7
commit 6d9d12d
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 4 deletions.
diff --git a/metricbeat/module/kibana/cluster_actions/data.go b/metricbeat/module/kibana/cluster_actions/data.go
@@ -90,9 +90,9 @@ func eventMapping(r mb.ReporterV2, content []byte, isXpack bool) error {
 		RootFields: mapstr.M{
 			"service.id":      serviceId,
 			"service.version": version,
-			"service.address": serviceAddress,
 		},
 		MetricSetFields: actionsFields,
+		Host:            fmt.Sprintf("%v", serviceAddress),
 	}
 
 	// xpack.enabled in config using standalone metricbeat writes to `.monitoring` instead of `metricbeat-*`

diff --git a/metricbeat/module/kibana/cluster_rules/data.go b/metricbeat/module/kibana/cluster_rules/data.go
@@ -90,9 +90,9 @@ func eventMapping(r mb.ReporterV2, content []byte, isXpack bool) error {
 		RootFields: mapstr.M{
 			"service.id":      serviceId,
 			"service.version": version,
-			"service.address": serviceAddress,
 		},
 		MetricSetFields: rulesFields,
+		Host:            fmt.Sprintf("%v", serviceAddress),
 	}
 
 	// xpack.enabled in config using standalone metricbeat writes to `.monitoring` instead of `metricbeat-*`

diff --git a/metricbeat/module/kibana/node_actions/data.go b/metricbeat/module/kibana/node_actions/data.go
@@ -86,9 +86,9 @@ func eventMapping(r mb.ReporterV2, content []byte, isXpack bool) error {
 		RootFields: mapstr.M{
 			"service.id":      serviceId,
 			"service.version": version,
-			"service.address": serviceAddress,
 		},
 		MetricSetFields: actionsFields,
+		Host:            fmt.Sprintf("%v", serviceAddress),
 	}
 
 	// xpack.enabled in config using standalone metricbeat writes to `.monitoring` instead of `metricbeat-*`

diff --git a/metricbeat/module/kibana/node_rules/data.go b/metricbeat/module/kibana/node_rules/data.go
@@ -86,9 +86,9 @@ func eventMapping(r mb.ReporterV2, content []byte, isXpack bool) error {
 		RootFields: mapstr.M{
 			"service.id":      serviceId,
 			"service.version": version,
-			"service.address": serviceAddress,
 		},
 		MetricSetFields: rulesFields,
+		Host:            fmt.Sprintf("%v", serviceAddress),
 	}
 
 	// xpack.enabled in config using standalone metricbeat writes to `.monitoring` instead of `metricbeat-*`

diff --git a/metricbeat/module/kibana/stats/data.go b/metricbeat/module/kibana/stats/data.go
@@ -158,6 +158,7 @@ func eventMapping(r mb.ReporterV2, content []byte, isXpack bool) error {
 		return event.Error
 	}
 	_, _ = event.RootFields.Put("service.address", serviceAddress)
+	event.Host = fmt.Sprintf("%v", serviceAddress)
 
 	// Set process PID
 	process, ok := data["process"].(map[string]interface{})