Struct Event 

pub struct Event<O: Clone> {
    pub kind: EventKind,
    pub task_id: Uuid,
    pub worker_id: String,
    pub progress: Option<Progress>,
    pub data: Option<O>,
    pub error: Option<String>,
    pub timestamp: DateTime<Utc>,
}

Event emitted by a worker task on the event channel.

Fields

kind: EventKind

The kind of this event.

task_id: Uuid

Identifier of the task that produced this event.

worker_id: String

Identifier of the worker that produced this event.

progress: Option<Progress>

Progress snapshot, present for EventKind::Progress events.

data: Option<O>

Task output payload, present for Partial and Result events.

error: Option<String>

Error or log message, present for Error and Log events.

timestamp: DateTime<Utc>

Wall-clock time at which the event was created.

Implementations

impl<O: Clone> Event<O>

pub fn progress( task_id: Uuid, worker_id: impl Into<String>, p: Progress, ) -> Self

Create a progress event carrying the given Progress snapshot.

pub fn partial(task_id: Uuid, worker_id: impl Into<String>, data: O) -> Self

Create a partial-result event carrying an intermediate output value.

pub fn log( task_id: Uuid, worker_id: impl Into<String>, message: impl Into<String>, ) -> Self

Create a log event carrying a free-form text message.

pub fn result(task_id: Uuid, worker_id: impl Into<String>, data: O) -> Self

Create a final-result event carrying the successful task output.

pub fn error( task_id: Uuid, worker_id: impl Into<String>, err: impl Into<String>, ) -> Self

Create an error event carrying the failure message.

Trait Implementations

impl<O: Clone + Clone> Clone for Event<O>

fn clone(&self) -> Event<O>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<O: Debug + Clone> Debug for Event<O>

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

Formats the value using the given formatter.