Module dead_letter_queue 

Dead Letter Queue (DLQ) for failed stream messages.

Provides a bounded, time-aware queue for messages that have exceeded retry limits or failed validation. Supports FIFO pop, topic-based lookup, replay, and reason grouping.

Structs

DeadLetter

A single dead-lettered message.

DeadLetterQueue

A bounded dead letter queue.

DlqConfig

Configuration for the DeadLetterQueue.

Enums

DlqError

Errors returned by DeadLetterQueue operations.

FailureReason

Why a message ended up in the dead letter queue.