X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fworker-choice-strategy-context.ts;h=5d26f82ba4f5784873c18eb037beed9b26a5e2f5;hb=fa418e129ade4cd910e34e9d41c3dfa5cac9b2de;hp=2a487acbdfde0f2d07c2f9eae9233d26da387604;hpb=7254e41972596ec68a8790747b9fd4ef0def5afc;p=poolifier.git diff --git a/src/pools/selection-strategies/worker-choice-strategy-context.ts b/src/pools/selection-strategies/worker-choice-strategy-context.ts index 2a487acb..5d26f82b 100644 --- a/src/pools/selection-strategies/worker-choice-strategy-context.ts +++ b/src/pools/selection-strategies/worker-choice-strategy-context.ts @@ -114,21 +114,39 @@ export class WorkerChoiceStrategyContext< this.workerChoiceStrategies.get(this.workerChoiceStrategy)?.reset() } + /** + * Updates the worker node key in the worker choice strategy internals in the context. + * + * @returns `true` if the update is successful, `false` otherwise. + */ + public update (workerNodeKey: number): boolean { + return ( + this.workerChoiceStrategies.get( + this.workerChoiceStrategy + ) as IWorkerChoiceStrategy + ).update(workerNodeKey) + } + /** * Executes the worker choice strategy algorithm in the context. * * @returns The key of the worker node. + * @throws {@link https://nodejs.org/api/errors.html#class-error} If the worker node key is null or undefined. */ public execute (): number { - return ( + const workerNodeKey = ( this.workerChoiceStrategies.get( this.workerChoiceStrategy ) as IWorkerChoiceStrategy ).choose() + if (workerNodeKey == null) { + throw new Error('Worker node key chosen is null or undefined') + } + return workerNodeKey } /** - * Removes a worker node key from the worker choice strategy in the context. + * Removes the worker node key from the worker choice strategy in the context. * * @param workerNodeKey - The key of the worker node. * @returns `true` if the removal is successful, `false` otherwise.