RetryExecutor

open class RetryExecutor

Constructors

Link copied to clipboard
private constructor()

Properties

Link copied to clipboard
private val LOG: Logger

Functions

Link copied to clipboard
open fun <T, C> executeSync(action: Callable<T>, context: C, policy: RetryPolicyContext<C>, retryableRes: BiPredicate<Integer, T>, retryableErr: BiPredicate<Integer, Exception>): T
Link copied to clipboard
private open fun performBackoff(attempt: Int, policy: RetryPolicyContext<out Any>)
Link copied to clipboard
private open fun <C> shouldRetryException(ex: Exception, attempt: Int, context: C, policy: RetryPolicyContext<C>, retryableErr: BiPredicate<Integer, Exception>): Boolean
Link copied to clipboard
private open fun <T, C> shouldRetryResult(result: T, attempt: Int, context: C, policy: RetryPolicyContext<C>, retryableRes: BiPredicate<Integer, T>): Boolean