Struct MailQueue 

pub struct MailQueue { /* private fields */ }

Mail queue with retry logic and priority support

Implementations

impl MailQueue

pub fn new() -> Self

Create a new mail queue without persistent storage

pub fn new_with_store(store: Arc<dyn QueueStore>) -> Self

Create a new mail queue with persistent storage

pub fn new_with_priority_config(priority_config: PriorityConfig) -> Self

Create a new mail queue with priority configuration

pub fn new_with_store_and_priority( store: Arc<dyn QueueStore>, priority_config: PriorityConfig, ) -> Self

Create a new mail queue with storage and priority configuration

pub fn update_priority_config(&self, config: PriorityConfig)

Update priority configuration

pub fn get_priority_config(&self) -> PriorityConfig

Get current priority configuration

pub async fn load_from_storage(&self) -> Result<()>

Load all pending entries from storage on startup

pub async fn enqueue(&self, mail: Mail) -> Result<()>

Enqueue a mail for delivery (atomic operation with persistence)

pub async fn enqueue_with_priority( &self, mail: Mail, priority: Priority, ) -> Result<()>

Enqueue a mail with explicit priority

pub fn get_ready_for_retry(&self, limit: usize) -> Vec<QueueEntry>

Get next batch of mails ready for retry, ordered by priority

pub fn get_ready_for_retry_by_priority( &self, priority: Priority, limit: usize, ) -> Vec<QueueEntry>

Get mails ready for retry for a specific priority

pub async fn mark_failed(&self, mail_id: &MailId, error: String) -> Result<()>

Mark delivery attempt as failed (atomic operation with persistence)

pub async fn mark_delivered(&self, mail_id: &MailId) -> Result<()>

Mark delivery as successful and remove from queue (atomic operation)

pub fn get_bounced(&self) -> Vec<QueueEntry>

Get all bounced messages (exceeded retry limit) - legacy in-memory only

pub async fn list_dlq(&self) -> Result<Vec<QueueEntry>>

List all entries in dead letter queue

pub async fn remove_from_dlq(&self, mail_id: &MailId) -> Result<()>

Remove a mail from dead letter queue

pub async fn retry_from_dlq(&self, mail_id: &MailId) -> Result<()>

Retry a message from dead letter queue

pub async fn remove(&self, mail_id: &MailId) -> Result<Option<QueueEntry>>

Remove a mail from queue (atomic operation)

pub fn stats(&self) -> QueueStats

Get queue statistics

pub fn stats_for_priority(&self, priority: Priority) -> QueueStats

Get statistics for a specific priority level

pub fn stats_by_priority(&self) -> HashMap<Priority, QueueStats>

Get statistics grouped by priority

pub fn list_all(&self) -> Vec<QueueEntry>

Get all queue entries (for inspection)

pub fn list_by_priority(&self, priority: Priority) -> Vec<QueueEntry>

Get queue entries for a specific priority

Trait Implementations

impl Default for MailQueue

fn default() -> Self

Returns the “default value” for a type.