27 lines
751 B
TypeScript
27 lines
751 B
TypeScript
import { MeterProvider, PeriodicExportingMetricReader } from "@opentelemetry/sdk-metrics";
|
|
import { OTLPMetricExporter } from "@opentelemetry/exporter-metrics-otlp-grpc";
|
|
|
|
const exporter = new OTLPMetricExporter({
|
|
url: "http://localhost:4317"
|
|
});
|
|
|
|
const metricReader = new PeriodicExportingMetricReader({
|
|
exporter: exporter,
|
|
exportIntervalMillis: 5000
|
|
});
|
|
|
|
const meterProvider = new MeterProvider({
|
|
readers: [metricReader]
|
|
});
|
|
|
|
const meter = meterProvider.getMeter("bullmq-worker");
|
|
|
|
export const jobCounter = meter.createCounter("job_count", {
|
|
description: "Number of executed BullMQ jobs"
|
|
});
|
|
|
|
export const jobDuration = meter.createHistogram("job_duration", {
|
|
description: "Execution duration of BullMQ jobs in milliseconds",
|
|
unit: "ms"
|
|
});
|