runtime/me.ahoo.wow.runtime.subscription/ParkedRetryOptions

ParkedRetryOptions

class ParkedRetryOptions @InternalWowApi constructor(val spec: ParkedRetrySpec = ParkedRetrySpec(), val specs: Map<SubscriptionId, ParkedRetrySpec> = emptyMap(), val scanInterval: Duration = 10.seconds)

How a SubscriptionRuntime retries its parked entries over the long horizon (9.x CompensationScheduler): every scanInterval it reads its subscriptions' ledger entries and, in each partition it runs, retries those whose next retry is due (me.ahoo.wow.spi.ledger.ParkedAggregate.nextRetryAt) and runs the requests an operator left on them.

An entry's retry spec is the one an operator applied to it, else its subscription's in specs (by SubscriptionId, as wow.subscriptions.[<context>.<name>].parked.* configures it), else spec (wow.subscription.parked.*).

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