Enum DispatchResult 

pub enum DispatchResult {
    Started {
        run_id: String,
        sop_name: String,
        action: Box<SopRunAction>,
    },
    Skipped {
        sop_name: String,
        reason: String,
    },
    Deferred {
        sop_name: String,
        reason: String,
    },
    Coalesced {
        sop_name: String,
        existing_run_id: String,
    },
    BlockedUnsafe {
        sop_name: Option<String>,
        reason: String,
    },
    NoMatch,
}

Outcome of attempting to dispatch an event to the SOP engine.

Variants

Started

Fields

run_id: String

sop_name: String

action: Box<SopRunAction>

Skipped

A matching SOP was found but could not start (cooldown, or the drop admission policy with no free slot). Logged, not retried.

Fields

sop_name: String

reason: String

Deferred

A2: a matching SOP could not admit now (execution slots or the pending-approval pool are full) and its admission policy DEFERS rather than drops. The outcome is always logged, never silent. Redelivery is transport- dependent: a caller with a manual-ack/requeue primitive (AMQP with durable_ack) MUST redeliver so the trigger is not lost. Transports that auto-ack on receive (MQTT via rumqttc, cron ticks) are AT-MOST-ONCE for a Deferred occurrence - they cannot hold the ack, so Deferred there is an observability signal, not a redelivery guarantee.

Fields

sop_name: String

reason: String

Coalesced

A2: a concurrent trigger collapsed into an already-in-flight run under the coalesce policy (the latest state is covered by the existing run). Not an error; recorded, not retried.

Fields

sop_name: String

existing_run_id: String

BlockedUnsafe

Untrusted trigger content was blocked before a run could start.

Fields

sop_name: Option<String>

reason: String

NoMatch

No loaded SOP matched the event.

Trait Implementations

impl Clone for DispatchResult

fn clone(&self) -> DispatchResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DispatchResult

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

Formats the value using the given formatter.