X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=15654803d64f2a3e1d6924c5120d47c4f56a2283;hb=02fd3265f178909511619be1593c3ff9774c8685;hp=367b45291853f0ca87c3b52ddf2621ae3465c3f4;hpb=eb7bf7441d410ca5d9ff9bb08f191ef22399371c;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 367b4529..15654803 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,4 +1,4 @@ -import EventEmitterAsyncResource from 'node:events' +import { EventEmitter } from 'node:events' import type { ErrorHandler, ExitHandler, @@ -47,7 +47,7 @@ export type WorkerType = keyof typeof WorkerTypes /** * Pool events emitter. */ -export class PoolEmitter extends EventEmitterAsyncResource {} +export class PoolEmitter extends EventEmitter {} /** * Enumeration of pool events. @@ -68,12 +68,13 @@ export type PoolEvent = keyof typeof PoolEvents * Pool information. */ export interface PoolInfo { + version: string type: PoolType worker: WorkerType minSize: number maxSize: number /** Pool utilization ratio. */ - utilization: number + utilization?: number /** Pool total worker nodes */ workerNodes: number /** Pool idle worker nodes */ @@ -85,6 +86,14 @@ export interface PoolInfo { queuedTasks: number maxQueuedTasks: number failedTasks: number + runTime?: { + minimum: number + maximum: number + } + waitTime?: { + minimum: number + maximum: number + } } /**