Enum FetchedEntry 

pub enum FetchedEntry {
    Decoded(ClaimedMessage),
    Malformed {
        id: String,
        error: EventBusError,
    },
}

One result per Redis Stream entry returned from read_new / reclaim_idle.

Backends report decode failures per entry instead of poisoning the whole batch with a single Result<Vec<_>, _> short-circuit. Otherwise a single corrupt PEL entry would loop forever:

• XREADGROUP already moved the entry into the consumer’s PEL.
• The bus would receive Err, log/observe, back off, retry.
• On the next cycle the same entry would re-decode → fail again.

With per-entry results the bus can ack the bad entry (so it leaves the PEL), publish a synthetic dead-letter envelope (when dead_letter_topic is configured), and surface the error to the crate::ErrorObserver.

Variants

Decoded(ClaimedMessage)

Malformed

Fields

id: String

error: EventBusError

Trait Implementations

impl Debug for FetchedEntry

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

Formats the value using the given formatter.