spring-boot/me.ahoo.wow.spring.boot/BackpressureProperties

BackpressureProperties

@InternalWowApi

class BackpressureProperties

How a subscription answers backpressure: a downstream that is up but asks to be called later (wow.command.busy, wow.wait.timeout, wow.query.busy, a 429 with Retry-After). The entry is retried, then its aggregate parks; it never pauses the partition. Meanwhile each backpressure halves the handlings the partition runs at once, and each success raises them again.

Constructors

BackpressureProperties

constructor()

Properties

var initialBackoff: Duration

The wait before the first retry; it doubles at each next one.

var jitter: Double

The share of each wait, 0 to 1, by which it is shortened at random, so that retries do not come in step.

var maxAttempts: Int

The most attempts of an entry that meets backpressure before its aggregate parks.

var maxBackoff: Duration

The longest wait between two retries; a downstream's longer Retry-After still counts.

var minConcurrency: Int

The fewest handlings a throttled partition runs at once.

Functions

fun options(): BackpressureOptions