Trait Job

Source

pub trait Job:
    Send
    + Sync
    + 'static {
    // Required methods
    fn name(&self) -> &str;
    fn execute(
        &self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>;

    // Provided methods
    fn max_retries(&self) -> u32 { ... }
    fn retry_delay(&self) -> Duration { ... }
}

Expand description

Trait for background jobs.

struct SendEmailJob { pub to: String, pub subject: String }

impl Job for SendEmailJob {
    fn name(&self) -> &str { "send_email" }

    fn execute(&self) -> Pin<Box<dyn Future<Output = Result<(), anyhow::Error>> + Send + '_>> {
        Box::pin(async {
            // send email logic
            Ok(())
        })
    }
}