[prometheusreceiver] Add attributes from target_info metric

CHANGELOG.md

@@ -39,6 +39,7 @@
 - `mezmoexporter`: add logging for HTTP errors (#10875)
 - `signalfxexporter`: Enable the exporting of seven Kubernetes metrics used in Splunk/SignalFx content by default (#11032)
 - `googlecloudexporter`: Support writing to multiple GCP projects by setting the `gcp.project.id` resource attribute, and support service account impersonation (#11051)
+- `prometheusreceiver`: Add `target_info` labels to resource attributes. (#11034)
 - `k8sattributeprocessor`: Add debug logs to help identify missing attributes (#11060)
 - `jmxreceiver`: Add latest releases of jmx metrics gatherer & wildfly jar to supported jars hash list (#11134)
 - `rabbitmqreceiver`: Add integration test for rabbitmq receiver (#10865)

receiver/prometheusreceiver/internal/otlp_transaction.go

@@ -32,6 +32,10 @@ import (
 	"go.uber.org/zap"
 )
 
+const (
+	targetMetricName = "target_info"
+)
+
 type transaction struct {
 	isNew                bool
 	ctx                  context.Context
@@ -89,6 +93,12 @@ func (t *transaction) Append(ref storage.SeriesRef, labels labels.Labels, atMs i
 		}
 	}
 
+	// For the `target_info` metric we need to convert it to resource attributes.
+	metricName := labels.Get(model.MetricNameLabel)
+	if metricName == targetMetricName {
+		return 0, t.AddTargetInfo(labels)
+	}
+
 	return 0, t.metricBuilder.AddDataPoint(labels, atMs, value)
 }
 
@@ -157,6 +167,20 @@ func (t *transaction) Rollback() error {
 	return nil
 }
 
+func (t *transaction) AddTargetInfo(labels labels.Labels) error {
+	attrs := t.nodeResource.Attributes()
+
+	for _, lbl := range labels {
+		if lbl.Name == model.JobLabel || lbl.Name == model.InstanceLabel || lbl.Name == model.MetricNameLabel {
+			continue
+		}
+
+		attrs.UpsertString(lbl.Name, lbl.Value)
+	}
+
+	return nil
+}
+
 func pdataTimestampFromFloat64(ts float64) pcommon.Timestamp {
 	secs := int64(ts)
 	nanos := int64((ts - float64(secs)) * 1e9)

receiver/prometheusreceiver/metrics_receiver_labels_test.go

@@ -685,3 +685,51 @@ func verifyRelabelJobInstance(t *testing.T, td *testData, rms []*pmetric.Resourc
 			}),
 	})
 }
+
+const targetResourceAttsInTargetInfo = `
+# HELP jvm_memory_bytes_used Used bytes of a given JVM memory area.
+# TYPE jvm_memory_bytes_used gauge
+jvm_memory_bytes_used{area="heap"} 100
+# HELP target_info has the resource attributes
+# TYPE target_info gauge
+target_info{foo="bar", team="infra"} 1
+`
+
+func TestTargetInfoResourceAttributes(t *testing.T) {
+	targets := []*testData{
+		{
+			name: "target1",
+			pages: []mockPrometheusResponse{
+				{code: 200, data: targetResourceAttsInTargetInfo},
+			},
+			validateFunc: verifyTargetInfoResourceAttributes,
+		},
+	}
+
+	testComponent(t, targets, false, "")
+}
+
+func verifyTargetInfoResourceAttributes(t *testing.T, td *testData, rms []*pmetric.ResourceMetrics) {
+	verifyNumValidScrapeResults(t, td, rms)
+	require.Greater(t, len(rms), 0, "At least one resource metric should be present")
+
+	wantAttributes := td.attributes
+	wantAttributes.InsertString("foo", "bar")
+	wantAttributes.InsertString("team", "infra")
+
+	metrics1 := rms[0].ScopeMetrics().At(0).Metrics()
+	ts1 := metrics1.At(0).Gauge().DataPoints().At(0).Timestamp()
+	doCompare(t, "relabel-job-instance", wantAttributes, rms[0], []testExpectation{
+		assertMetricPresent("jvm_memory_bytes_used",
+			compareMetricType(pmetric.MetricDataTypeGauge),
+			[]dataPointExpectation{
+				{
+					numberPointComparator: []numberPointComparator{
+						compareTimestamp(ts1),
+						compareDoubleValue(100),
+						compareAttributes(map[string]string{"area": "heap"}),
+					},
+				},
+			}),
+	})
+}