ParkedRetrySpec

class ParkedRetrySpec @InternalWowApi constructor(val maxRetries: Int = DEFAULT_MAX_RETRIES, val initialBackoff: Duration = DEFAULT_INITIAL_BACKOFF, val claimTtl: Duration = DEFAULT_CLAIM_TTL)

How a parked entry is retried over the long horizon (9.x RetrySpec): at most maxRetries automatic retries, the first initialBackoff after the failure and each next one twice as long after the previous one started; claimTtl is how long a retry's claim on the entry holds before another retry may start, such as on the partition's next owner: it cancels nothing, the retry runs on. A maxRetries of 0 turns automatic retries off.

Fields may be added: construct one with of; the constructor is internal to Wow.

Constructors

Link copied to clipboard
constructor(maxRetries: Int = DEFAULT_MAX_RETRIES, initialBackoff: Duration = DEFAULT_INITIAL_BACKOFF, claimTtl: Duration = DEFAULT_CLAIM_TTL)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun backoff(retries: Int): Duration

The backoff after retries retries: initialBackoff doubled retries times, at most Long.MAX_VALUE ms.

Link copied to clipboard
fun copyWith(maxRetries: Int = this.maxRetries, initialBackoff: Duration = this.initialBackoff, claimTtl: Duration = this.claimTtl): ParkedRetrySpec

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

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String