Package-level declarations

Marker interface for user-defined typed compensation actions.

Scope for compensation execution, providing access to both step result and saga state.

Builder for "completes with result" DSL syntax.

Wrapper for the "events" keyword in monitor configuration.

Builder for "fails with reason" DSL syntax.

Flow-based saga executor that emits events as a reactive stream.

Marker for steps that are safe to retry (idempotent operations).

Extension to mark steps as idempotent at runtime.

Default no-op monitor implementation.

Retry policy for saga step execution with exponential backoff.

DSL builder for creating standalone saga executors.

Context carried through saga execution.

Wrapper for the "do" keyword in saga step configuration.

Events emitted during saga execution for monitoring and logging.

Error that occurred during saga execution or compensation.

Executes saga steps with forward and compensating logic.

Monitor for observing saga execution lifecycle events.

Result of saga execution.

Immutable descriptor of a saga step with forward and compensation logic.

Configuration scope for a saga step, enabling fluent chaining.

Wrapper for the "with" keyword in step forward action configuration.

Builder for "skip with reason" DSL syntax.

Wrapper for the "events" keyword in monitor configuration.

DSL builder for creating stateful saga executors with typed state management.

Wrapper for the "do" keyword in stateful saga step configuration.

Executes stateful saga steps with forward and compensating logic.

Result of stateful saga execution.

Represents a single step in a stateful saga with typed state management.

Configuration scope for a stateful saga step, enabling fluent chaining.

Wrapper for the "with" keyword in stateful step forward action configuration.

Builder for step action configuration.

Scope for forward step execution, providing access to saga state.

Builder for step action configuration.

Exception thrown when a step explicitly fails using fails with reason.

Represents the outcome of a saga step execution.

A type-safe wrapper for values that may be either enums or strings.

Starts the first saga step with "first do 'name' with { ... }" syntax.

Alternative: starts any saga step (not necessarily first).

Starts monitor configuration with "watching" keyword.

Extension to allow chaining after SagaStepConfiguration.

Extension to allow chaining after StatefulSagaStepConfiguration.

Extension function to convert a SagaExecutor to a FlowBasedSagaExecutor.

Marks the last step as idempotent using simple syntax.

Marks the last step as non-idempotent.

Adds compensation to the last defined step using simple syntax (suspend function).

Adds compensation to the last defined step using simple syntax.

Execute saga and return a Flow that emits all events followed by a terminal result event.

Adds a saga monitor using "monitoring with" syntax.

Adds a saga monitor instance.

Execute multiple suspend operations in parallel and wait for all to complete.

Execute two operations in parallel and return their results as a Pair.

Execute three operations in parallel and return their results as a Triple.

Factory function for creating sagas with DSL.

Factory function for creating stateful sagas with typed state management.

Alternative syntax: "step 'name' does { ... }"

Execute an operation with retry logic according to the policy.