Arrow Resilience Kit/com.sorinirmies.arrow.resiliencekit/AdaptiveLimiter

AdaptiveLimiter

class AdaptiveLimiter(source)

AIMD-based adaptive concurrency limiter. See file-level docs for details.

Types

object Companion

Factory for AdaptiveLimiter.

Properties

val config: AdaptiveLimiterConfig

The configuration this limiter was created with.

Functions

suspend fun currentLimit(): Int

Returns the current dynamic concurrency limit.

suspend fun <T> execute(block: suspend () -> T): T

Executes block under the adaptive concurrency limit, blocking (without polling) until a slot is available.

suspend fun statistics(): AdaptiveLimiterStatistics

Returns a snapshot of the current limiter statistics.

Inherited functions

fun AdaptiveLimiter.asPolicy(): Policy

Adapts this AdaptiveLimiter into a Policy.