Struct EmailQueueService

pub struct EmailQueueService<B: QueueBackend> { /* private fields */ }

Email queue service - high-level interface for queuing emails

Implementations

impl<B: QueueBackend> EmailQueueService<B>

pub fn new(backend: B) -> Self

Create a new email queue service

pub fn with_processor(self, processor: Arc<EmailJobProcessor>) -> Self

Set the email job processor

pub async fn enqueue(&self, email: Email) -> QueueResult<JobId>

Queue an email for sending

pub async fn enqueue_with_priority( &self, email: Email, priority: EmailPriority, ) -> QueueResult<JobId>

Queue an email with specific priority

pub async fn enqueue_scheduled( &self, email: Email, send_at: DateTime<Utc>, ) -> QueueResult<JobId>

Queue an email for later sending

pub async fn enqueue_batch(&self, emails: Vec<Email>) -> QueueResult<Vec<JobId>>

Queue a batch of emails

pub async fn get_job(&self, job_id: JobId) -> QueueResult<Option<JobEntry>>

Get job by ID

pub async fn get_jobs_by_state( &self, state: JobState, limit: Option<usize>, ) -> QueueResult<Vec<JobEntry>>

Get jobs by state

pub async fn stats(&self) -> QueueResult<EmailQueueStats>

Get queue statistics

pub async fn remove_job(&self, job_id: JobId) -> QueueResult<bool>

Remove a job from the queue

pub async fn clear(&self) -> QueueResult<()>

Clear all jobs

pub async fn process_next_job(&self) -> QueueResult<bool>

Process jobs (typically called by workers)