Enum WorkerEvent 

pub enum WorkerEvent<'a> {
    Started {
        worker_id: &'a str,
    },
    Polling,
    JobClaimed {
        job: &'a HarvestJob,
    },
    JobStarted {
        job_id: Uuid,
        portal_url: &'a str,
    },
    JobCompleted {
        job_id: Uuid,
        stats: &'a SyncStats,
    },
    JobFailed {
        job_id: Uuid,
        error: &'a str,
        will_retry: bool,
    },
    JobCancelled {
        job_id: Uuid,
        stats: &'a SyncStats,
    },
    ShuttingDown {
        worker_id: &'a str,
        jobs_released: u64,
    },
    Stopped {
        worker_id: &'a str,
    },
}

Events emitted by the worker during operation.

Variants

Started

Worker started and is ready to process jobs.

Fields

worker_id: &'a str

Polling

Worker is polling for new jobs.

JobClaimed

Worker claimed a job.

Fields

job: &'a HarvestJob

JobStarted

Job processing started.

Fields

job_id: Uuid

portal_url: &'a str

JobCompleted

Job completed successfully.

Fields

job_id: Uuid

stats: &'a SyncStats

JobFailed

Job failed with error.

Fields

job_id: Uuid

error: &'a str

will_retry: bool

JobCancelled

Job was cancelled.

Fields

job_id: Uuid

stats: &'a SyncStats

ShuttingDown

Worker is shutting down.

Fields

worker_id: &'a str

jobs_released: u64

Stopped

Worker stopped.

Fields

worker_id: &'a str

Trait Implementations

impl<'a> Clone for WorkerEvent<'a>

fn clone(&self) -> WorkerEvent<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for WorkerEvent<'a>

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

Formats the value using the given formatter.