internals library

Internal implementation details of the durable_workflow package.

This library exposes engine components that are not part of the stable public API. Use these only when you need to extend or test engine internals directly.

For normal usage, import package:durable_workflow/durable_workflow.dart.

Classes

RetryExecutor
Handles retry logic for workflow steps based on RetryPolicy.
SagaCompensator
Executes saga compensation (rollback) for failed workflow executions.
SignalManager
Manages durable signals for workflow waitSignal operations.
StepExecutor
Executes individual workflow steps with checkpoint/resume semantics.
TimerManager
Manages durable timers for workflow sleep operations.
WorkflowContextImpl
Concrete implementation of WorkflowContext.

Functions

utcNow() String
Returns the current UTC time as an ISO 8601 string.

Typedefs

StepNameMismatchWarning = void Function(String workflowExecutionId, int stepIndex, String checkpointedName, String currentName)
Callback signature for step name mismatch warnings during replay.

Exceptions / Errors

WorkflowCancelledException
Exception thrown when a workflow execution is cancelled during step execution.