X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=ba9393ab9ba8241e5f1a1184165d42055b859835;hb=87de9ff55a7ad494b9e9500208b9b7319c094ea6;hp=841a2bcb1513ba3dc017d4b599ef61e3329611ab;hpb=a788de39a01b042deb0707c2e92af99181b933d2;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 841a2bcb..ba9393ab 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -57,55 +57,71 @@ export interface Task { } /** - * Worker tasks usage statistics. + * Measurement statistics. * * @internal */ -export interface TasksUsage { +export interface MeasurementStatistics { /** - * Number of tasks executed. + * Measurement aggregation. */ - ran: number + aggregation: number /** - * Number of tasks running. + * Measurement average. */ - running: number + average: number /** - * Tasks runtime. + * Measurement median. */ - runTime: number + median: number /** - * Tasks runtime history. + * Measurement history. */ - runTimeHistory: CircularArray + history: CircularArray +} + +/** + * Task statistics. + * + * @internal + */ +export interface TaskStatistics { /** - * Average tasks runtime. + * Number of tasks executed. */ - avgRunTime: number + executed: number /** - * Median tasks runtime. + * Number of tasks executing. */ - medRunTime: number + executing: number /** - * Tasks wait time. + * Number of tasks queued. */ - waitTime: number + queued: number /** - * Tasks wait time history. + * Number of tasks failed. */ - waitTimeHistory: CircularArray + failed: number +} + +/** + * Worker usage statistics. + * + * @internal + */ +export interface WorkerUsage { /** - * Average tasks wait time. + * Tasks statistics. */ - avgWaitTime: number + tasks: TaskStatistics /** - * Median tasks wait time. + * Tasks runtime statistics. */ - medWaitTime: number + runTime: MeasurementStatistics /** - * Number of tasks errored. + * Tasks wait time statistics. */ - error: number + waitTime: MeasurementStatistics /** * Event loop utilization. */ @@ -148,9 +164,9 @@ export interface WorkerNode { */ readonly worker: Worker /** - * Worker node tasks usage statistics. + * Worker node worker usage statistics. */ - tasksUsage: TasksUsage + workerUsage: WorkerUsage /** * Worker node tasks queue. */