Skip to main content

runMetricsAggregationWorker

API Docs


Function: runMetricsAggregationWorker()

runMetricsAggregationWorker(snapshotGetter, windowMinutes, logger): Promise<AggregatedMetrics | undefined>

Defined in: src/workers/metrics/metricsAggregationWorker.ts:201

Runs the metrics aggregation worker to collect and aggregate performance snapshots.

Parameters

snapshotGetter

(windowMinutes?) => PerfSnapshot[]

Function to retrieve performance snapshots (from performance plugin)

windowMinutes

number

Time window in minutes for filtering snapshots (default: 5)

logger

FastifyBaseLogger

Fastify logger instance

Returns

Promise<AggregatedMetrics | undefined>

Aggregated metrics or undefined if no snapshots available