Start pushing exponential histograms instead of classic.

Author: bobymicroby

.github/workflows/ci.yml

@@ -64,4 +64,4 @@ jobs:
         env:
           OTEL_EXPORTER_OTLP_PROTOCOL: 'http/protobuf'
           ACTIONS_STEP_DEBUG: 'true'
-          OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION: 'base2_exponential_bucket_histogram'
+          OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION: 'BASE2_EXPONENTIAL_BUCKET_HISTOGRAM'

badges/coverage.svg

@@ -48,11 +48,11 @@
     "@actions/core": "1.11.1",
     "@actions/github": "6.0.1",
     "@opentelemetry/api": "^1.9.0",
-    "@opentelemetry/auto-instrumentations-node": "^0.62.0",
-    "@opentelemetry/exporter-metrics-otlp-proto": "^0.203.0",
-    "@opentelemetry/resources": "^2.0.1",
-    "@opentelemetry/sdk-metrics": "^2.0.1",
-    "@opentelemetry/sdk-node": "^0.203.0",
+    "@opentelemetry/auto-instrumentations-node": "^0.64.1",
+    "@opentelemetry/exporter-metrics-otlp-proto": "^0.205.0",
+    "@opentelemetry/resources": "^2.1.0",
+    "@opentelemetry/sdk-metrics": "^2.1.0",
+    "@opentelemetry/sdk-node": "^0.205.0",
     "@opentelemetry/semantic-conventions": "^1.36.0",
     "fast-xml-parser": "^5.2.5"
   },

dist/index.js

@@ -16,6 +16,7 @@ exports[`MetricsSubmitter should configures histogram with explicit buckets 1`]
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {
@@ -110,6 +111,7 @@ exports[`MetricsSubmitter should creates instruments for each metric type 1`] =
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {
@@ -246,6 +248,7 @@ exports[`MetricsSubmitter should handles metrics with different attributes corre
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {
@@ -307,6 +310,7 @@ exports[`MetricsSubmitter should handles multiple metric types in one submission
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {
@@ -443,6 +447,7 @@ exports[`MetricsSubmitter should handles updowncounter negative values correctly
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {
@@ -496,6 +501,7 @@ exports[`MetricsSubmitter should reuses existing instruments for same metric nam
           "1.0.0",
         ],
       ],
+      "_schemaUrl": undefined,
     },
     "scopeMetrics": [
       {

dist/index.js.map

@@ -31,7 +31,10 @@ const mockMeterProvider = {
 const mockOpenTelemetry = {
   MeterProvider: jest.fn(() => mockMeterProvider),
   PeriodicExportingMetricReader: jest.fn(() => ({})),
-  ConsoleMetricExporter: jest.fn(() => ({}))
+  ConsoleMetricExporter: jest.fn(() => ({})),
+  AggregationType: {
+    EXPONENTIAL_HISTOGRAM: 5
+  }
 }
 
 const mockOTLPExporter = {
@@ -144,6 +147,7 @@ describe('main.ts', () => {
     })
 
     expect(mockOTLPExporter.OTLPMetricExporter).toHaveBeenCalledWith({
+      aggregationPreference: expect.any(Function),
       url: 'http://localhost:4318/v1/metrics',
       headers: {
         'api-key': 'secret123',

package-lock.json

@@ -5,8 +5,10 @@ import { ingestDir } from './junit-parser.js'
 import { generateMetrics, type TMetricsConfig } from './metrics-generator.js'
 import { MetricsSubmitter } from './metrics-submitter.js'
 import {
+  InstrumentType,
   MeterProvider,
-  PeriodicExportingMetricReader
+  PeriodicExportingMetricReader,
+  AggregationType
 } from '@opentelemetry/sdk-metrics'
 import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-proto'
 import { resourceFromAttributes } from '@opentelemetry/resources'
@@ -28,6 +30,8 @@ import {
   DiagLogger,
   diag
 } from '@opentelemetry/api'
+import { DEFAULT_AGGREGATION_SELECTOR } from '@opentelemetry/sdk-metrics/build/src/export/AggregationSelector.js'
+import { ExponentialHistogramAggregationOption } from '@opentelemetry/sdk-metrics/build/src/view/AggregationOption.js'
 
 class CapturingDiagLogger implements DiagLogger {
   private baseLogger: DiagConsoleLogger
@@ -122,7 +126,19 @@ export async function run(): Promise<void> {
       [ATTR_DEPLOYMENT_ENVIRONMENT_NAME]: deploymentEnvironment
     })
 
+    const aggregationPreference = (t: InstrumentType) => {
+      if (t === 'HISTOGRAM') {
+        return {
+          type: AggregationType.EXPONENTIAL_HISTOGRAM,
+          options: {
+            recordMinMax: true
+          }
+        } as ExponentialHistogramAggregationOption
+      }
+      return DEFAULT_AGGREGATION_SELECTOR(t)
+    }
     const exporter = new OTLPMetricExporter({
+      aggregationPreference,
       url: otlpEndpoint,
       headers,
       timeoutMillis: DEFAULT_TIMEOUT_MS