Struct SqlContext

pub struct SqlContext { /* private fields */ }

The context for a job is represented here Used to provide a context for a job with an sql backend

Implementations

impl SqlContext

pub fn new() -> Self

Build a new context with defaults

pub fn set_max_attempts(&mut self, max_attempts: i32)

Set the number of attempts

pub fn max_attempts(&self) -> i32

Gets the maximum attempts for a job. Default 25

pub fn done_at(&self) -> &Option<i64>

Get the time a job was done

pub fn set_done_at(&mut self, done_at: Option<i64>)

Set the time a job was done

pub fn run_at(&self) -> &DateTime<Utc>

Get the time a job is supposed to start

pub fn set_run_at(&mut self, run_at: DateTime<Utc>)

Set the time a job should run

pub fn lock_at(&self) -> &Option<i64>

Get the time a job was locked

pub fn set_lock_at(&mut self, lock_at: Option<i64>)

Set the lock_at value

pub fn status(&self) -> &State

Get the job status

pub fn set_status(&mut self, status: State)

Set the job status

pub fn lock_by(&self) -> &Option<WorkerId>

Get the time a job was locked

pub fn set_lock_by(&mut self, lock_by: Option<WorkerId>)

Set lock_by

pub fn last_error(&self) -> &Option<String>

Get the time a job was locked

pub fn set_last_error(&mut self, error: Option<String>)

Set the last error

pub fn set_priority(&mut self, priority: i32)

Set the job priority. Larger values will run sooner. Default is 0.

pub fn priority(&self) -> &i32

Get the job priority

Trait Implementations

impl Clone for SqlContext

fn clone(&self) -> SqlContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SqlContext

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

Formats the value using the given formatter.

impl Default for SqlContext

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SqlContext

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Req> FromRequest<Request<Req, SqlContext>> for SqlContext

fn from_request(req: &Request<Req, SqlContext>) -> Result<Self, Error>

Perform the extraction.

impl Serialize for SqlContext

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.