@lucid-softworks/queue-metrics

Projects queue lifecycle events into an in-process metrics snapshot.

import { QueueMetrics } from "@lucid-softworks/queue-metrics";

const metrics = new QueueMetrics();
events.subscribe((event) => metrics.observe(event));
console.log(metrics.snapshot.averageDuration);

Tracks enqueue, start, active, completion, failure, retry, dead-letter, cancellation, heartbeat, and average observed execution duration counts. reset clears all counters and in-flight timing state.