[datadogexporter] Deduplicate hosts for which we send running metrics

exporter/datadogexporter/metrics_translator.go

@@ -255,6 +255,7 @@ func mapHistogramMetrics(name string, slice pdata.HistogramDataPointSlice, bucke
 func mapMetrics(logger *zap.Logger, cfg config.MetricsConfig, prevPts *ttlmap.TTLMap, fallbackHost string, md pdata.Metrics, buildInfo component.BuildInfo) (series []datadog.Metric, droppedTimeSeries int) {
 	pushTime := uint64(time.Now().UTC().UnixNano())
 	rms := md.ResourceMetrics()
+	seenHosts := make(map[string]struct{})
 	for i := 0; i < rms.Len(); i++ {
 		rm := rms.At(i)
 
@@ -270,11 +271,7 @@ func mapMetrics(logger *zap.Logger, cfg config.MetricsConfig, prevPts *ttlmap.TT
 		if !ok {
 			host = fallbackHost
 		}
-
-		// Report the host as running
-		runningMetric := metrics.DefaultMetrics("metrics", host, pushTime, buildInfo)
-
-		series = append(series, runningMetric...)
+		seenHosts[host] = struct{}{}
 
 		ilms := rm.InstrumentationLibraryMetrics()
 		for j := 0; j < ilms.Len(); j++ {
@@ -317,5 +314,12 @@ func mapMetrics(logger *zap.Logger, cfg config.MetricsConfig, prevPts *ttlmap.TT
 			}
 		}
 	}
+
+	for host := range seenHosts {
+		// Report the host as running
+		runningMetric := metrics.DefaultMetrics("metrics", host, pushTime, buildInfo)
+		series = append(series, runningMetric...)
+	}
+
 	return
 }

exporter/datadogexporter/metrics_translator_test.go

@@ -556,7 +556,7 @@ func TestRunningMetrics(t *testing.T) {
 
 	assert.ElementsMatch(t,
 		runningHostnames,
-		[]string{"fallbackHostname", "resource-hostname-1", "resource-hostname-1", "resource-hostname-2"},
+		[]string{"fallbackHostname", "resource-hostname-1", "resource-hostname-2"},
 	)
 
 }

exporter/datadogexporter/translate_traces.go

@@ -73,23 +73,27 @@ func convertToDatadogTd(td pdata.Traces, fallbackHost string, cfg *config.Config
 
 	var traces []*pb.TracePayload
 
-	var runningMetrics []datadog.Metric
+	seenHosts := make(map[string]struct{})
+	var series []datadog.Metric
 	pushTime := pdata.TimestampFromTime(time.Now())
 	for i := 0; i < resourceSpans.Len(); i++ {
 		rs := resourceSpans.At(i)
 		host, ok := metadata.HostnameFromAttributes(rs.Resource().Attributes())
 		if !ok {
 			host = fallbackHost
 		}
-
+		seenHosts[host] = struct{}{}
 		payload := resourceSpansToDatadogSpans(rs, host, cfg, blk)
 		traces = append(traces, &payload)
+	}
 
-		ms := metrics.DefaultMetrics("traces", host, uint64(pushTime), buildInfo)
-		runningMetrics = append(runningMetrics, ms...)
+	for host := range seenHosts {
+		// Report the host as running
+		runningMetric := metrics.DefaultMetrics("traces", host, uint64(pushTime), buildInfo)
+		series = append(series, runningMetric...)
 	}
 
-	return traces, runningMetrics
+	return traces, series
 }
 
 func aggregateTracePayloadsByEnv(tracePayloads []*pb.TracePayload) []*pb.TracePayload {

exporter/datadogexporter/translate_traces_test.go

@@ -191,7 +191,7 @@ func TestRunningTraces(t *testing.T) {
 
 	assert.ElementsMatch(t,
 		runningHostnames,
-		[]string{"resource-hostname-1", "resource-hostname-1", "resource-hostname-2", "fallbackHost"},
+		[]string{"resource-hostname-1", "resource-hostname-2", "fallbackHost"},
 	)
 }