Stress test modified to have a reader to force sdk to do aggregation

open-telemetry · Nov 20, 2021 · a97644b · a97644b
1 parent 3a516f3
commit a97644b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/test/OpenTelemetry.Tests.Stress.Metrics/OpenTelemetry.Tests.Stress.Metrics.csproj b/test/OpenTelemetry.Tests.Stress.Metrics/OpenTelemetry.Tests.Stress.Metrics.csproj
@@ -9,6 +9,7 @@
   <ItemGroup>
     <Compile Include="$(RepoRoot)\test\OpenTelemetry.Tests.Stress\Skeleton.cs" />
     <ProjectReference Include="$(RepoRoot)\src\OpenTelemetry\OpenTelemetry.csproj" />
+    <ProjectReference Include="$(RepoRoot)\src\OpenTelemetry.Exporter.InMemory\OpenTelemetry.Exporter.InMemory.csproj" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/test/OpenTelemetry.Tests.Stress.Metrics/Program.cs b/test/OpenTelemetry.Tests.Stress.Metrics/Program.cs
@@ -15,15 +15,14 @@
 // </copyright>
 
 using System;
+using System.Collections.Generic;
 using System.Diagnostics.Metrics;
 using System.Runtime.CompilerServices;
 using System.Threading;
-using OpenTelemetry;
+using OpenTelemetry.Exporter;
 using OpenTelemetry.Metrics;
-using OpenTelemetry.Tests;
 
 namespace OpenTelemetry.Tests.Stress;
-
 public partial class Program
 {
     private const int ArraySize = 10;
@@ -39,8 +38,12 @@ public static void Main()
             DimensionValues[i] = $"DimValue{i}";
         }
 
+        var exportedItems = new List<Metric>();
+        var reader = new BaseExportingMetricReader(new InMemoryExporter<Metric>(exportedItems));
+
         using var meterProvider = Sdk.CreateMeterProviderBuilder()
             .AddMeter(TestMeter.Name)
+            .AddReader(reader)
             .Build();
         Stress();
     }