X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=d10a27c9171c978ce44e7b9f6a1d2a9fb66131db;hb=a3ae469eebfcc990a251133beb01378599313233;hp=7bf86848690538010dd9acbf3cb2cee2bb411c26;hpb=70c7d7d3af9c38417416ca9096a6ab3ae835b5d0;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 7bf86848..d10a27c9 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. + * Submission timestamp. + */ + readonly submissionTimestamp?: 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 } /**