X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Futility-types.ts;h=9cdf6b0a7e82f9d1e3da5fb434537ca8e2d943f9;hb=a788de39a01b042deb0707c2e92af99181b933d2;hp=fb0e435a81ac949b0b82740f1b17c1561bd9d762;hpb=b40ed51168059b59f6f5827def37f622be139ddb;p=poolifier.git diff --git a/src/utility-types.ts b/src/utility-types.ts index fb0e435a..9cdf6b0a 100644 --- a/src/utility-types.ts +++ b/src/utility-types.ts @@ -1,5 +1,6 @@ import type { Worker as ClusterWorker } from 'node:cluster' import type { MessagePort } from 'node:worker_threads' +import type { EventLoopUtilization } from 'node:perf_hooks' import type { KillBehavior } from './worker/worker-options' import type { IWorker, Task } from './pools/worker' @@ -10,6 +11,15 @@ import type { IWorker, Task } from './pools/worker' */ export type Draft = { -readonly [P in keyof T]?: T[P] } +/** + * Performance statistics computation. + */ +export interface WorkerStatistics { + runTime: boolean + waitTime: boolean + elu: boolean +} + /** * Message object that is passed between main worker and worker. * @@ -19,24 +29,40 @@ export type Draft = { -readonly [P in keyof T]?: T[P] } */ export interface MessageValue< Data = unknown, - MainWorker extends ClusterWorker | MessagePort | unknown = unknown + MainWorker extends ClusterWorker | MessagePort = ClusterWorker | MessagePort > extends Task { /** * Kill code. */ readonly kill?: KillBehavior | 1 /** - * Error. + * Task error. */ readonly error?: string + /** + * Task data triggering task error. + */ + readonly errorData?: unknown /** * Runtime. */ readonly runTime?: number + /** + * Wait time. + */ + readonly waitTime?: number + /** + * Event loop utilization. + */ + readonly elu?: EventLoopUtilization /** * Reference to main worker. */ readonly parent?: MainWorker + /** + * Whether to compute the given statistics or not. + */ + readonly statistics?: WorkerStatistics } /**