Struct zeebest::JobWorker

pub struct JobWorker { /* fields omitted */ }

A worker will activate zeebe jobs and us the job handler to process those jobs concurrently.

Methods

impl JobWorker

pub fn new<F>(
    worker: String,
    job_type: String,
    timeout: i64,
    max_amount: u16,
    panic_option: PanicOption,
    client: Client,
    job_handler: F
) -> Self where
    F: Fn(ActivatedJob) -> Pin<Box<dyn Future<Output = JobResult> + Send>> + Send + Sync + 'static, 

pub fn activate_and_process_jobs(
    self
) -> Pin<Box<dyn Future<Output = ()> + Send>>

Activates a batch of jobs and processes each job with the job handler. Will not activate more jobs that max_concurrent_jobs - current_job_count.

Trait Implementations

impl Clone for JobWorker

fn clone(&self) -> JobWorker

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.