Trait kannon::task::worker::Worker [−][src]
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>
[src]
Ready worker with given topology topology::Topology
.
If ready is failed, return error code.
fn execute(&self) -> Result<(), TaskError>
[src]
Execute worker and process tasks.
If ready is failed, return error code.
fn wait_finish(&self)
[src]
Implementors
impl Worker for SequentialWorker
[src]
impl Worker for SequentialWorker
[src]