Make AggregationTemporality configurable for OtlpInMemoryMetricExporter

open-telemetry · Feb 24, 2023 · 231b5dc · 231b5dc
1 parent ba9df3f
commit 231b5dc
Showing 1 changed file with 18 additions and 1 deletion.
diff --git a/...src/main/java/io/opentelemetry/javaagent/testing/exporter/OtlpInMemoryMetricExporter.java b/...src/main/java/io/opentelemetry/javaagent/testing/exporter/OtlpInMemoryMetricExporter.java
@@ -19,11 +19,28 @@
 import java.util.List;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.logging.Logger;
+
+import static java.util.logging.Level.CONFIG;
 
 class OtlpInMemoryMetricExporter implements MetricExporter {
 
+  private static final Logger logger = Logger.getLogger(OtlpInMemoryMetricExporter.class.getName());
+
   private final Queue<byte[]> collectedRequests = new ConcurrentLinkedQueue<>();
 
+  private final AggregationTemporality aggregationTemporality;
+
+  OtlpInMemoryMetricExporter() {
+    String temporalityProperty = System.getProperty("otel.javaagent.testing.exporter.temporality");
+    if (temporalityProperty == null) {
+      aggregationTemporality = AggregationTemporality.DELTA;
+    } else {
+      aggregationTemporality = AggregationTemporality.valueOf(temporalityProperty.toUpperCase());
+    }
+    logger.log(CONFIG, "Setting aggregation temporality to {0}", aggregationTemporality.toString());
+  }
+
   List<byte[]> getCollectedExportRequests() {
     return new ArrayList<>(collectedRequests);
   }
@@ -34,7 +51,7 @@ void reset() {
 
   @Override
   public AggregationTemporality getAggregationTemporality(InstrumentType instrumentType) {
-    return AggregationTemporality.DELTA;
+    return aggregationTemporality;
   }
 
   @Override