Struct SqlContext 

pub struct SqlContext { /* private fields */ }

The SQL context used for jobs stored in a SQL database

Implementations

impl SqlContext

pub fn new() -> SqlContext

Build a new context with defaults

pub fn with_max_attempts(self, max_attempts: i32) -> SqlContext

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 with_done_at(self, done_at: Option<i64>) -> SqlContext

Set the time a job was done

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

Get the time a job was locked

pub fn with_lock_at(self, lock_at: Option<i64>) -> SqlContext

Set the lock_at value

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

Get the time a job was locked

pub fn with_lock_by(self, lock_by: Option<String>) -> SqlContext

Set lock_by

pub fn last_result(&self) -> &Option<Value>

Get the time a job was locked

pub fn with_last_result(self, result: Option<Value>) -> SqlContext

Set the last result

pub fn with_priority(self, priority: i32) -> SqlContext

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

pub fn priority(&self) -> i32

Get the job priority

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

Get the queue name

pub fn with_queue(self, queue: String) -> SqlContext

Set the queue name

pub fn meta(&self) -> &Map<String, Value>

Get the metadata map

pub fn with_meta(self, meta: Map<String, Value>) -> SqlContext

Set the metadata map

Trait Implementations

impl Clone for SqlContext

fn clone(&self) -> SqlContext

Returns a duplicate 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<(), Error>

Formats the value using the given formatter.

impl Default for SqlContext

fn default() -> SqlContext

Returns the “default value” for a type.

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

fn deserialize<__D>( __deserializer: __D, ) -> Result<SqlContext, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Args, IdType> FromRequest<Task<Args, SqlContext, IdType>> for SqlContext

where Args: Sync, IdType: Sync,

type Error = Infallible

The error type that can occur during extraction.

async fn from_request( req: &Task<Args, SqlContext, IdType>, ) -> Result<SqlContext, <SqlContext as FromRequest<Task<Args, SqlContext, IdType>>>::Error>

Perform the extraction.

impl<T> MetadataExt<T> for SqlContext

where T: DeserializeOwned + Serialize,

type Error = Error

The error type that can occur during extraction or injection.

fn extract(&self) -> Result<T, <SqlContext as MetadataExt<T>>::Error>

Extract metadata of type T.

fn inject( &mut self, value: T, ) -> Result<(), <SqlContext as MetadataExt<T>>::Error>

Inject metadata of type T.

impl Serialize for SqlContext

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

where __S: Serializer,

Serialize this value into the given Serde serializer.