connector-redis/com.river.connector.redis

Package-level declarations

Functions

Link copied to clipboard
@ExperimentalCoroutinesApi
fun RedissonClient.semaphore(name: String, concurrencyLevel: Int, leaseTime: Duration = 10.seconds): suspend CoroutineScope.() -> AsyncSemaphore<String>

Returns a suspending function that creates an AsyncSemaphore using a Redisson semaphore. The semaphore is created the first time the returned function is invoked.