Struct MailOutboxDbStore 

pub struct MailOutboxDbStore { /* private fields */ }

SeaORM-backed mail outbox store.

Implementations

impl MailOutboxDbStore

pub const fn new(db: DatabaseConnection) -> Self

Creates a mail outbox store from a SeaORM database connection.

pub async fn create(&self, request: MailOutboxCreate) -> Result<Model>

Enqueues one pending mail outbox row.

pub async fn list_claimable( &self, now: DateTime<Utc>, stale_before: DateTime<Utc>, limit: u64, ) -> Result<Vec<Model>>

Lists rows that are due or stale enough to be reclaimed.

pub async fn try_claim( &self, id: i64, now: DateTime<Utc>, stale_before: DateTime<Utc>, ) -> Result<bool>

Attempts to claim one row for processing.

pub async fn mark_sent(&self, id: i64, sent_at: DateTime<Utc>) -> Result<bool>

Marks a processing row as sent and clears its sensitive payload.

pub async fn mark_retry( &self, id: i64, attempt_count: i32, next_attempt_at: DateTime<Utc>, last_error: &str, ) -> Result<bool>

Marks a processing row for retry.

pub async fn mark_failed( &self, id: i64, attempt_count: i32, failed_at: DateTime<Utc>, last_error: &str, ) -> Result<bool>

Marks a processing row as permanently failed and clears its sensitive payload.

pub async fn count_active(&self) -> Result<u64>

Counts pending or retry rows.

pub async fn dispatch_due<E, Deliver, DeliverFut, OnSent, OnSentFut, OnFailed, OnFailedFut>( &self, config: &MailOutboxDispatchConfig, deliver: Deliver, on_sent: OnSent, on_failed: OnFailed, ) -> Result<DispatchStats, E>

where E: From<DbError> + Display, Deliver: FnMut(Model) -> DeliverFut, DeliverFut: Future<Output = Result<String, E>>, OnSent: FnMut(MailOutboxDispatchContext, i32, String) -> OnSentFut, OnSentFut: Future<Output = ()>, OnFailed: FnMut(MailOutboxDispatchContext, i32, String) -> OnFailedFut, OnFailedFut: Future<Output = ()>,

Runs one shared dispatch pass using the standard database-backed outbox mechanics.

Forge owns list/claim/mark/retry/failure persistence for the shared mail_outbox table. Products only provide rendering/delivery and audit hooks, which keeps every Aster service on the same state machine without copying payload-heavy rows across persistence callbacks.

Trait Implementations

impl Clone for MailOutboxDbStore

fn clone(&self) -> MailOutboxDbStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.