jqueuers 0.1.2

jobs queues manager
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

use jqueuers::{ Option, App, AsyncTask, QueueParams, QueueOption };
use anyhow::Error;

#[tokio::main]
async fn main() -> Result<(), Error> {
    let mut app = App::init(Option {
        url: "redis://127.0.0.1/",
    }).await.unwrap();

    async fn process() -> Result<(), Error> {
        Ok(())
    }
    let process_closure = Box::new(|| -> AsyncTask { Box::pin(process()) });

    let params = QueueParams {
        name: "Fila",
        option: QueueOption {},
    };

    app.define(params, process_closure).await;

    let _ = app.run().await.unwrap();

    Ok(())
}