X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futility-types.ts;h=1a660434f07dee07dd300b0f3473a33b529af045;hb=fc3e65861bc1939ae047ee1e8e91a1ce577035f4;hp=9c8d9650b15ccc31007a19d199117860a650ac58;hpb=e088a00c285c320395d883d57d1db51d42300b10;p=poolifier.git diff --git a/src/utility-types.ts b/src/utility-types.ts index 9c8d9650..1a660434 100644 --- a/src/utility-types.ts +++ b/src/utility-types.ts @@ -1,6 +1,6 @@ -import type { Worker } from 'cluster' -import type { MessagePort } from 'worker_threads' -import type { IWorker } from './pools/abstract-pool' +import type { Worker as ClusterWorker } from 'node:cluster' +import type { MessagePort } from 'node:worker_threads' +import type { IPoolWorker } from './pools/pool-worker' import type { KillBehavior } from './worker/worker-options' /** @@ -13,7 +13,7 @@ export type Draft = { -readonly [P in keyof T]?: T[P] } */ export interface MessageValue< Data = unknown, - MainWorker extends Worker | MessagePort | unknown = unknown + MainWorker extends ClusterWorker | MessagePort | unknown = unknown > { /** * Input data that will be passed to the worker. @@ -22,7 +22,7 @@ export interface MessageValue< /** * Id of the message. */ - readonly id?: number + readonly id?: string /** * Kill code. */ @@ -31,10 +31,14 @@ export interface MessageValue< * Error. */ readonly error?: string + /** + * Task runtime. + */ + readonly taskRunTime?: number /** * Reference to main worker. * - * _Only for internal use_ + * Only for internal use. */ readonly parent?: MainWorker } @@ -42,11 +46,11 @@ export interface MessageValue< /** * An object holding the worker that will be used to resolve/rejects the promise later on. * - * @template Worker Type of worker. - * @template Response Type of response of execution. This can only be serializable data. + * @typeParam Worker - Type of worker. + * @typeParam Response - Type of response of execution. This can only be serializable data. */ export interface PromiseWorkerResponseWrapper< - Worker extends IWorker, + Worker extends IPoolWorker, Response = unknown > { /**