X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=257b0d64b0844d664ba00763b1dcde79c4711ee7;hb=e5536a06df85c554b8832f5fb5195b369258053b;hp=0013bf5dc20a27a9b84b63645233d2e636c9df49;hpb=6b27d40762317ec8502657663bdc839e358cda03;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 0013bf5d..257b0d64 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -31,6 +31,19 @@ export const PoolTypes = Object.freeze({ */ export type PoolType = keyof typeof PoolTypes +/** + * Enumeration of worker types. + */ +export const WorkerTypes = Object.freeze({ + cluster: 'cluster', + thread: 'thread' +} as const) + +/** + * Worker type. + */ +export type WorkerType = keyof typeof WorkerTypes + /** * Pool events emitter. */ @@ -56,14 +69,17 @@ export type PoolEvent = keyof typeof PoolEvents */ export interface PoolInfo { type: PoolType + worker: WorkerType minSize: number maxSize: number workerNodes: number idleWorkerNodes: number busyWorkerNodes: number - runningTasks: number + executedTasks: number + executingTasks: number queuedTasks: number maxQueuedTasks: number + failedTasks: number } /** @@ -144,12 +160,6 @@ export interface IPool< Data = unknown, Response = unknown > { - /** - * Pool type. - * - * If it is `'dynamic'`, it provides the `max` property. - */ - readonly type: PoolType /** * Pool information. */ @@ -178,7 +188,7 @@ export interface IPool< */ execute: (data?: Data, name?: string) => Promise /** - * Shutdowns every current worker in this pool. + * Terminate every current worker in this pool. */ destroy: () => Promise /**