AdaptiveConcurrencyLimiterStrategy
Defined in: src/adaptive-concurrency.ts:210
Concurrency limiter whose limit follows the dependency: it grows while latency stays flat and shrinks when latency or failures show queueing.
Type Parameters
Section titled “Type Parameters”T
Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new AdaptiveConcurrencyLimiterStrategy<
T>(options,source):AdaptiveConcurrencyLimiterStrategy<T>
Defined in: src/adaptive-concurrency.ts:224
Parameters
Section titled “Parameters”options
Section titled “options”AdaptiveConcurrencyLimiterOptions<T>
source
Section titled “source”Returns
Section titled “Returns”AdaptiveConcurrencyLimiterStrategy<T>
Accessors
Section titled “Accessors”inflight
Section titled “inflight”Get Signature
Section titled “Get Signature”get inflight():
number
Defined in: src/adaptive-concurrency.ts:247
Returns
Section titled “Returns”number
Get Signature
Section titled “Get Signature”get limit():
number
Defined in: src/adaptive-concurrency.ts:243
Current concurrency limit (whole permits).
Returns
Section titled “Returns”number
queued
Section titled “queued”Get Signature
Section titled “Get Signature”get queued():
number
Defined in: src/adaptive-concurrency.ts:251
Returns
Section titled “Returns”number
Methods
Section titled “Methods”execute()
Section titled “execute()”execute(
next,context):Promise<Outcome<T,unknown>>
Defined in: src/adaptive-concurrency.ts:255
Parameters
Section titled “Parameters”Next<T>
context
Section titled “context”Returns
Section titled “Returns”Promise<Outcome<T, unknown>>