X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Finterfaces%2FIPool.html;h=b64725e9908f76f69b5b40cc232538def3381e9d;hb=71d327d5587f0ce2b746ba33ec0cfbb3a0dc5d1b;hp=d706dad9582035dcadb4311ddd3455441468ff05;hpb=4608939f425568da5553db1f5bf883d4cca18e02;p=poolifier.git diff --git a/docs/interfaces/IPool.html b/docs/interfaces/IPool.html index d706dad9..b64725e9 100644 --- a/docs/interfaces/IPool.html +++ b/docs/interfaces/IPool.html @@ -1,4 +1,4 @@ -IPool | poolifier - v2.6.45
+IPool | poolifier - v2.7.4
  • Preparing search index...
  • -
  • The search index is not available
poolifier - v2.6.45
+
  • The search index is not available
  • poolifier - v2.7.4
    @@ -46,7 +46,7 @@ +
  • Defined in src/pools/pool.ts:201
  • @@ -54,13 +54,17 @@

    Properties

    +
    + +
    addTaskFunction: ((name, fn) => Promise<boolean>)
    +
    +

    Type declaration

    +
      +
    • +
        +
      • (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.

        +
    destroy: (() => Promise<void>)
    @@ -77,18 +116,19 @@
      • -
      • (): Promise<void>
      • +
      • (): Promise<void>
      • Terminates all workers in this pool.

        Returns Promise<void>

    +
  • Defined in src/pools/pool.ts:259
  • -
    emitter?: PoolEmitter
    -

    Emitter on which events can be listened to.

    +
    emitter?: __module | 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.
    • @@ -102,7 +142,7 @@
    +
  • Defined in src/pools/pool.ts:238
  • enableTasksQueue: ((enable, tasksQueueOptions?) => void)
    @@ -111,7 +151,7 @@
      • -
      • (enable, tasksQueueOptions?): void
      • +
      • (enable, tasksQueueOptions?): void
      • Enables/disables the worker node tasks queue in this pool.

        @@ -131,7 +171,7 @@

        Returns void

    +
  • Defined in src/pools/pool.ts:325
  • execute: ((data?, name?, transferList?) => Promise<Response>)
    @@ -140,7 +180,7 @@
    +
  • Defined in src/pools/pool.ts:247
  • +
    + +
    hasTaskFunction: ((name) => boolean)
    +
    +

    Type declaration

    +
      +
    • +
        +
      • (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.

        + +
    hasWorkerNodeBackPressure: ((workerNodeKey) => boolean)
    @@ -175,7 +240,7 @@
    +
  • Defined in src/pools/pool.ts:223
  • info: PoolInfo
    @@ -199,16 +264,16 @@
    -
    - -
    listTaskFunctions: (() => string[])
    +
  • Defined in src/pools/pool.ts:209
  • +
    + +
    listTaskFunctionNames: (() => string[])

    Type declaration

      • -
      • (): string[]
      • +
      • (): string[]
      • Lists the names of task function available in this pool.

        @@ -216,7 +281,57 @@
    +
  • Defined in src/pools/pool.ts:293
  • +
    + +
    removeTaskFunction: ((name) => Promise<boolean>)
    +
    +

    Type declaration

    +
      +
    • +
        +
      • (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.

        + +
    +
    + +
    setDefaultTaskFunction: ((name) => Promise<boolean>)
    +
    +

    Type declaration

    +
      +
    • +
        +
      • (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.

        + +
    setTasksQueueOptions: ((tasksQueueOptions) => void)
    @@ -225,7 +340,7 @@
    +
  • Defined in src/pools/pool.ts:334
  • setWorkerChoiceStrategy: ((workerChoiceStrategy, workerChoiceStrategyOptions?) => void)
    @@ -249,7 +364,7 @@
    +
  • Defined in src/pools/pool.ts:307
  • setWorkerChoiceStrategyOptions: ((workerChoiceStrategyOptions) => void)
    @@ -278,7 +393,7 @@
    +
  • Defined in src/pools/pool.ts:316
  • start: (() => void)
    @@ -302,14 +417,14 @@
    +
  • Defined in src/pools/pool.ts:255
  • workerNodes: IWorkerNode<Worker, Data>[]
    @@ -317,7 +432,7 @@
    +
  • Defined in src/pools/pool.ts:215
  • Generated using TypeDoc