Struct Worker 

pub struct Worker<Data, Comp, Ctx> {
    pub stats: WorkerStats,
    pub options: WorkerOptions,
    /* private fields */
}

Fields

stats: WorkerStats

options: WorkerOptions

Implementations

impl<Data, Comp, Ctx> Worker<Data, Comp, Ctx>

where Data: Debug + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, Comp: Computation<Data, Ctx> + Send + Sync + 'static, Ctx: Configurable + Send + Sync + 'static,

A worker implementation that fetches a task from the storage, processes it, and then updates the task status. If the processing fails, the task is retried up to N times.

pub fn new( worker_id: WorkerId, ctx: Arc<Ctx>, queue: Arc<dyn TaskQueue<Data> + Send + Sync>, computation: Arc<Comp>, options: WorkerOptions, ) -> Self

pub fn get_stats(&self) -> &WorkerStats

pub async fn run(&mut self) -> Result<bool>

Worker run lify-cycle

1. pop task from queue (or wait a bit)
2. run computation over task
3. update task according to computation result

Return true if should continue or false otherwise

Trait Implementations

impl<Data, Comp, Ctx> Debug for Worker<Data, Comp, Ctx>

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

Formats the value using the given formatter.