diff options
| author | jerop <[email protected]> | 2025-06-10 21:23:35 +0000 |
|---|---|---|
| committer | Jerop Kipruto <[email protected]> | 2025-06-10 17:30:50 -0400 |
| commit | fa27bc832ff7a9370bd809def296b8965830a6cf (patch) | |
| tree | 7c9580bed70016c409e9589ab5e8e162fb8d94c5 /packages/core/src | |
| parent | f0f7a30d9f47bff291171ad0aeb45cf8e8e23cc8 (diff) | |
feat: enable gzip compression for otlp exporters
Diffstat (limited to 'packages/core/src')
| -rw-r--r-- | packages/core/src/telemetry/sdk.ts | 16 |
1 files changed, 13 insertions, 3 deletions
diff --git a/packages/core/src/telemetry/sdk.ts b/packages/core/src/telemetry/sdk.ts index 65d4ae68..8cd20b7b 100644 --- a/packages/core/src/telemetry/sdk.ts +++ b/packages/core/src/telemetry/sdk.ts @@ -8,6 +8,7 @@ import { DiagConsoleLogger, DiagLogLevel, diag } from '@opentelemetry/api'; import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-grpc'; import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-grpc'; import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-grpc'; +import { CompressionAlgorithm } from '@opentelemetry/otlp-exporter-base'; import { NodeSDK } from '@opentelemetry/sdk-node'; import { SemanticResourceAttributes } from '@opentelemetry/semantic-conventions'; import { Resource } from '@opentelemetry/resources'; @@ -75,14 +76,23 @@ export function initializeTelemetry(config: Config): void { const useOtlp = !!grpcParsedEndpoint; const spanExporter = useOtlp - ? new OTLPTraceExporter({ url: grpcParsedEndpoint }) + ? new OTLPTraceExporter({ + url: grpcParsedEndpoint, + compression: CompressionAlgorithm.GZIP, + }) : new ConsoleSpanExporter(); const logExporter = useOtlp - ? new OTLPLogExporter({ url: grpcParsedEndpoint }) + ? new OTLPLogExporter({ + url: grpcParsedEndpoint, + compression: CompressionAlgorithm.GZIP, + }) : new ConsoleLogRecordExporter(); const metricReader = useOtlp ? new PeriodicExportingMetricReader({ - exporter: new OTLPMetricExporter({ url: grpcParsedEndpoint }), + exporter: new OTLPMetricExporter({ + url: grpcParsedEndpoint, + compression: CompressionAlgorithm.GZIP, + }), exportIntervalMillis: 10000, }) : new PeriodicExportingMetricReader({ |
