1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::fmt::Debug;

use async_trait::async_trait;
use serde::{Deserialize, Serialize};

/// Defines a background job that can be queued and executed.
#[async_trait]
pub trait Job: Debug + Send + Sync + 'static {
    /// The output type of the job.
    type Output: Clone + Serialize + for<'de> Deserialize<'de> + Send + Sync + 'static;

    /// Executes the job and returns the result.
    async fn execute(&mut self) -> anyhow::Result<Self::Output>;
}

/// Defines a background job that has a unique `key`.
pub trait Keyed<Key>: Job
where
    Key: Clone + std::hash::Hash + Eq + Send + Sync + Debug + 'static,
{
    /// The unique `key` for this `Job`
    fn key(&self) -> Key;
}

#[async_trait]
pub trait Executable: Send + Sync + Debug {
    async fn execute(&mut self);
}