/** * Computation helpers for monitor-reader. * * Pure functions that compute derived values from snapshots: * durations, dispatch summaries, and concurrency status. * * @module */ import type { MetricsSnapshot } from "../../../dispatch/persistence/metrics.ts"; import type { TaskSnapshot, DispatchSummary, ConcurrencyStatus } from "./monitor-reader-types.ts"; export declare const CONCURRENCY_GAUGE_ACTIVE = "concurrency_active"; export declare const CONCURRENCY_GAUGE_QUEUED = "concurrency_queued"; export declare const CONCURRENCY_GAUGE_LIMIT = "concurrency_limit"; export declare function computeDurationMs(startedAt: string | undefined, completedAt?: string): number; /** * Compute a DispatchSummary from an array of TaskSnapshot objects. * Counts tasks by their status field. */ export declare function computeDispatchSummary(tasks: TaskSnapshot[]): DispatchSummary; /** * Compute an aggregate ConcurrencyStatus from a MetricsSnapshot. * * Scans the metrics gauges for keys matching known concurrency gauge * patterns (concurrency_active, concurrency_queued, concurrency_limit) * and aggregates their values across all model keys. * * Returns a zeroed ConcurrencyStatus when no metrics or no concurrency * gauges are present. */ export declare function computeConcurrencyStatus(metrics: MetricsSnapshot | null | undefined): ConcurrencyStatus; //# sourceMappingURL=monitor-reader-compute.d.ts.map