X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=d633e72ee14b0a655fbb17da2e69b2ba94ddd6cf;hb=c22b117f8593bba575a4385b8f125f14b4bf1099;hp=27ed4997fc97f37ad8390ae2455176a5feb5dc99;hpb=6b83e544b1827a8a04898c3032dab73fe19687e6;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 27ed4997..d633e72e 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.6.23
+AbstractPool | poolifier - v2.6.29
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.23
+
  • The search index is not available
  • poolifier - v2.6.29
    @@ -49,7 +49,7 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:56
  • @@ -117,19 +117,24 @@ getWorkerNodeKeyByWorkerId handleTaskExecutionResponse handleWorkerReadyResponse +hasBackPressure +hasWorkerNodeBackPressure internalBusy isMain +listTaskFunctions redistributeQueuedTasks registerWorkerMessageListener removeWorkerNode +sendKillMessageToWorker sendStartupMessageToWorker +sendStatisticsMessageToWorker sendToWorker -sendWorkerStatisticsMessageToWorker setTasksQueueOptions setWorkerChoiceStrategy setWorkerChoiceStrategyOptions setupHook shallCreateDynamicWorker +shallUpdateTaskFunctionWorkerUsage startPool tasksQueueSize updateEluWorkerUsage @@ -177,7 +182,7 @@

    Returns AbstractPool<Worker, Data, Response>

    +
  • Defined in src/pools/abstract-pool.ts:103
  • Properties

    @@ -186,17 +191,19 @@

    Emitter on which events can be listened to.

    Events that can currently be listened to:

      -
    • 'full': Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected.
    • 'ready': Emitted when the number of workers created in the pool has reached the minimum size expected and are ready.
    • 'busy': Emitted when the number of workers created in the pool has reached the maximum size expected and are executing at least one task.
    • +
    • 'full': Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected.
    • +
    • 'destroy': Emitted when the pool is destroyed.
    • 'error': Emitted when an uncaught error occurs.
    • 'taskError': Emitted when an error occurs while executing a task.
    • +
    • 'backPressure': Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size >= pool maximum size^2).
    +
  • Defined in src/pools/abstract-pool.ts:65
  • filePath: string
    @@ -204,7 +211,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:105
  • numberOfWorkers: number
    @@ -212,7 +219,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:104
  • opts: PoolOptions<Worker>
    @@ -220,7 +227,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:106
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    @@ -233,7 +240,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:75
  • startTimestamp: number
    @@ -241,7 +248,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:94
  • starting: boolean
    @@ -249,7 +256,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:90
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -257,16 +264,16 @@
    +
  • Defined in src/pools/abstract-pool.ts:81
  • - +
    workerNodes: IWorkerNode<Worker, Data>[] = []

    Pool worker nodes.

    +
  • Defined in src/pools/abstract-pool.ts:62
  • Accessors

    @@ -280,7 +287,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:640
  • +
  • Defined in src/pools/abstract-pool.ts:631
  • +
  • Defined in src/pools/abstract-pool.ts:321
  • +
  • Defined in src/pools/abstract-pool.ts:517
  • +
  • Defined in src/pools/abstract-pool.ts:512
  • +
  • Defined in src/pools/abstract-pool.ts:464
  • +
  • Defined in src/pools/abstract-pool.ts:502
  • +
  • Defined in src/pools/abstract-pool.ts:481
  • +
  • Defined in src/pools/abstract-pool.ts:507
  • Methods

    @@ -396,7 +403,7 @@

    Throws

    https://nodejs.org/api/errors.html#class-error If the added worker node is not found.

    +
  • Defined in src/pools/abstract-pool.ts:1252
  • +
  • Defined in src/pools/abstract-pool.ts:818
  • +
  • Defined in src/pools/abstract-pool.ts:1081
  • +
  • Defined in src/pools/abstract-pool.ts:795
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:618
  • +
  • Defined in src/pools/abstract-pool.ts:1224
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:176
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:145
  • +
  • Defined in src/pools/abstract-pool.ts:525
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:158
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:202
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:284
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:230
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:240
  • +
  • Defined in src/pools/abstract-pool.ts:942
  • +
  • Defined in src/pools/abstract-pool.ts:1028
  • +
  • Defined in src/pools/abstract-pool.ts:988
  • +
  • Defined in src/pools/abstract-pool.ts:981
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1319
  • +
  • Defined in src/pools/abstract-pool.ts:741
  • +
  • Defined in src/pools/abstract-pool.ts:771
  • +
  • Defined in src/pools/abstract-pool.ts:596
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1311
  • +
  • Defined in src/pools/abstract-pool.ts:681
  • +
  • Defined in src/pools/abstract-pool.ts:1306
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1327
  • +
  • Defined in src/pools/abstract-pool.ts:1337
  • +
  • Defined in src/pools/abstract-pool.ts:1241
  • +
  • Defined in src/pools/abstract-pool.ts:544
  • +
  • Defined in src/pools/abstract-pool.ts:556
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1196
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1182
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:647
  • +
  • Defined in src/pools/abstract-pool.ts:786
  • +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1115
  • +
  • Defined in src/pools/abstract-pool.ts:1068
  • +
  • Defined in src/pools/abstract-pool.ts:1275
  • +
    + +
    -
    - -
    +
    + +

    Returns void

    -
    - -
    +
    + +

    Returns void

    +
  • Defined in src/pools/abstract-pool.ts:970
  • +
  • Defined in src/pools/abstract-pool.ts:608
  • +
  • Defined in src/pools/abstract-pool.ts:563
  • +
  • Defined in src/pools/abstract-pool.ts:582
  • +
  • Defined in src/pools/abstract-pool.ts:779
  • +
  • Defined in src/pools/abstract-pool.ts:959
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:308
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1323
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:903
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:877
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:852
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:889
  • +
  • Defined in src/pools/abstract-pool.ts:1164