Struct izta::runner::Runner

pub struct Runner<F> where
    F: Fn(&Task) -> RunTaskResult,
    F: Send + 'static + Sync + Clone + Copy,  { /* fields omitted */ }

Runner spawns the task executor and allows new tasks to be scheduled.

Methods

impl<F> Runner<F> where
    F: Fn(&Task) -> RunTaskResult,
    F: Send + 'static + Sync + Clone + Copy, 

pub fn new(
    f: F,
    db_url: &str,
    table_name: &str,
    queues: Vec<String>
) -> Runner<F> where
    F: Fn(&Task) -> RunTaskResult,
    F: Send + 'static + Sync + Clone + Copy, 

Returns a new Runner. Must call start() to begin executing tasks.

Arguments

• f - Callback generated by process_jobs!. See Examples below.
• db_url - Address of Postgres database containing tasks table. Syntax: postgres://username:password@hostname:port/db_name
• table_name - The name of the Postgres table containing tasks.
• queues - If empty, process any task. If not empty, only process tasks belonging to specified queues.

Example

// Provided that JobA and JobB are two types implementing the Job trait
let runner = Runner::new(
    process_jobs!(JobA, JobB),
    "postgres://izta:password@localhost:5432/izta_test",
    "tasks",
    vec![],
);

pub fn start(&self)

Begin executing tasks.

pub fn add_task(&self, req: &TaskReq) -> Task

Creates and schedules a new Task for execution from a TaskReq. Returns new task

pub fn finished(&self) -> Vec<Task>

Return all finished tasks managed by this Runner

pub fn failed(&self) -> Vec<Task>

Return all failed tasks managed by this Runner