backyard-core 0.1.0

Core traits and types for the Backyard async job queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::{error::Result, job::JobContext};
use std::collections::HashMap;
use std::future::Future;
use std::pin::Pin;

pub struct JobRegistration {
    pub name: &'static str,
    pub handler:
        fn(raw: &[u8], ctx: JobContext) -> Pin<Box<dyn Future<Output = Result<()>> + Send>>,
}

inventory::collect!(JobRegistration);

pub fn build_dispatch_table(
) -> HashMap<&'static str, fn(&[u8], JobContext) -> Pin<Box<dyn Future<Output = Result<()>> + Send>>>
{
    inventory::iter::<JobRegistration>()
        .map(|r| (r.name, r.handler))
        .collect()
}