X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=592b3fe7d4234fe3df267074963b10301ee23707;hb=a4e07f7216246b772e13783937a97c87105b8fc3;hp=bd5e284496fa82826b51980fdb199c4d4dcbf884;hpb=184855e69fea29f1018024a34be10de2c8e3141a;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index bd5e2844..592b3fe7 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -1,5 +1,4 @@ -import type { ClusterSettings, Worker } from 'node:cluster' -import cluster from 'node:cluster' +import cluster, { type ClusterSettings, type Worker } from 'node:cluster' import type { MessageValue } from '../../utility-types' import { AbstractPool } from '../abstract-pool' import { @@ -19,8 +18,7 @@ export interface ClusterPoolOptions extends PoolOptions { * * @see https://nodejs.org/api/cluster.html#cluster_cluster_fork_env */ - // eslint-disable-next-line @typescript-eslint/no-explicit-any - env?: any + env?: Record /** * Cluster settings. * @@ -55,7 +53,7 @@ export class FixedClusterPool< public constructor ( numberOfWorkers: number, filePath: string, - public readonly opts: ClusterPoolOptions = {} + protected readonly opts: ClusterPoolOptions = {} ) { super(numberOfWorkers, filePath, opts) } @@ -101,7 +99,7 @@ export class FixedClusterPool< } /** @inheritDoc */ - public get type (): PoolType { + protected get type (): PoolType { return PoolTypes.fixed } @@ -120,11 +118,6 @@ export class FixedClusterPool< return this.numberOfWorkers } - /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length >= this.numberOfWorkers - } - /** @inheritDoc */ protected get busy (): boolean { return this.internalBusy()