Struct OutboxClaim 

pub struct OutboxClaim { /* private fields */ }

The outbox pass’s intent: it wants the delivery while the deployment is not draining, it still holds the row’s claim, and the chosen worker is still registered.

The claim is the half no transport can ask about — see the module docs.

Why the registration term is here and not left to the transport

An intent answers the caller’s whole question. If a transport also applied terms of its own, still_wanted() would be a partial answer whose real meaning depended on which transport asked it, and the two halves could drift apart with nothing to catch it. So every term the outbox arm’s original closure asked lives here — including the registration re-check, which that closure did ask (liminal_transport.rs:1209-1220) and which would otherwise be silently lost in the move.

Implementations

impl OutboxClaim

pub fn new( gate: DeliveryGate, dispatch_key: String, registry: ConnectedWorkerRegistry, worker: WorkerId, ) -> Self

Bind this intent to the gate, the dispatch key of the row being delivered, and the worker the pass selected.

Trait Implementations

impl Debug for OutboxClaim

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

Formats the value using the given formatter.

impl DeliveryIntent for OutboxClaim

fn still_wanted(&self) -> bool

true while the caller still wants this delivery to complete.