Set AggregationTemporality from exporter options (#2455)

Co-authored-by: Cijo Thomas <cithomas@microsoft.com>
open-telemetry · Oct 6, 2021 · 08049d6 · 08049d6
1 parent 5c7feb0
commit 08049d6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/src/OpenTelemetry.Exporter.Console/ConsoleExporterMetricsExtensions.cs b/src/OpenTelemetry.Exporter.Console/ConsoleExporterMetricsExtensions.cs
@@ -41,12 +41,13 @@ public static MeterProviderBuilder AddConsoleExporter(this MeterProviderBuilder
 
             var exporter = new ConsoleMetricExporter(options);
 
-            if (options.MetricExportIntervalMilliseconds == Timeout.Infinite)
-            {
-                return builder.AddReader(new BaseExportingMetricReader(exporter));
-            }
+            var reader = options.MetricExportIntervalMilliseconds == Timeout.Infinite
+                ? new BaseExportingMetricReader(exporter)
+                : new PeriodicExportingMetricReader(exporter, options.MetricExportIntervalMilliseconds);
+
+            reader.PreferredAggregationTemporality = options.AggregationTemporality;
 
-            return builder.AddReader(new PeriodicExportingMetricReader(exporter, options.MetricExportIntervalMilliseconds));
+            return builder.AddReader(reader);
         }
     }
 }
diff --git a/src/OpenTelemetry.Exporter.OpenTelemetryProtocol/OtlpMetricExporterExtensions.cs b/src/OpenTelemetry.Exporter.OpenTelemetryProtocol/OtlpMetricExporterExtensions.cs
@@ -54,6 +54,7 @@ private static MeterProviderBuilder AddOtlpExporter(MeterProviderBuilder builder
 
             var metricExporter = new OtlpMetricExporter(options);
             var metricReader = new PeriodicExportingMetricReader(metricExporter, options.MetricExportIntervalMilliseconds);
+            metricReader.PreferredAggregationTemporality = options.AggregationTemporality;
             return builder.AddReader(metricReader);
         }
     }