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

AdaptiveLimiterConfig

data class AdaptiveLimiterConfig(val initialLimit: Int = 20, val minLimit: Int = 1, val maxLimit: Int = 200, val increaseStep: Int = 1, val decreaseFactor: Double = 0.5, val latencyThreshold: Duration? = null)(source)

Configuration for AdaptiveLimiter.

Constructors

constructor(initialLimit: Int = 20, minLimit: Int = 1, maxLimit: Int = 200, increaseStep: Int = 1, decreaseFactor: Double = 0.5, latencyThreshold: Duration? = null)

Properties

decreaseFactor

val decreaseFactor: Double

Multiplicative factor applied to the limit on failure/overload (e.g. 0.5 halves it).

increaseStep

val increaseStep: Int

How much the limit grows after each successful, on-time call.

initialLimit

val initialLimit: Int

Concurrency limit the limiter starts at.

latencyThreshold

val latencyThreshold: Duration?

If a call takes longer than this, it's treated as an overload signal even though it succeeded — mirrors latency-based congestion detection. null disables latency-based back-off.

maxLimit

val maxLimit: Int

Upper bound the limit will never grow above.

minLimit

val minLimit: Int

Lower bound the limit will never shrink below.