Enum EngineError 

pub enum EngineError {
    MissingStore,
    MissingVisibilityStore,
    Load {
        reason: String,
    },
    UnknownVersion {
        workflow_type: String,
        version: ContentHash,
        loaded: String,
    },
    VersionPinned {
        workflow_type: String,
        version: ContentHash,
        pinned_by: PinHolder,
    },
    RouteActive {
        workflow_type: String,
        version: ContentHash,
    },
    ManifestMismatch {
        workflow_type: String,
        version: ContentHash,
        resident_digest: String,
        incoming_digest: String,
    },
    ConflictingEventPublisher,
    EventStreaming(PublishError),
    Store(StoreError),
    Durability(DurabilityError),
    Package(PackageError),
    Runtime {
        reason: String,
    },
    Gate3BifReplacementMissing {
        module: String,
        function: String,
        arity: u8,
    },
    CleanupExecutorPoisoned,
    CleanupExecutorShutdownTimedOut {
        timeout_millis: u128,
    },
    ProcessExitRegistryPoisoned,
    ProcessExitOwnershipPoisoned {
        process_id: u64,
    },
    ProcessExitStatePoisoned {
        process_id: u64,
    },
    ProcessExitSubscriptionUnavailable,
    ProcessExitDrainerSpawn {
        reason: String,
    },
    ProcessExitDrainerPoisoned,
    ProcessExitOutcomeMissingAfterEvent {
        process_id: u64,
    },
    ProcessExitEventStreamDisconnected,
    ProcessExitDrainerShutdownTimedOut {
        timeout_millis: u128,
    },
    ProcessExitDrainerPanicked,
    ProcessExitCallbackDispatcherPoisoned,
    ProcessExitCallbackDispatcherUnavailable,
    ProcessExitCallbackDispatcherShutdownTimedOut {
        timeout_millis: u128,
    },
    ProcessExitAlreadyTerminal {
        process_id: u64,
    },
    ActivityDeliveryPoisoned {
        process_id: u64,
    },
    RegistryPoisoned,
    CatalogPoisoned,
    InvalidState {
        reason: String,
    },
    ShuttingDown,
    WorkflowNotFound {
        workflow_type: String,
    },
    ScheduleNotFound {
        schedule_id: ScheduleId,
    },
    Schedule {
        reason: String,
    },
    NifRegistration {
        reason: String,
    },
    SignalRouter(SignalRouterError),
    Query(QueryError),
}

Errors returned by the embedded workflow engine.

Variants

MissingStore

The builder was asked to construct an engine without an event store.

MissingVisibilityStore

The builder was asked to construct an engine without a visibility store.

Load

A workflow package failed to load or validate for engine registration.

Fields

reason: String

Human-readable load failure reason.

UnknownVersion

A route or unload targeted a (workflow type, version) that is not loaded.

Fields

workflow_type: String

Logical workflow type requested by the caller.

version: ContentHash

Content-hash version requested by the caller.

loaded: String

Comma-separated loaded versions of the type, or none.

VersionPinned

An unload was refused because something still pins the version.

Fields

workflow_type: String

Logical workflow type targeted by the unload.

version: ContentHash

Content-hash version targeted by the unload.

pinned_by: PinHolder

What pins the version, naming the concrete holder.

RouteActive

An unload was refused because the version is route-active for its type.

Fields

workflow_type: String

Logical workflow type targeted by the unload.

version: ContentHash

Content-hash version targeted by the unload.

ManifestMismatch

An idempotent re-load presented the resident content hash with a different manifest. The content hash covers the canonical beam set only, so this is the wrong-deploy tripwire: the resident version is retained untouched and the incoming archive is refused.

Fields

workflow_type: String

Logical workflow type targeted by the load.

version: ContentHash

Content-hash version shared by both archives.

resident_digest: String

Canonical digest of the resident manifest.

incoming_digest: String

Canonical digest of the incoming manifest.

ConflictingEventPublisher

The builder was given both event_streaming and an explicit event-publisher seam.

EventStreaming(PublishError)

Live event streaming setup failed.

Store(StoreError)

The configured event store returned an error.

Durability(DurabilityError)

The durability recorder or replay path returned an error.

Package(PackageError)

A .aion package operation returned an error.

Runtime

The embedded runtime returned an error.

Fields

reason: String

Human-readable runtime failure reason.

Gate3BifReplacementMissing

A Gate-3 BIF required for tracked local fun spawns was not registered.

Fields

module: String

Native module containing the required function.

function: String

Required native function.

arity: u8

Required native function arity.

CleanupExecutorPoisoned

The runtime-owned cleanup executor’s ownership state was poisoned.

