jono_consume 0.1.5

Worker interface to process Jono jobs
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

use jono_core::{JobMetadata, Result};
use serde_json::Value;

pub trait Worker: Send + Sync {
    fn process(&self, job: &Workload) -> Result<Outcome>;
}

pub struct Workload {
    pub job_id: String,
    pub payload: Value,
}

impl Workload {
    pub fn from_metadata(metadata: JobMetadata) -> Self {
        Self {
            job_id: metadata.id,
            payload: metadata.payload,
        }
    }
}

#[derive(Debug, Clone)]
pub enum Outcome {
    Success(Option<Value>),
    Failure(String),
}