X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=841a2bcb1513ba3dc017d4b599ef61e3329611ab;hb=a788de39a01b042deb0707c2e92af99181b933d2;hp=7bf86848690538010dd9acbf3cb2cee2bb411c26;hpb=227be16668f5a3adf78a255c20e956d6f5b3f567;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 7bf86848..841a2bcb 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -1,3 +1,4 @@ +import type { EventLoopUtilization } from 'node:perf_hooks' import type { CircularArray } from '../circular-array' import type { Queue } from '../queue' @@ -46,7 +47,11 @@ export interface Task { */ readonly data?: Data /** - * UUID of the message. + * Timestamp. + */ + readonly timestamp?: number + /** + * Message UUID. */ readonly id?: string } @@ -60,7 +65,7 @@ export interface TasksUsage { /** * Number of tasks executed. */ - run: number + ran: number /** * Number of tasks running. */ @@ -81,10 +86,30 @@ export interface TasksUsage { * Median tasks runtime. */ medRunTime: number + /** + * Tasks wait time. + */ + waitTime: number + /** + * Tasks wait time history. + */ + waitTimeHistory: CircularArray + /** + * Average tasks wait time. + */ + avgWaitTime: number + /** + * Median tasks wait time. + */ + medWaitTime: number /** * Number of tasks errored. */ error: number + /** + * Event loop utilization. + */ + elu: EventLoopUtilization | undefined } /**