CleanupExecutorShutdownTimedOut

The runtime cleanup worker did not stop within the configured bound.

Fields

timeout_millis: u128

Configured shutdown observation bound in milliseconds.

ProcessExitRegistryPoisoned

The process-exit registry lifecycle lock was poisoned.

ProcessExitOwnershipPoisoned

A process exit record’s installation/abort ownership gate was poisoned.

Fields

process_id: u64

Process whose monitor/abort ownership could not be serialized.

ProcessExitStatePoisoned

A process exit record’s fan-out state was poisoned.

Fields

process_id: u64

Process whose cached exit state could not be accessed.

ProcessExitSubscriptionUnavailable

The scheduler’s one exit-event subscription was already claimed.

ProcessExitDrainerSpawn

The singleton process-exit drainer could not be spawned.

Fields

reason: String

Operating-system thread creation failure.

ProcessExitDrainerPoisoned

The singleton process-exit drainer’s ownership lock was poisoned.

ProcessExitOutcomeMissingAfterEvent

beamr published an exit event without the promised durable outcome.

Fields

process_id: u64

Process named by the contract-breaking event.

ProcessExitEventStreamDisconnected

beamr disconnected its event publisher while the runtime still owned it.

ProcessExitDrainerShutdownTimedOut

The process-exit drainer did not stop within the configured bound.

Fields

timeout_millis: u128

Configured shutdown observation bound in milliseconds.

ProcessExitDrainerPanicked

The process-exit drainer thread panicked.

ProcessExitCallbackDispatcherPoisoned

The process-exit callback dispatcher’s ownership state was poisoned.

ProcessExitCallbackDispatcherUnavailable

The process-exit callback dispatcher had already stopped.

ProcessExitCallbackDispatcherShutdownTimedOut

The process-exit callback dispatcher did not stop within its configured bound.

Fields

timeout_millis: u128

Configured shutdown observation bound in milliseconds.

ProcessExitAlreadyTerminal

A retired process generation cannot accept another outcome consumer.

Fields

process_id: u64

Process generation whose heavyweight exit record was retired.

ActivityDeliveryPoisoned

A workflow’s activity-delivery synchronization lock was poisoned.

Fields

process_id: u64

Workflow process whose scoped delivery lock was poisoned.

RegistryPoisoned

The active workflow registry lock was poisoned.

CatalogPoisoned

The workflow catalog lock was poisoned.

InvalidState

A precondition on the target workflow’s current state was not met.

Raised by the reopen operation when the target run is not in a reopenable state: not terminal, terminal for a non-reopenable reason (Completed/TimedOut), or already Running. The reason names the actual status so callers and operators can see why the reopen was rejected. Maps to the INVALID_STATE wire code (gRPC FailedPrecondition / HTTP 409).

Fields

reason: String

Human-readable precondition-failure reason naming the actual status.

ShuttingDown

The engine is already shutting down and no new workflow starts are accepted.

WorkflowNotFound

No live, durable, or loaded workflow was found for the request.

Fields

workflow_type: String

Logical workflow type requested by the caller.

ScheduleNotFound

No durable schedule was found for the request.

Fields

schedule_id: ScheduleId

Schedule identifier requested by the caller.

Schedule

Schedule trigger, projection, or evaluator side effect failed.

Fields

reason: String

Human-readable schedule failure reason.

NifRegistration

Native implemented function registration failed.

Fields

reason: String

Human-readable native implemented function registration failure reason.

SignalRouter(SignalRouterError)

Signal routing failed after the target was resolved.

Query(QueryError)

Live workflow query dispatch failed after the target was resolved.

Trait Implementations

impl Debug for EngineError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for EngineError

fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for EngineError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<DurabilityError> for EngineError

fn from(source: DurabilityError) -> Self

Converts to this type from the input type.

impl From<PackageError> for EngineError

fn from(source: PackageError) -> Self

Converts to this type from the input type.

impl From<PublishError> for EngineError

fn from(source: PublishError) -> Self

Converts to this type from the input type.

impl From<QueryError> for EngineError

fn from(source: QueryError) -> Self

Converts to this type from the input type.

impl From<ScheduleError> for EngineError

fn from(error: ScheduleError) -> Self

Converts to this type from the input type.

impl From<ScheduleEvaluatorError> for EngineError

fn from(error: ScheduleEvaluatorError) -> Self

Converts to this type from the input type.

impl From<SignalRouterError> for EngineError

fn from(source: SignalRouterError) -> Self

Converts to this type from the input type.

impl From<StoreError> for EngineError

fn from(source: StoreError) -> Self

Converts to this type from the input type.