SagaExecutor

Executes saga steps with forward and compensating logic.

SagaExecutor orchestrates the execution of saga steps, handling forward execution, compensation on failure, and event notification. The executor is coroutine-friendly and uses suspend functions for async operations.

Execution Model

1. Execute steps sequentially in order (asynchronously using coroutines)

2. If a step fails, compensate completed steps in reverse order (LIFO)

3. Notify monitors of all lifecycle events

4. Return structured result (Completed/Aborted/CompensationFailure)

Coroutine Safety

SagaExecutor uses suspend functions for execution, allowing for non-blocking async operations. Each execution is isolated and maintains its own completion stack. Multiple executions can run concurrently in different coroutines.

Usage Example

val saga = sagaExecutor<OrderContext, OrderResult> {
    step("reserve") { context -> /* suspend operation */}
    compensate { result -> /* suspend compensation */}

    step("charge") { context -> /* suspend operation */}
    compensate { result -> /* suspend compensation */}
}

// Execute within a coroutine
val result = saga.execute(OrderContext(...))

Parameters

Inheritors