job_queue 0.0.13

A simple, efficient Rust library for handling asynchronous job processing and task queuing.
Documentation 
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use job_queue::{Client, DispatchOptions, Error, Job};
use std::time::Duration;

#[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(())
    }
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    let queue = Client::builder()
        .connect("postgres://kabbouchi:@localhost/job_queue")
        .await?;

    loop {
        println!("Dispatching job...");
        queue
            .custom_dispatch(
                &HelloJob {
                    message: "Hello, world!".to_string(),
                },
                &DispatchOptions {
                    queue: Some("default".to_string()),
                    delay: Some(Duration::from_secs(5)),
                },
            )
            .await?;

        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
    }

    // Ok(())
}