mirrors/oneuptime
1
0
Fork 0
mirror of https://github.com/OneUptime/oneuptime synced 2024-11-22 07:10:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor OpenTelemetry configuration

Browse Source
This commit is contained in:
Simon Larsen 2024-02-20 13:01:58 +00:00
parent fb7fe8af1e
commit 30d9cbe9a3
No known key found for this signature in database
GPG Key ID: AB45983AA9C81CDE
1 changed files with 30 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
CommonServer/Utils/OpenTelemetry.ts
View File

@ -6,41 +6,45 @@ import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics';
import logger from './Logger';
import Dictionary from 'Common/Types/Dictionary';
let sdk: opentelemetry.NodeSDK | null = null;
let sdk: opentelemetry.NodeSDK | null = null;
if (
process.env['OTEL_EXPORTER_OTLP_ENDPOINT'] &&
process.env['OTEL_EXPORTER_OTLP_HEADERS']
process.env['OTEL_EXPORTER_OTLP_ENDPOINT'] &&
process.env['OTEL_EXPORTER_OTLP_HEADERS']
) {
const headersStrings: Array<string> =
process.env['OTEL_EXPORTER_OTLP_HEADERS'].split(';');
const headersStrings: Array<string> =
process.env['OTEL_EXPORTER_OTLP_HEADERS'].split(';');
const headers: Dictionary<string> = {};
const headers: Dictionary<string> = {};
for (const headerString of headersStrings) {
const header: Array<string> = headerString.split('=');
if (header.length === 2) {
headers[header[0]!.toString()] = header[1]!.toString();
}
for (const headerString of headersStrings) {
const header: Array<string> = headerString.split('=');
if (header.length === 2) {
headers[header[0]!.toString()] = header[1]!.toString();
}
}
sdk = new opentelemetry.NodeSDK({
traceExporter: new OTLPTraceExporter({
url: process.env['OTEL_EXPORTER_OTLP_ENDPOINT'],
headers: headers,
}),
metricReader: new PeriodicExportingMetricReader({
exporter: new OTLPMetricExporter({
url: process.env['OTEL_EXPORTER_OTLP_ENDPOINT'],
headers: headers,
}),
}) as any,
instrumentations: [getNodeAutoInstrumentations()],
});
const otlpEndpoint = process.env['OTEL_EXPORTER_OTLP_ENDPOINT'];
sdk.start();
logger.info(otlpEndpoint);
logger.info('Instrumentation initialized');
sdk = new opentelemetry.NodeSDK({
traceExporter: new OTLPTraceExporter({
url: otlpEndpoint + '/v1/traces',
headers: headers,
}),
metricReader: new PeriodicExportingMetricReader({
exporter: new OTLPMetricExporter({
url: otlpEndpoint + '/v1/metrics',
headers: headers,
}),
}) as any,
instrumentations: [getNodeAutoInstrumentations()],
});
sdk.start();
logger.info('Instrumentation initialized');
}
export default sdk;