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

TimeLimiterRegistry

Registry for managing multiple named time limiters.

Example usage:

val registry = TimeLimiterRegistry.create()

val fastLimiter = registry.getOrCreate("fast-operations") {
    timeout = 1.seconds
}

val slowLimiter = registry.getOrCreate("slow-operations") {
    timeout = 30.seconds
}

Types

Companion

object Companion

Factory for TimeLimiterRegistry.

Functions

get

suspend fun get(name: String): TimeLimiter?

Gets an existing time limiter by name.

getAllStatistics

suspend fun getAllStatistics(): Map<String, TimeLimiterStatistics>

Gets statistics for all time limiters.

getNames

suspend fun getNames(): Set<String>

Gets all time limiter names in the registry.

getOrCreate

suspend fun getOrCreate(name: String, configure: TimeLimiterConfigBuilder.() -> Unit? = null): TimeLimiter

Gets an existing time limiter or creates a new one.

remove

suspend fun remove(name: String): TimeLimiter?

Removes a time limiter from the registry.

resetAllStatistics

suspend fun resetAllStatistics()

Resets statistics for all time limiters in the registry.