Struct brokkr::Job

pub struct Job<T, R> {
    pub id: Uuid,
    pub task: T,
    pub result: Option<R>,
    pub failure_info: Option<String>,
    pub created_at: NaiveDateTime,
    pub started_at: Option<NaiveDateTime>,
    pub processed_at: Option<NaiveDateTime>,
    pub state: JobState,
}

A job and its metadata / state information.

Fields

id: Uuid

The unique id of this job.

task: T

The actual application level task to be processed.

result: Option<R>

Result of processing the task.

failure_info: Option<String>

Failure information, that's the panic payload in case of panic or the. reported error in case of handled error.

created_at: NaiveDateTime

Time when the job was created / queued.

started_at: Option<NaiveDateTime>

Time when processing started for this job.

processed_at: Option<NaiveDateTime>

Time when processing finished for this job.

state: JobState

State of this job.

Methods

impl<T: Encodable, R: Encodable> Job<T, R>

pub fn new(task: T) -> Self

Create a job given a task object.

Trait Implementations

impl<T: Debug, R: Debug> Debug for Job<T, R>

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

Formats the value using the given formatter.

impl<T: Clone, R: Clone> Clone for Job<T, R>

fn clone(&self) -> Job<T, R>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug, R: Debug> Display for Job<T, R>

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

Formats the value using the given formatter.