Struct EmailJob

pub struct EmailJob {
    pub email: Email,
    pub priority: EmailPriority,
    pub max_retries: u32,
    pub timeout_seconds: u64,
    pub provider: Option<String>,
    pub metadata: HashMap<String, String>,
}

Email job for background processing

Fields

email: Email

The email to be sent

priority: EmailPriority

Job priority

max_retries: u32

Maximum retry attempts

timeout_seconds: u64

Job timeout

provider: Option<String>

Provider to use for sending (optional, uses default if None)

metadata: HashMap<String, String>

Additional metadata

Implementations

impl EmailJob

pub fn new(email: Email) -> Self

Create a new email job

pub fn with_priority(self, priority: EmailPriority) -> Self

Set job priority

pub fn with_max_retries(self, max_retries: u32) -> Self

Set maximum retry attempts

pub fn with_timeout(self, timeout: Duration) -> Self

Set job timeout

pub fn with_provider(self, provider: String) -> Self

Set specific provider to use

pub fn with_metadata(self, key: String, value: String) -> Self

Add metadata

Trait Implementations

impl Clone for EmailJob

fn clone(&self) -> EmailJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EmailJob

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EmailJob

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Job for EmailJob

fn execute<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = JobResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the job

fn job_type(&self) -> &'static str

Get the job type identifier

fn max_retries(&self) -> u32

Get maximum number of retry attempts (default: 3)

fn retry_delay(&self, attempt: u32) -> Duration

Get retry delay (default: exponential backoff starting at 1 second)

fn timeout(&self) -> Duration

Get job timeout (default: 5 minutes)

impl Serialize for EmailJob

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.