diff options
| author | Jerop Kipruto <[email protected]> | 2025-06-13 10:27:22 -0700 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-06-13 10:27:22 -0700 |
| commit | 1f63f3331f1d19e2157d87e8316828dc1c4c8b6b (patch) | |
| tree | 7310f3eb29db6a862f46be9afccee083788e8e3a /packages/core/src/telemetry/sdk.ts | |
| parent | daceb9963f8962051628127c661297fbd95b4a1d (diff) | |
Revert "Telemetry: Auto-export to GCP if GOOGLE_CLOUD_PROJECT is set" (#1011)
Diffstat (limited to 'packages/core/src/telemetry/sdk.ts')
| -rw-r--r-- | packages/core/src/telemetry/sdk.ts | 73 |
1 files changed, 15 insertions, 58 deletions
diff --git a/packages/core/src/telemetry/sdk.ts b/packages/core/src/telemetry/sdk.ts index e1750a86..61f501a6 100644 --- a/packages/core/src/telemetry/sdk.ts +++ b/packages/core/src/telemetry/sdk.ts @@ -71,77 +71,34 @@ export function initializeTelemetry(config: Config): void { 'session.id': config.getSessionId(), }); - const otlpEndpointSetting = config.getTelemetryOtlpEndpoint(); - const gcpProjectId = process.env.GOOGLE_CLOUD_PROJECT; + const otlpEndpoint = config.getTelemetryOtlpEndpoint(); + const grpcParsedEndpoint = parseGrpcEndpoint(otlpEndpoint); + const useOtlp = !!grpcParsedEndpoint; - let spanExporter; - let logExporter; - let metricReader; - - if (otlpEndpointSetting && otlpEndpointSetting.trim() !== '') { - const grpcParsedEndpoint = parseGrpcEndpoint(otlpEndpointSetting); - if (grpcParsedEndpoint) { - diag.info(`Using user-configured OTLP endpoint: ${grpcParsedEndpoint}`); - spanExporter = new OTLPTraceExporter({ + const spanExporter = useOtlp + ? new OTLPTraceExporter({ url: grpcParsedEndpoint, compression: CompressionAlgorithm.GZIP, - }); - logExporter = new OTLPLogExporter({ + }) + : new ConsoleSpanExporter(); + const logExporter = useOtlp + ? new OTLPLogExporter({ url: grpcParsedEndpoint, compression: CompressionAlgorithm.GZIP, - }); - metricReader = new PeriodicExportingMetricReader({ + }) + : new ConsoleLogRecordExporter(); + const metricReader = useOtlp + ? new PeriodicExportingMetricReader({ exporter: new OTLPMetricExporter({ url: grpcParsedEndpoint, compression: CompressionAlgorithm.GZIP, }), exportIntervalMillis: 10000, - }); - } else { - diag.warn( - `Invalid user-configured OTLP endpoint: "${otlpEndpointSetting}". Falling back to console exporter.`, - ); - spanExporter = new ConsoleSpanExporter(); - logExporter = new ConsoleLogRecordExporter(); - metricReader = new PeriodicExportingMetricReader({ + }) + : new PeriodicExportingMetricReader({ exporter: new ConsoleMetricExporter(), exportIntervalMillis: 10000, }); - } - } else if (gcpProjectId) { - diag.info( - `No OTLP endpoint configured, GOOGLE_CLOUD_PROJECT detected (${gcpProjectId}). Exporting telemetry to Google Cloud.`, - ); - const gcpTraceUrl = 'https://trace.googleapis.com:443'; - const gcpMetricUrl = 'https://monitoring.googleapis.com:443'; - const gcpLogUrl = 'https://logging.googleapis.com:443'; - - spanExporter = new OTLPTraceExporter({ - url: gcpTraceUrl, - compression: CompressionAlgorithm.GZIP, - }); - logExporter = new OTLPLogExporter({ - url: gcpLogUrl, - compression: CompressionAlgorithm.GZIP, - }); - metricReader = new PeriodicExportingMetricReader({ - exporter: new OTLPMetricExporter({ - url: gcpMetricUrl, - compression: CompressionAlgorithm.GZIP, - }), - exportIntervalMillis: 10000, - }); - } else { - diag.info( - 'No OTLP endpoint or GOOGLE_CLOUD_PROJECT detected. Using console exporters.', - ); - spanExporter = new ConsoleSpanExporter(); - logExporter = new ConsoleLogRecordExporter(); - metricReader = new PeriodicExportingMetricReader({ - exporter: new ConsoleMetricExporter(), - exportIntervalMillis: 10000, - }); - } sdk = new NodeSDK({ resource, |
