SagaBuilder

class SagaBuilder<T>(clock: Clock = Clock.System)(source)

Builder for constructing a saga with multiple steps.

Constructors

constructor(clock: Clock = Clock.System)

Builds the saga.

Configures saga behavior.

fun <R> step(name: String, action: suspend () -> R, compensation: suspend (R) -> Unit? = null): SagaBuilder<T>

Adds a step to the saga.

fun <R> stepWithRetry(name: String, retries: Long = 3, action: suspend () -> R, compensation: suspend (R) -> Unit? = null): SagaBuilder<T>

Adds a step with retry capability.

fun <R> stepWithTimeout(name: String, timeout: Duration, action: suspend () -> R, compensation: suspend (R) -> Unit? = null): SagaBuilder<T>

Adds a step with timeout.