SystemicFailureOptions

class SystemicFailureOptions @InternalWowApi constructor(val failingAggregates: Int = 3, val window: Duration = 10.seconds, val initialBackoff: Duration = 1.seconds, val maxBackoff: Duration = 30.seconds)

When a subscription pauses a partition on a systemic failure: at once on a failure classified me.ahoo.wow.spi.subscription.FailureClass.SYSTEMIC; and when failingAggregates different aggregates failed with a recoverable one within window, with no handling succeeding since (0 turns that off). While paused, one attempt at a time probes whether what failed is back, the first initialBackoff after the pause, each next one twice as long after the previous one failed, at most maxBackoff.

Fields may be added: Wow builds it from the host's configuration, so the constructor is internal to Wow.

Constructors

Link copied to clipboard
constructor(failingAggregates: Int = 3, window: Duration = 10.seconds, initialBackoff: Duration = 1.seconds, maxBackoff: Duration = 30.seconds)

Properties

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

Functions

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