Catalyst/io.circul.catalyst

Package-level declarations

Types

typealias RetryBlock<T> = suspend (Int) -> T

Represents a block to be retried, taking an integer parameter (the retry count) and returning a value of type T.

open class RetryPolicy(retryPredicate: RetryPredicate = onException, delayStrategy: DelayStrategy = noDelay)

Represents a retry policy that combines a RetryPredicate and a DelayStrategy.

Properties

val DelayStrategy.asRetryPolicy: RetryPolicy

Converts a DelayStrategy to a RetryPolicy with a RetryPredicate of onException

val RetryPredicate.asRetryPolicy: RetryPolicy

Converts a RetryPredicate to a RetryPolicy with a DelayStrategy of noDelay

Functions

infix fun DelayStrategy.with(that: RetryPredicate): RetryPolicy

Combines a DelayStrategy with a RetryPredicate to create a RetryPolicy.

infix fun RetryPredicate.with(that: DelayStrategy): RetryPolicy

Combines a RetryPredicate with a DelayStrategy to create a RetryPolicy.