Trait kannon::task::worker::Worker

pub trait Worker {
    fn ready(&self, topology: &Topology) -> Result<(), TaskError>;
    fn execute(&self) -> Result<(), TaskError>;
    fn wait_finish(&self);
}

Default worker trait for executing tasks in the various ways.

Required methods

fn ready(&self, topology: &Topology) -> Result<(), TaskError>

Ready worker with given topology topology::Topology.

If ready is failed, return error code.

fn execute(&self) -> Result<(), TaskError>

Execute worker and process tasks.

If ready is failed, return error code.

fn wait_finish(&self)

Loading content...

Implementors

impl Worker for SequentialWorker

fn ready(&self, topology: &Topology) -> Result<(), TaskError>

fn execute(&self) -> Result<(), TaskError>

fn wait_finish(&self)

impl Worker for ThreadingWorker

fn ready(&self, topology: &Topology) -> Result<(), TaskError>

fn execute(&self) -> Result<(), TaskError>

fn wait_finish(&self)

Loading content...