Module queue 

Queue row type, status enum, and retry-attempt bookkeeping.

Structs

QueuedMessage

One queued outbound message — the full row stored in the outbound queue.

Enums

QueueStatus

Lifecycle status of a queued message.

Functions

add_suppression

add a recipient to the suppression list after a hard bounce

cancel_pending

cancel a pending outbound message (undo send)

cancel_pending_by_message_id

cancel a pending outbound message by message_id (undo send)

claim_for_delivery

Atomically claim up to limit pending messages and transition them to inflight, returning the claimed rows.

count_inflight

Count of rows in status = 'inflight' (currently being delivered by a worker). Used alongside count_pending so dashboards can show both “queued” and “in-flight” depth.

count_pending

Count of rows in status = 'pending' (any next_retry). Used by the delivery worker to publish a mailrs_outbound_queue_depth gauge per poll tick. O(rows) but cheap with the status index.

dequeue

fetch pending messages ready for delivery (legacy, non-atomic).

enqueue

enqueue a message for outbound delivery

enqueue_ex

enqueue a message for outbound delivery with forwarding flag

enqueue_scheduled

enqueue a message for scheduled delivery at a future time

get_message

get a specific queued message by id

is_hard_bounce

detect if an SMTP error is a permanent/hard bounce (5xx)

is_suppressed

check if a recipient address is in the suppression list (hard bounce)

list_recent

list recent queue entries for admin UI

list_suppressions

list all suppressed addresses

mark_bounced

mark a message as permanently bounced

mark_delivered

mark a message as delivered

mark_failed

mark a message as failed with next retry time

mark_inflight

mark a message as in-flight

notify

notify the delivery worker that new messages are queued via the in-process kevy queue:notify channel.

queue_stats

get queue statistics

recover_stale_inflight

recover messages stuck in inflight status for more than 10 minutes (worker crashed or was killed before marking them as delivered/failed)

remove_suppression

remove an address from the suppression list (admin override)

retry_message

reset a bounced/failed message back to pending for retry