DynamicClusterPool | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicClusterPool.html;h=11212b2005cb21a76266044a1d3316fcba230c16;hb=f7d15c1217381b306300beb7926b42fde93bc579;hp=10e968f8a809e4966a607183ffab07d4170bbe17;hpb=0e502832d98443e291ea5558423ca0de86b96e13;p=poolifier.git diff --git a/docs/classes/DynamicClusterPool.html b/docs/classes/DynamicClusterPool.html index 10e968f8..11212b20 100644 --- a/docs/classes/DynamicClusterPool.html +++ b/docs/classes/DynamicClusterPool.html @@ -1,4 +1,4 @@ -DynamicClusterPool | poolifier - v2.6.42

+DynamicClusterPool | poolifier - v2.7.0

@@ -45,7 +45,7 @@ When the maximum number of workers is reached and workers are busy, an event is

DynamicClusterPool

Defined in src/pools/cluster/dynamic.ts:15

@@ -80,7 +80,8 @@ When the maximum number of workers is reached and workers are busy, an event is

Methods

afterTaskExecutionHook +

addTaskFunction +afterTaskExecutionHook afterWorkerNodeSetup beforeTaskExecutionHook checkDynamicPoolSize @@ -93,18 +94,22 @@ When the maximum number of workers is reached and workers are busy, an event is execute flushTasksQueue getWorkerInfo +hasTaskFunction hasWorkerNodeBackPressure internalBusy isMain -listTaskFunctions +listTaskFunctionNames registerWorkerMessageListener +removeTaskFunction sendKillMessageToWorker sendStartupMessageToWorker sendToWorker +setDefaultTaskFunction setTasksQueueOptions setWorkerChoiceStrategy setWorkerChoiceStrategyOptions setupHook +start workerListener

@@ -150,7 +155,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/dynamic.ts:27

Properties

@@ -171,7 +176,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:69

`Protected` `Readonly` filePath

filePath: string

@@ -180,7 +185,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:124

`Protected` `Readonly` max

max: number

@@ -189,7 +194,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/dynamic.ts:29

`Protected` `Readonly` numberOfWorkers

numberOfWorkers: number

@@ -198,7 +203,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:123

`Protected` `Readonly` opts

opts: ClusterPoolOptions = {}

@@ -207,11 +212,11 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/fixed.ts:47

`Protected` promiseResponseMap

promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...

The task execution response promise map.

The task execution response promise map:

key: The message id of each submitted task.
value: An object that contains the worker, the execution response promise resolve and reject callbacks.

Defined in src/pools/abstract-pool.ts:78

`Protected` workerChoiceStrategyContext

workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>

@@ -230,7 +235,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:84

`Readonly` `Internal` workerNodes

workerNodes: IWorkerNode<Worker, Data>[] = []

@@ -239,7 +244,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:66

Accessors

@@ -254,7 +259,7 @@ When the maximum number of workers is reached and workers are busy, an event is

Defined in src/pools/cluster/dynamic.ts:43

Methods

addTaskFunction

addTaskFunction(name, fn): Promise<boolean>
+
Adds a task function to this pool. +If a task function with the same name already exists, it will be overwritten.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
- +
  fn: TaskFunction<Data, Response>
  +
  The task function.
  +
  +
+
Returns Promise<boolean>
true if the task function was added, false otherwise.
+ +
+
Throws
https://nodejs.org/api/errors.html#class-typeerror If the name parameter is not a string or an empty string.
+ +
Throws
https://nodejs.org/api/errors.html#class-typeerror If the fn parameter is not a function.
+
+
Inherited from FixedClusterPool.addTaskFunction
+
- Defined in src/pools/abstract-pool.ts:856

`Protected` afterTaskExecutionHook

Defined in src/pools/abstract-pool.ts:1090

`Protected` afterWorkerNodeSetup

Defined in src/pools/abstract-pool.ts:1374

