X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractPool.html;h=57b75a1a6da1adfb6f25fa46a5518a8e1ce7ed62;hb=70ceef6e16bec1f1d12754b2f5e8d71c91ca06a7;hp=30969c24eba5305e5ab3a9f7431500638caca2a7;hpb=dbf662afd2c11c4d18c4e648f90d392528a715f8;p=poolifier.git diff --git a/docs/classes/AbstractPool.html b/docs/classes/AbstractPool.html index 30969c24..57b75a1a 100644 --- a/docs/classes/AbstractPool.html +++ b/docs/classes/AbstractPool.html @@ -1,4 +1,4 @@ -AbstractPool | poolifier - v2.7.0
+AbstractPool | poolifier - v3.0.0
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.7.0
+
  • The search index is not available
  • poolifier - v3.0.0

    Constructors

    @@ -203,13 +202,14 @@

    Returns AbstractPool<Worker, Data, Response>

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

    - -
    emitter?: PoolEmitter
    -

    Emitter on which events can be listened to.

    + +
    emitter?: EventEmitterAsyncResource
    +

    Event emitter integrated with async resource on which events can be listened to. +The async tracking tooling identifier is poolifier:<PoolType>-<WorkerType>-pool.

    Events that can currently be listened to:

    • 'ready': Emitted when the number of workers created in the pool has reached the minimum size expected and are ready.
    • @@ -224,7 +224,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:73
  • filePath: string
    @@ -232,7 +232,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:128
  • max?: number
    @@ -240,7 +240,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:78
  • numberOfWorkers: number
    @@ -248,7 +248,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:127
  • opts: PoolOptions<Worker>
    @@ -256,7 +256,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:129
  • promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...
    @@ -269,7 +269,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:87
  • startTimestamp: number
    @@ -277,7 +277,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:117
  • started: boolean
    @@ -285,7 +285,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:109
  • starting: boolean
    @@ -293,7 +293,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:113
  • taskFunctions: Map<string, TaskFunction<Data, Response>>
    @@ -305,7 +305,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:104
  • workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>
    @@ -313,7 +313,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:93
  • workerNodes: IWorkerNode<Worker, Data>[] = []
    @@ -322,7 +322,7 @@
    +
  • Defined in src/pools/abstract-pool.ts:70
  • Accessors

    @@ -336,7 +336,7 @@

    Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:660
  • +
  • Defined in src/pools/abstract-pool.ts:651
  • +
  • Defined in src/pools/abstract-pool.ts:271
  • +
  • Defined in src/pools/abstract-pool.ts:484
  • +
  • Defined in src/pools/abstract-pool.ts:477
  • +
  • Defined in src/pools/abstract-pool.ts:429
  • +
  • Defined in src/pools/abstract-pool.ts:467
  • +
  • Defined in src/pools/abstract-pool.ts:446
  • +
  • Defined in src/pools/abstract-pool.ts:472
  • Methods

    @@ -461,7 +461,7 @@ If a task function with the same name already exists, it will be overwritten.

    +
  • Defined in src/pools/abstract-pool.ts:796
  • +
  • Defined in src/pools/abstract-pool.ts:1593
  • +
  • Defined in src/pools/abstract-pool.ts:1033
  • +
  • Defined in src/pools/abstract-pool.ts:1344
  • +
  • Defined in src/pools/abstract-pool.ts:1003
  • Returns TasksQueueOptions

    +
  • Defined in src/pools/abstract-pool.ts:600
  • +
  • Defined in src/pools/abstract-pool.ts:1568
  • +
  • Defined in src/pools/abstract-pool.ts:1556
  • -
    - -
    -
    - -
    +
  • Defined in src/pools/abstract-pool.ts:1562
  • +
  • Defined in src/pools/abstract-pool.ts:494
  • Returns void

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

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

    +
  • Defined in src/pools/abstract-pool.ts:217
  • +
  • Defined in src/pools/abstract-pool.ts:1160
  • +
  • Defined in src/pools/abstract-pool.ts:1250
  • +
  • Defined in src/pools/abstract-pool.ts:1206
  • +
  • Defined in src/pools/abstract-pool.ts:1199
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:855
  • Returns undefined | Task<Data>

    +
  • Defined in src/pools/abstract-pool.ts:1658
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:940
  • +
  • Defined in src/pools/abstract-pool.ts:979
  • +
  • Defined in src/pools/abstract-pool.ts:565
  • Returns number

    +
  • Defined in src/pools/abstract-pool.ts:1652
  • +
  • Defined in src/pools/abstract-pool.ts:870
  • +
  • Defined in src/pools/abstract-pool.ts:1646
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1666
  • +
  • Defined in src/pools/abstract-pool.ts:1676
  • +
  • Defined in src/pools/abstract-pool.ts:1582
  • +
  • Defined in src/pools/abstract-pool.ts:513
  • +
  • Defined in src/pools/abstract-pool.ts:525
  • Returns void

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

    +
  • Defined in src/pools/abstract-pool.ts:1512
  • +
  • Defined in src/pools/abstract-pool.ts:1631
  • +
  • Defined in src/pools/abstract-pool.ts:783
  • +
  • Defined in src/pools/abstract-pool.ts:1624
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:667
  • +
  • Defined in src/pools/abstract-pool.ts:994
  • +
  • Defined in src/pools/abstract-pool.ts:835
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1390
  • +
    + +
    +
  • Defined in src/pools/abstract-pool.ts:1305
  • +
  • Defined in src/pools/abstract-pool.ts:819
  • +
  • Defined in src/pools/abstract-pool.ts:1615
  • Returns Promise<void>

    +
  • Defined in src/pools/abstract-pool.ts:951
  • +
  • Defined in src/pools/abstract-pool.ts:1371
  • +
  • Defined in src/pools/abstract-pool.ts:1378
  • Returns Promise<boolean>

    +
  • Defined in src/pools/abstract-pool.ts:686
  • Returns Promise<boolean>

    +
  • Defined in src/pools/abstract-pool.ts:727
  • +
  • Defined in src/pools/abstract-pool.ts:1188
  • +
  • Defined in src/pools/abstract-pool.ts:848
  • +
  • Defined in src/pools/abstract-pool.ts:620
  • +
  • Defined in src/pools/abstract-pool.ts:579
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:614
  • +
  • Defined in src/pools/abstract-pool.ts:633
  • +
  • Defined in src/pools/abstract-pool.ts:532
  • +
  • Defined in src/pools/abstract-pool.ts:551
  • +
  • Defined in src/pools/abstract-pool.ts:987
  • +
  • Defined in src/pools/abstract-pool.ts:1177
  • Returns boolean

    +
  • Defined in src/pools/abstract-pool.ts:861
  • +
  • Defined in src/pools/abstract-pool.ts:1066
  • +
  • Defined in src/pools/abstract-pool.ts:924
  • Returns void

    +
  • Defined in src/pools/abstract-pool.ts:1430
  • Returns number

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

    +
  • Defined in src/pools/abstract-pool.ts:1458
  • +
  • Defined in src/pools/abstract-pool.ts:627
  • +
  • Defined in src/pools/abstract-pool.ts:640
  • Returns void

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

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

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

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

    -
    - +
  • Defined in src/pools/abstract-pool.ts:1107
  • +
    +
    +
  • Defined in src/pools/abstract-pool.ts:1496
  • @@ -1691,13 +1714,9 @@ Can be overridden.

  • checkAndEmitDynamicWorkerCreationEvents
  • checkAndEmitTaskExecutionEvents
  • checkAndEmitTaskQueuingEvents
  • -
  • checkDynamicPoolSize
  • -
  • checkFilePath
  • checkMessageWorkerId
  • checkNumberOfWorkers
  • checkPoolOptions
  • -
  • checkValidTasksQueueOptions
  • -
  • checkValidWorkerChoiceStrategy
  • checkValidWorkerChoiceStrategyOptions
  • chooseWorkerNode
  • createAndSetupDynamicWorkerNode
  • @@ -1705,6 +1724,7 @@ Can be overridden.

  • createWorker
  • deleteTaskFunctionWorkerUsages
  • dequeueTask
  • +
  • deregisterWorkerMessageListener
  • destroy
  • destroyWorkerNode
  • enableTasksQueue
  • @@ -1721,10 +1741,12 @@ Can be overridden.

  • hasBackPressure
  • hasTaskFunction
  • hasWorkerNodeBackPressure
  • +
  • initializeEventEmitter
  • internalBusy
  • isMain
  • listTaskFunctionNames
  • redistributeQueuedTasks
  • +
  • registerOnceWorkerMessageListener
  • registerWorkerMessageListener
  • removeTaskFunction
  • removeWorkerNode
  • @@ -1756,9 +1778,9 @@ Can be overridden.

  • updateTaskStatisticsWorkerUsage
  • updateTaskStolenStatisticsWorkerUsage
  • updateWaitTimeWorkerUsage
  • -
  • workerListener
  • +
  • workerMessageListener
  • Generated using TypeDoc

    -
    \ No newline at end of file +
    \ No newline at end of file