X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=4d935a113336921a5f49e6858046b07a863096fd;hb=a4e07f7216246b772e13783937a97c87105b8fc3;hp=841a2bcb1513ba3dc017d4b599ef61e3329611ab;hpb=213e817d69db5ac80137ef59ed5cdadcde4d73cf;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 841a2bcb..4d935a11 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -57,55 +57,72 @@ export interface Task { } /** - * Worker tasks usage statistics. + * Measure statistics. * * @internal */ -export interface TasksUsage { +export interface MeasureStatistics { /** - * Number of tasks executed. + * Measure aggregation. */ - ran: number + aggregation: number /** - * Number of tasks running. + * Measure average. */ - running: number + average: number /** - * Tasks runtime. + * Measure median. */ - runTime: number + median: number /** - * Tasks runtime history. + * Measure 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: MeasureStatistics /** - * Number of tasks errored. + * Tasks wait time statistics. */ - error: number + waitTime: MeasureStatistics /** * Event loop utilization. */ @@ -148,9 +165,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. */