`Protected` beforeTaskExecutionHook

Defined in src/pools/abstract-pool.ts:1060

`Protected` checkDynamicPoolSize

Returns void

Defined in src/pools/abstract-pool.ts:197

`Protected` createAndSetupDynamicWorkerNode

Defined in src/pools/abstract-pool.ts:1307

`Protected` createAndSetupWorkerNode

Defined in src/pools/abstract-pool.ts:1263

`Protected` createWorker

Defined in src/pools/cluster/fixed.ts:108

destroy

Defined in src/pools/abstract-pool.ts:1000

`Protected` destroyWorkerNode

Defined in src/pools/cluster/fixed.ts:63

enableTasksQueue

Defined in src/pools/abstract-pool.ts:646

execute

Defined in src/pools/abstract-pool.ts:930

`Protected` flushTasksQueue

Returns void

Defined in src/pools/abstract-pool.ts:1697

`Protected` getWorkerInfo

Defined in src/pools/abstract-pool.ts:1613

hasTaskFunction

hasTaskFunction(name): boolean
+
Whether the specified task function exists in this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns boolean
true if the task function exists, false otherwise.
+ +
+
Inherited from FixedClusterPool.hasTaskFunction
+
- Defined in src/pools/abstract-pool.ts:843

hasWorkerNodeBackPressure

Defined in src/pools/abstract-pool.ts:1655

`Protected` internalBusy

Defined in src/pools/abstract-pool.ts:748

`Protected` isMain

listTaskFunctions

Defined in src/pools/cluster/fixed.ts:58

listTaskFunctionNames

listTaskFunctions(): string[]
listTaskFunctionNames(): string[]
Lists the names of task function available in this pool.

Returns string[]
The names of task function available in this pool.
-
Inherited from FixedClusterPool.listTaskFunctions
+
Inherited from FixedClusterPool.listTaskFunctionNames
- Defined in src/pools/abstract-pool.ts:726

Defined in src/pools/abstract-pool.ts:895

`Protected` registerWorkerMessageListener

Defined in src/pools/cluster/fixed.ts:100

removeTaskFunction

removeTaskFunction(name): Promise<boolean>
+
Removes a task function from this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns Promise<boolean>
true if the task function was removed, false otherwise.
+ +
+
Inherited from FixedClusterPool.removeTaskFunction
+
- Defined in src/pools/abstract-pool.ts:879

`Protected` sendKillMessageToWorker

sendKillMessageToWorker(workerNodeKey, workerId): Promise<void>
sendKillMessageToWorker(workerNodeKey): Promise<void>
Parameters
- -
  workerNodeKey: number
- -
  workerId: number
+
workerNodeKey: number

Returns Promise<void>

Defined in src/pools/abstract-pool.ts:1010

`Protected` sendStartupMessageToWorker

Defined in src/pools/cluster/fixed.ts:93

`Protected` sendToWorker

Defined in src/pools/cluster/fixed.ts:82

setDefaultTaskFunction

setDefaultTaskFunction(name): Promise<boolean>
+
Sets the default task function in this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns Promise<boolean>
true if the default task function was set, false otherwise.
+ +
+
Inherited from FixedClusterPool.setDefaultTaskFunction
+
- Defined in src/pools/abstract-pool.ts:908

setTasksQueueOptions

Defined in src/pools/abstract-pool.ts:660

setWorkerChoiceStrategy

Defined in src/pools/abstract-pool.ts:613

setWorkerChoiceStrategyOptions

Defined in src/pools/abstract-pool.ts:632

`Protected` setupHook

Defined in src/pools/cluster/fixed.ts:53

start

start(): void
+
Starts the minimum number of workers in this pool.
+
+
Returns void
+
+
Inherited from FixedClusterPool.start
+
- Defined in src/pools/abstract-pool.ts:984

`Protected` workerListener

Defined in src/pools/abstract-pool.ts:1525