ReadonlydefaultDomains for routing events
ReadonlyexecutionEngine responsible for executing state machine logic
ReadonlyexecutionunitsComputational cost metric associated with event handling operations
ReadonlyregistryRegistry containing available state machines
ReadonlyspanOpenTelemetry span configuration for observability
ReadonlysyncResource manager for state synchronization and memory access
The contract-defined domain for the handler
Memory interface for state persistence and retrieval
Whether this orchestrator requires resource locking for concurrent safety
Source identifier from the first registered machine
Provides access to the system error event schema configuration.
Executes state machine orchestration for an incoming event.
Performs the complete orchestration workflow: resolves the appropriate machine, validates input, executes the machine logic, processes emitted events, and persists the new state. Handles both new orchestrations and continuation of existing ones.
For violation errors (transaction, execution, contract, config), the error is thrown to enable retry mechanisms. For non-violation errors, system error events are emitted to the workflow initiator, and the orchestration enters a terminal failure state.
The incoming event triggering orchestration
Optionalopentelemetry: ArvoEventHandlerOpenTelemetryOptionsOptional OpenTelemetry configuration for tracing
Object containing emitted events from the orchestration or system errors
Orchestrates state machine execution and lifecycle management.
Coordinates machine resolution, state persistence, event processing, and error handling for Arvo's event-driven orchestration workflows. Manages the complete lifecycle from event receipt through machine execution to emitting result events.