runtime/me.ahoo.wow.runtime.subscription/RetryPolicy

RetryPolicy

class RetryPolicy @InternalWowApi constructor(val maxAttempts: Int = HandlerRetry.DEFAULT_MAX_ATTEMPTS, val initialBackoff: Duration = 100.milliseconds, val maxBackoff: Duration = 5.seconds, val multiplier: Double = 2.0, val timeout: Duration = Duration.INFINITE)

How a failing call is retried: at most maxAttempts calls in all, waiting initialBackoff after the first failure and multiplier times longer after each next one, never longer than maxBackoff. A handler's attempt that runs longer than timeout is cancelled and counts as failed; infinite by default.

Constructors

RetryPolicy

@InternalWowApi

constructor(maxAttempts: Int = HandlerRetry.DEFAULT_MAX_ATTEMPTS, initialBackoff: Duration = 100.milliseconds, maxBackoff: Duration = 5.seconds, multiplier: Double = 2.0, timeout: Duration = Duration.INFINITE)

Types

Companion

object Companion

Properties

initialBackoff

val initialBackoff: Duration

maxAttempts

val maxAttempts: Int

maxBackoff

val maxBackoff: Duration

multiplier

val multiplier: Double

timeout

val timeout: Duration

Functions

backoff

fun backoff(failures: Int): Duration

The wait after failures failed calls (1 for the first).

copyWith

@InternalWowApi

fun copyWith(maxAttempts: Int = this.maxAttempts, initialBackoff: Duration = this.initialBackoff, maxBackoff: Duration = this.maxBackoff, multiplier: Double = this.multiplier, timeout: Duration = this.timeout): RetryPolicy

This RetryPolicy with the given fields replaced: Wow's own copy, left out of the ABI.

equals

open operator override fun equals(other: Any?): Boolean

hashCode

open override fun hashCode(): Int

toString

open override fun toString(): String

with

fun with(retry: HandlerRetry?): RetryPolicy

This policy with the settings retry gives in place of its own. An initial backoff longer than this policy's maximum raises the maximum to it, unless retry gives the maximum too.