X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=f22906dfc00f89ba32430f63732492eb986dcfd3;hb=d46660cd0cccf38566337876c3fad0c3795aeb94;hp=a0c6b16f6ed7b5a16e38c30c75c62302cd54b9c7;hpb=6b27d40762317ec8502657663bdc839e358cda03;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index a0c6b16f..f22906df 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -1,8 +1,13 @@ -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 { type PoolOptions, type PoolType, PoolTypes } from '../pool' +import { + type PoolOptions, + type PoolType, + PoolTypes, + type WorkerType, + WorkerTypes +} from '../pool' /** * Options for a poolifier cluster pool. @@ -49,7 +54,7 @@ export class FixedClusterPool< public constructor ( numberOfWorkers: number, filePath: string, - public readonly opts: ClusterPoolOptions = {} + protected readonly opts: ClusterPoolOptions = {} ) { super(numberOfWorkers, filePath, opts) } @@ -95,23 +100,23 @@ export class FixedClusterPool< } /** @inheritDoc */ - public get type (): PoolType { + protected get type (): PoolType { return PoolTypes.fixed } /** @inheritDoc */ - protected get minSize (): number { - return this.numberOfWorkers + protected get worker (): WorkerType { + return WorkerTypes.cluster } /** @inheritDoc */ - protected get maxSize (): number { + protected get minSize (): number { return this.numberOfWorkers } /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length >= this.numberOfWorkers + protected get maxSize (): number { + return this.numberOfWorkers } /** @inheritDoc */