Struct json_job_dispatch::Director

pub struct Director<'a> { /* fields omitted */ }

Dispatch jobs to registered handlers.

Jobs are sorted into accept, reject, and fail directories based on whether they were accepted by the relevant handler. Once handled, a .stamp file containing the timestamp of when the job was completed is created beside the final location. In addition, rejected and failed jobs have a .reason file describing what happened.

Methods

impl<'a> Director<'a>

pub fn new(root: &Path) -> Result<Self, DirectorError>

Creates a new Director.

The accept and reject directories are created as children of the given directory.

pub fn add_handler<K>(
    &mut self,
    kind: K,
    handler: &'a dyn Handler
) -> Result<(), DirectorError> where
    K: Into<String>, 

Add a handler for jobs labeled as kind.

pub fn run_one<P>(&self, path: P) -> RunResult where
    P: AsRef<Path>, 

Handle a single file.

Returns true if the loop should terminate.

pub fn run<I, P>(&self, paths: I) -> RunResult where
    I: IntoIterator<Item = P>,
    P: AsRef<Path>, 

Handle a batch of files at once.

Returns true if the loop should terminate.

pub fn watch_directory(&self, path: &Path) -> Result<RunResult, DirectorError>

Watch a directory for new job files and act upon them.

Upon startup, this searches the directory for existing files. These files are processed in lexigraphic order.

Trait Implementations

impl<'a> Debug for Director<'a>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.