shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga/SagaProperties

SagaProperties

@ConfigurationProperties(prefix = "veds.saga")

data class SagaProperties(val awaitResponseTimeout: Duration = Duration.ofMinutes(DEFAULT_AWAIT_RESPONSE_TIMEOUT_MINUTES), val watchdogInterval: Duration = Duration.ofMinutes(DEFAULT_WATCHDOG_INTERVAL_MINUTES), val compensationRetryCooldown: Duration = Duration.ofMinutes(DEFAULT_COMPENSATION_RETRY_COOLDOWN_MINUTES))(source)

Externalized configuration for the saga engine and its watchdog.

Bound from veds.saga.*.

Example:

veds:
  saga:
    await-response-timeout: 30m
    watchdog-interval: 1m
    compensation-retry-cooldown: 5m

Constructors

SagaProperties

constructor(awaitResponseTimeout: Duration = Duration.ofMinutes(DEFAULT_AWAIT_RESPONSE_TIMEOUT_MINUTES), watchdogInterval: Duration = Duration.ofMinutes(DEFAULT_WATCHDOG_INTERVAL_MINUTES), compensationRetryCooldown: Duration = Duration.ofMinutes(DEFAULT_COMPENSATION_RETRY_COOLDOWN_MINUTES))

Types

Companion

object Companion

Properties

awaitResponseTimeout

val awaitResponseTimeout: Duration

After a saga has been in AWAITING_RESPONSE for longer than this, the watchdog automatically fails it with reason "timeout", triggering compensation.

compensationRetryCooldown

val compensationRetryCooldown: Duration

Minimum time between two compensation attempts on the same saga. Sagas stuck in COMPENSATING or that ended in COMPENSATION_FAILED are eligible for another compensation attempt once this cooldown elapses (based on updatedAt).

watchdogInterval

val watchdogInterval: Duration

Scheduled interval at which the saga watchdog runs.