Trait rtj::Job

pub trait Job {
    fn encode(&self) -> Vec<u8>;
    fn decode(input: &[u8]) -> Self;
    fn ack(&self) -> Vec<u8>;
    fn run(&self) -> Result<(), Box<dyn Error>>;
}

The core trait Job providing required methods to user-defined data types for orchestrating task execution.

It is left to the implementor to ensure these methods do not panic or that errors are handled as they see fit.

Required methods

fn encode(&self) -> Vec<u8>

fn decode(input: &[u8]) -> Self

fn ack(&self) -> Vec<u8>

fn run(&self) -> Result<(), Box<dyn Error>>

Implementors