faktory 0.13.1

API bindings for the language-agnostic Faktory work server
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

use faktory::Worker;
use std::io::Error as IOError;

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt::fmt()
        .with_max_level(tracing::Level::TRACE)
        .init();

    // this will terminate under one of the following conditions:
    // - signal from the Faktory server;
    // - ctrl+c signal;
    // - worker panic;
    Worker::builder()
        .register_fn("job_type", |j| async move {
            println!("{:?}", j);
            Ok::<(), IOError>(())
        })
        .connect()
        .await
        .expect("Connected to server")
        .run_to_completion(&["default"])
        .await
}