[chore] filterprocessor uses mdatagen for internal metrics (open-tele…

…metry#33197)

Signed-off-by: Alex Boten <[email protected]>

processor/filterprocessor/documentation.md

@@ -0,0 +1,31 @@
+[comment]: <> (Code generated by mdatagen. DO NOT EDIT.)
+
+# filter
+
+## Internal Telemetry
+
+The following telemetry is emitted by this component.
+
+### processor_filter_datapoints.filtered
+
+Number of metric data points dropped by the filter processor
+
+| Unit | Metric Type | Value Type | Monotonic |
+| ---- | ----------- | ---------- | --------- |
+| 1 | Sum | Int | true |
+
+### processor_filter_logs.filtered
+
+Number of logs dropped by the filter processor
+
+| Unit | Metric Type | Value Type | Monotonic |
+| ---- | ----------- | ---------- | --------- |
+| 1 | Sum | Int | true |
+
+### processor_filter_spans.filtered
+
+Number of spans dropped by the filter processor
+
+| Unit | Metric Type | Value Type | Monotonic |
+| ---- | ----------- | ---------- | --------- |
+| 1 | Sum | Int | true |

processor/filterprocessor/metadata.yaml

@@ -11,3 +11,27 @@ status:
     active: [TylerHelmuth, boostchicken]
 tests:
   config:
+
+telemetry:
+  metrics:
+    processor_filter_datapoints.filtered:
+      enabled: true
+      description: Number of metric data points dropped by the filter processor
+      unit: 1
+      sum:
+        value_type: int
+        monotonic: true
+    processor_filter_logs.filtered:
+      enabled: true
+      description: Number of logs dropped by the filter processor
+      unit: 1
+      sum:
+        value_type: int
+        monotonic: true
+    processor_filter_spans.filtered:
+      enabled: true
+      description: Number of spans dropped by the filter processor
+      unit: 1
+      sum:
+        value_type: int
+        monotonic: true

processor/filterprocessor/telemetry.go

@@ -7,7 +7,6 @@ import (
 	"context"
 
 	"go.opentelemetry.io/collector/processor"
-	"go.opentelemetry.io/collector/processor/processorhelper"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
 
@@ -27,61 +26,31 @@ type filterProcessorTelemetry struct {
 
 	processorAttr []attribute.KeyValue
 
-	datapointsFiltered metric.Int64Counter
-	logsFiltered       metric.Int64Counter
-	spansFiltered      metric.Int64Counter
+	telemetryBuilder *metadata.TelemetryBuilder
 }
 
 func newfilterProcessorTelemetry(set processor.CreateSettings) (*filterProcessorTelemetry, error) {
-	processorID := set.ID.String()
-
-	fpt := &filterProcessorTelemetry{
-		processorAttr: []attribute.KeyValue{attribute.String(metadata.Type.String(), processorID)},
-		exportCtx:     context.Background(),
-	}
-
-	counter, err := metadata.Meter(set.TelemetrySettings).Int64Counter(
-		processorhelper.BuildCustomMetricName(metadata.Type.String(), "datapoints.filtered"),
-		metric.WithDescription("Number of metric data points dropped by the filter processor"),
-		metric.WithUnit("1"),
-	)
-	if err != nil {
-		return nil, err
-	}
-	fpt.datapointsFiltered = counter
-
-	counter, err = metadata.Meter(set.TelemetrySettings).Int64Counter(
-		processorhelper.BuildCustomMetricName(metadata.Type.String(), "logs.filtered"),
-		metric.WithDescription("Number of logs dropped by the filter processor"),
-		metric.WithUnit("1"),
-	)
-	if err != nil {
-		return nil, err
-	}
-	fpt.logsFiltered = counter
-
-	counter, err = metadata.Meter(set.TelemetrySettings).Int64Counter(
-		processorhelper.BuildCustomMetricName(metadata.Type.String(), "spans.filtered"),
-		metric.WithDescription("Number of spans dropped by the filter processor"),
-		metric.WithUnit("1"),
-	)
+	telemetryBuilder, err := metadata.NewTelemetryBuilder(set.TelemetrySettings)
 	if err != nil {
 		return nil, err
 	}
-	fpt.spansFiltered = counter
 
-	return fpt, nil
+	return &filterProcessorTelemetry{
+		processorAttr:    []attribute.KeyValue{attribute.String(metadata.Type.String(), set.ID.String())},
+		exportCtx:        context.Background(),
+		telemetryBuilder: telemetryBuilder,
+	}, nil
 }
 
 func (fpt *filterProcessorTelemetry) record(trigger trigger, dropped int64) {
 	var triggerMeasure metric.Int64Counter
 	switch trigger {
 	case triggerMetricDataPointsDropped:
-		triggerMeasure = fpt.datapointsFiltered
+		triggerMeasure = fpt.telemetryBuilder.ProcessorFilterDatapointsFiltered
 	case triggerLogsDropped:
-		triggerMeasure = fpt.logsFiltered
+		triggerMeasure = fpt.telemetryBuilder.ProcessorFilterLogsFiltered
 	case triggerSpansDropped:
-		triggerMeasure = fpt.spansFiltered
+		triggerMeasure = fpt.telemetryBuilder.ProcessorFilterSpansFiltered
 	}
 
 	triggerMeasure.Add(fpt.exportCtx, dropped, metric.WithAttributes(fpt.processorAttr...))