Enum DispatchOrigin 

pub enum DispatchOrigin {
    Engine,
    OutboxRow {
        dispatch_key: String,
    },
}

Which caller staged a dispatch — and, because the two owe a waiting delivery different things, which abandonment condition applies to it.

Why this is a named type rather than an optional dispatch key

An Option<String> whose presence selected the intent would be control flow wearing configuration: an engine-scheduled activity that accidentally acquired a key would silently become an outbox claim, and nothing would say so. The same objection retires outbox.transport as a routing key, so reintroducing its shape here would be a poor trade. With two named arms the caller declares which it is, absence never decides, and the match in send_to_candidates is exhaustive — a third origin cannot be added without the compiler asking what it owes.

Variants

Engine

Scheduled by the engine seam directly. There is no row and no claim, so the delivery is wanted while the deployment is not draining and the chosen worker is still registered.

OutboxRow

Claimed from the durable outbox by a pass that holds the row’s claim in the delivery gate. The delivery is wanted only while that claim stands — a term no transport can evaluate for itself, because a key that was never begun reads identically to one that was released.

Fields

dispatch_key: String

The row’s dispatch key, as held in the delivery gate.

Trait Implementations

impl Clone for DispatchOrigin

fn clone(&self) -> DispatchOrigin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatchOrigin

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

Formats the value using the given formatter.

impl Eq for DispatchOrigin

impl PartialEq for DispatchOrigin

fn eq(&self, other: &DispatchOrigin) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DispatchOrigin