Class WorkerChoiceStrategyContext<Worker, Data, Response>

The worker choice strategy context.

Type Parameters

Worker extends IWorker

Type of worker.
Data = unknown

Type of data sent to the worker. This can only be structured-cloneable data.
Response = unknown

Type of execution response. This can only be structured-cloneable data.

Hierarchy

WorkerChoiceStrategyContext

Index

Constructors

constructor

new WorkerChoiceStrategyContext<Worker, Data, Response>(pool, workerChoiceStrategy?, opts?): WorkerChoiceStrategyContext<Worker, Data, Response>
Worker choice strategy context constructor.
Type Parameters
- Worker extends IWorker
- Data = unknown
- Response = unknown
Parameters
- pool: IPool<Worker, Data, Response>
  
  The pool instance.
- workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN" = WorkerChoiceStrategies.ROUND_ROBIN
  
  The worker choice strategy.
- opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS
  
  The worker choice strategy options.
Returns WorkerChoiceStrategyContext<Worker, Data, Response>
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:49

Properties

`Private` opts

opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS

The worker choice strategy options.

`Private` retriesCount

retriesCount: number = 0

The number of times the worker choice strategy in the context has been retried.

`Private` `Readonly` workerChoiceStrategies

`Private` workerChoiceStrategy

The worker choice strategy.

Methods

execute

execute(): number
Executes the worker choice strategy in the context algorithm.

Returns number
The key of the worker node.

Throws
https://nodejs.org/api/errors.html#class-error If after configured retries the worker node key is null or undefined .
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:173

getStrategyPolicy

getStrategyPolicy(): StrategyPolicy
Gets the strategy policy in the context.

Returns StrategyPolicy
The strategy policy.
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:119

getTaskStatisticsRequirements

getTaskStatisticsRequirements(): TaskStatisticsRequirements
Gets the worker choice strategy in the context task statistics requirements.

Returns TaskStatisticsRequirements
The task statistics requirements.
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:132

remove

remove(workerNodeKey): boolean
Removes the worker node key from the worker choice strategy in the context.
Parameters
- workerNodeKey: number
  
  The worker node key.
Returns boolean
true if the removal is successful, false otherwise.
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:200

setOptions

setOptions(opts): void
Sets the worker choice strategies in the context options.
Parameters
- opts: WorkerChoiceStrategyOptions
  
  The worker choice strategy options.
Returns void
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:213

setWorkerChoiceStrategy

setWorkerChoiceStrategy(workerChoiceStrategy): void
Sets the worker choice strategy to use in the context.
Parameters
- workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN"
  
  The worker choice strategy to set.
Returns void
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:145

update

update(workerNodeKey): boolean
Updates the worker node key in the worker choice strategy in the context internals.
Parameters
- workerNodeKey: number
Returns boolean
true if the update is successful, false otherwise.
- Defined in src/pools/selection-strategies/worker-choice-strategy-context.ts:159

Class WorkerChoiceStrategyContext<Worker, Data, Response>

Type Parameters

Worker extends IWorker

Data = unknown

Response = unknown

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Type Parameters

Worker extends IWorker

Data = unknown

Response = unknown

Parameters

pool: IPool<Worker, Data, Response>

workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN" = WorkerChoiceStrategies.ROUND_ROBIN

opts: WorkerChoiceStrategyOptions = DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS

Returns WorkerChoiceStrategyContext<Worker, Data, Response>

Properties

Private opts

Private retriesCount

Private Readonly workerChoiceStrategies

Private workerChoiceStrategy

Methods

execute

Returns number

Throws

getStrategyPolicy

Returns StrategyPolicy

getTaskStatisticsRequirements

Returns TaskStatisticsRequirements

remove

Parameters

workerNodeKey: number

Returns boolean

setOptions

Parameters

opts: WorkerChoiceStrategyOptions

Returns void

setWorkerChoiceStrategy

Parameters

workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN"

Returns void

update

Parameters

workerNodeKey: number

Returns boolean

Settings

Member Visibility

Theme

On This Page

`Private` opts

`Private` retriesCount

`Private` `Readonly` workerChoiceStrategies

`Private` workerChoiceStrategy