Options for this dynamic cluster pool.
Readonly fileReadonly maxMaximum number of workers that can be created by this pool.
Readonly numberReadonly optsProtected promiseThe promise response map.
+The execution response promise map.
key: The message id of each submitted task.value: An object that contains the worker, the promise resolve and reject callbacks.value: An object that contains the worker, the execution response promise resolve and reject callbacks.When we receive a message from the worker we get a map entry with the promise resolve/reject bound to the message.
+When we receive a message from the worker, we get a map entry with the promise resolve/reject bound to the message id.
Protected workerWorker choice strategy context referencing a worker choice algorithm implementation.
Default to a round robin algorithm.
Readonly workerPrivate numberPrivate numberProtected afterProtected afterHook executed after the worker task promise resolution. +
Hook executed after the worker task execution. Can be overridden.
The worker.
The received message.
Protected afterProtected beforeProtected beforeHook executed before the worker task promise resolution. +
Hook executed before the worker task execution. Can be overridden.
The worker node key.
Protected chooseChooses a worker node for the next task.
The default uses a round robin algorithm to distribute the load.
[worker node key, worker node].
Protected createProtected createProtected dequeueProtected enqueueProtected flushProtected flushProtected internalProtected isProtected removeProtected sendProtected setupProtected tasksProtected workerThis function is the listener registered for each worker message.
The listener function to execute when a message is received from a worker.
This function is the listener registered for each worker message.
@@ -628,15 +532,16 @@ Can be overridden.Generated using TypeDoc
Constructs a new poolifier dynamic cluster pool.