Enum InboxOutcome 

pub enum InboxOutcome {
    Processed,
    Duplicate,
}

Outcome of committing an InboxReceipt.

A Duplicate is not an error: the message was already processed, so the consumer treats it as success (acks) without re-running effects.

Variants

Processed

The receipt was newly recorded (first time this message was processed).

Duplicate

A receipt for (consumer, message_id) already existed; effects were skipped.

Implementations

impl InboxOutcome

pub fn is_processed(self) -> bool

Whether this is the first processing (vs a deduplicated replay).

pub fn is_duplicate(self) -> bool

Whether the message was already processed (a deduplicated replay).

Trait Implementations

impl Clone for InboxOutcome

fn clone(&self) -> InboxOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for InboxOutcome

impl Debug for InboxOutcome

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

Formats the value using the given formatter.

impl Eq for InboxOutcome

impl PartialEq for InboxOutcome

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for InboxOutcome