Skip to content

ConcurrencyLimiterStrategy

Defined in: src/rate-limiter.ts:50

Bulkhead: limits concurrent executions, queues a few, rejects the rest.

T

new ConcurrencyLimiterStrategy<T>(options, source): ConcurrencyLimiterStrategy<T>

Defined in: src/rate-limiter.ts:59

ConcurrencyLimiterOptions

StrategySource

ConcurrencyLimiterStrategy<T>

get active(): number

Defined in: src/rate-limiter.ts:69

Executions running now.

number


get queued(): number

Defined in: src/rate-limiter.ts:74

Executions waiting for a permit.

number

execute(next, context): Promise<Outcome<T, unknown>>

Defined in: src/rate-limiter.ts:78

Next<T>

ResilienceContext

Promise<Outcome<T, unknown>>

ResilienceStrategy.execute