Struct InProgressTask

pub struct InProgressTask { /* private fields */ }

Represents an in-progress task that’s been dequeued.

Importantly, Postgres manages a lock over the row this task belongs to. This means that so long as database operations over this are performed in the same transaction they are atomic.

Typically this will not be used directly. Instead workers use this type to manage state transitions as they process the task. In fact, all valid state transitions are encapsulated by it and this is the only interface through which task state should be altered.

Trait Implementations

impl Clone for InProgressTask

fn clone(&self) -> InProgressTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InProgressTask

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

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for InProgressTask

where &'a str: ColumnIndex<R>, TaskId: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, Value: Decode<'a, R::Database> + Type<R::Database>, PgInterval: Decode<'a, R::Database> + Type<R::Database>, RetryPolicy: Decode<'a, R::Database> + Type<R::Database>, Option<String>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>