job_queue

Setup

cargo add job_queue

Usage

Create a job

use job_queue::{Error, Job};

#[derive(Debug, serde::Deserialize, serde::Serialize)]
pub struct HelloJob {
    pub message: String,
}

#[async_trait::async_trait]
#[typetag::serde]
impl Job for HelloJob {
    async fn handle(&self) -> Result<(), Error> {
        println!("{}", self.message);
        Ok(())
    }
}

Create a queue and dispatch a job

use job_queue::{Error, Job, Queue};

let queue = Client::builder()
    .connect("mysql://root:@localhost/job_queue")
    .await?;

queue
    .dispatch(HelloJob {
        message: "Hello, world!".to_string(),
    })
    .await?;

Create a worker

let worker = Worker::builder()
        .connect("mysql://root:@localhost/job_queue")
        .await?;

loop {
    worker.run().await.unwrap();
    tokio::time::sleep(Duration::from_millis(100)).await;
}