X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=be753f26c66d6837b8e47043f8cb866625b74dfd;hb=51711a7bd394055296e4eab0829df39d787e06b7;hp=488280ac4aa1b6382716cf99fddd5e0e553a4762;hpb=f7d06005106fbf8e845731e6652dd676b765f60e;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 488280ac..be753f26 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.6.27
+AbstractPool | poolifier - v2.6.31
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.27
+
  • The search index is not available
  • poolifier - v2.6.31
    @@ -49,7 +49,7 @@
    • IPool<Worker, Data, Response>
    +
  • Defined in src/pools/abstract-pool.ts:56
  • @@ -63,12 +63,12 @@

    Properties

    @@ -91,7 +91,9 @@ afterWorkerNodeSetup beforeTaskExecutionHook buildTasksQueueOptions -checkAndEmitEvents +checkAndEmitDynamicWorkerCreationEvents +checkAndEmitTaskExecutionEvents +checkAndEmitTaskQueuingEvents checkDynamicPoolSize checkFilePath checkMessageWorkerId @@ -118,6 +120,8 @@ getWorkerNodeKeyByWorkerId handleTaskExecutionResponse handleWorkerReadyResponse +hasBackPressure +hasWorkerNodeBackPressure internalBusy isMain listTaskFunctions @@ -133,6 +137,7 @@ setWorkerChoiceStrategyOptions setupHook shallCreateDynamicWorker +shallUpdateTaskFunctionWorkerUsage startPool tasksQueueSize updateEluWorkerUsage @@ -180,7 +185,7 @@

    Returns AbstractPool<Worker, Data, Response>

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

    @@ -195,12 +200,13 @@
  • '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
    @@ -208,7 +214,15 @@
    +
  • Defined in src/pools/abstract-pool.ts:110
  • +
    + +
    max?: number
    +

    Dynamic pool maximum size property placeholder.

    +
    +
    numberOfWorkers: number
    @@ -216,7 +230,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:109
  • opts: PoolOptions<Worker>
    @@ -224,7 +238,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:111
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    @@ -237,7 +251,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:75
  • startTimestamp: number
    @@ -245,7 +259,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:99
  • starting: boolean
    @@ -253,15 +267,7 @@
    -
    - -
    taskFunctions: string[]
    -

    The task function names.

    -
    -
    +
  • Defined in src/pools/abstract-pool.ts:95
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -269,16 +275,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

    @@ -292,7 +298,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:650
  • +
  • Defined in src/pools/abstract-pool.ts:641
  • +
  • Defined in src/pools/abstract-pool.ts:324
  • - +
    +
  • Defined in src/pools/abstract-pool.ts:525
  • - +
    +
  • Defined in src/pools/abstract-pool.ts:518
  • +
  • Defined in src/pools/abstract-pool.ts:470
  • +
  • Defined in src/pools/abstract-pool.ts:508
  • +
  • Defined in src/pools/abstract-pool.ts:487
  • +
  • Defined in src/pools/abstract-pool.ts:513
  • Methods

    @@ -408,7 +414,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:1291
  • +
  • Defined in src/pools/abstract-pool.ts:834
  • +
  • Defined in src/pools/abstract-pool.ts:1109
  • +
  • Defined in src/pools/abstract-pool.ts:804
  • Returns TasksQueueOptions

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

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

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

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:243
  • +
  • Defined in src/pools/abstract-pool.ts:966
  • +
  • Defined in src/pools/abstract-pool.ts:1052
  • +
  • Defined in src/pools/abstract-pool.ts:1012
  • +
  • Defined in src/pools/abstract-pool.ts:1005
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1357
  • +
  • Defined in src/pools/abstract-pool.ts:750
  • +
  • Defined in src/pools/abstract-pool.ts:780
  • +
  • Defined in src/pools/abstract-pool.ts:606
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1351
  • +
  • Defined in src/pools/abstract-pool.ts:691
  • +
  • Defined in src/pools/abstract-pool.ts:1345
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1365
  • +
  • Defined in src/pools/abstract-pool.ts:1375
  • -

    Returns WorkerInfo

    The worker information.

    +

    Returns undefined | WorkerInfo

    The worker information.

    +
  • Defined in src/pools/abstract-pool.ts:1280
  • +
  • Defined in src/pools/abstract-pool.ts:554
  • +
  • Defined in src/pools/abstract-pool.ts:566
  • Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:1212
  • +
    + +
    +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:657
  • +
  • Defined in src/pools/abstract-pool.ts:795
  • +
  • Defined in src/pools/abstract-pool.ts:678
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1143
  • +
  • Defined in src/pools/abstract-pool.ts:1096
  • +
  • Defined in src/pools/abstract-pool.ts:1314
  • Returns Promise<void>

    +
  • Defined in src/pools/abstract-pool.ts:759
  • +
  • Defined in src/pools/abstract-pool.ts:1123
  • +
  • Defined in src/pools/abstract-pool.ts:1130
  • +
  • Defined in src/pools/abstract-pool.ts:994
  • +
  • Defined in src/pools/abstract-pool.ts:618
  • +
  • Defined in src/pools/abstract-pool.ts:573
  • +
  • Defined in src/pools/abstract-pool.ts:592
  • +
  • Defined in src/pools/abstract-pool.ts:788
  • +
  • Defined in src/pools/abstract-pool.ts:983
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:311
  • Returns number

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

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

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

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

    +
  • Defined in src/pools/abstract-pool.ts:913
  • +
  • Defined in src/pools/abstract-pool.ts:1192