X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fselection-strategies-types.ts;h=1467ab4f566317742dca3f453d6cfedff860fa16;hb=refs%2Ftags%2Fv3.1.9;hp=b476592ac59e17c3c6c3b64cc4481fcca6bb79cb;hpb=8c0b113f317f5e59160fb5174fd951330756221b;p=poolifier.git diff --git a/src/pools/selection-strategies/selection-strategies-types.ts b/src/pools/selection-strategies/selection-strategies-types.ts index b476592a..1467ab4f 100644 --- a/src/pools/selection-strategies/selection-strategies-types.ts +++ b/src/pools/selection-strategies/selection-strategies-types.ts @@ -67,12 +67,6 @@ export interface MeasurementOptions { * Worker choice strategy options. */ export interface WorkerChoiceStrategyOptions { - /** - * Number of worker choice retries to perform if no worker is eligible. - * - * @defaultValue 6 - */ - readonly retries?: number /** * Measurement to use in worker choice strategy supporting it. */ @@ -101,7 +95,22 @@ export interface WorkerChoiceStrategyOptions { * * @defaultValue Weights computed automatically given the CPU performance. */ - readonly weights?: Record + weights?: Record +} + +/** + * Worker choice strategy internal options. + * + * @internal + */ +export interface InternalWorkerChoiceStrategyOptions + extends WorkerChoiceStrategyOptions { + /** + * Number of worker choice retries to perform if no worker is eligible. + * + * @defaultValue pool maximum size + */ + readonly retries?: number } /** @@ -182,13 +191,15 @@ export interface IWorkerChoiceStrategy { readonly reset: () => boolean /** * Updates the worker node key strategy internals. + * This is called after a task has been executed on a worker node. * * @returns `true` if the update is successful, `false` otherwise. */ readonly update: (workerNodeKey: number) => boolean /** * Chooses a worker node in the pool and returns its key. - * If the worker node is not eligible, `undefined` is returned. + * If no worker nodes are not eligible, `undefined` is returned. + * If `undefined` is returned, the caller retry. * * @returns The worker node key or `undefined`. */ @@ -206,4 +217,10 @@ export interface IWorkerChoiceStrategy { * @param opts - The worker choice strategy options. */ readonly setOptions: (opts: WorkerChoiceStrategyOptions) => void + /** + * Whether the pool has worker nodes ready or not. + * + * @returns Whether the pool has worker nodes ready or not. + */ + readonly hasPoolWorkerNodesReady: () => boolean }