Implement rate as counter

grafana · May 23, 2024 · c47abf6 · c47abf6
1 parent 8ddf863
commit c47abf6
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/pkg/opentelemetry/output.go b/pkg/opentelemetry/output.go
@@ -181,9 +181,15 @@ func (o *Output) dispatch(entry metrics.Sample) error {
 		}
 
 		trend.Record(ctx, entry.Value, otelMetric.WithAttributes(MapTagSet(entry.Tags)...))
+	case metrics.Rate:
+		rate, err := o.getOrCreateCounter(name)
+		if err != nil {
+			return err
+		}
+
+		rate.Add(ctx, entry.Value, otelMetric.WithAttributes(MapTagSet(entry.Tags)...))
 	default:
-		// TODO: add support for other metric types
-		o.logger.Debugf("Drop unsupported metric type: %s", entry.Metric.Name)
+		o.logger.Warnf("metric %q has unsupported metric type", entry.Metric.Name)
 	}
 
 	return nil