later 0.0.10

Distributed Background jobs manager and runner for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use async_trait::async_trait;
use serde::{de::DeserializeOwned, Serialize};

use crate::BackgroundJobServerPublisher;

/// A message that can be used to enqueue a background job
pub trait JobParameter
where
    Self: Sized + Serialize + DeserializeOwned,
{
    fn to_bytes(&self) -> anyhow::Result<Vec<u8>>;
    fn from_bytes(payload: &[u8]) -> Self;
    fn get_ptype(&self) -> String;
}

#[async_trait]
// Marker trait used to decorate handles
pub trait BgJobHandler<C> {
    fn get_ctx(&self) -> &C;
    fn get_publisher(&self) -> &BackgroundJobServerPublisher;
    async fn dispatch(&self, ptype: String, payload: &[u8]) -> anyhow::Result<()>;
}