Struct SqlContext 

pub struct SqlContext<Pool> { /* private fields */ }

The SQL context used for jobs stored in a SQL database

Implementations

impl<Pool> SqlContext<Pool>

pub fn new() -> Self

Build a new context with defaults

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

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>) -> Self

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>) -> Self

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>) -> Self

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>) -> Self

Set the last result

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

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) -> Self

Set the queue name

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

Get the metadata map

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

Set the metadata map

Trait Implementations

impl<Pool> Clone for SqlContext<Pool>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Pool: Debug> Debug for SqlContext<Pool>

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

Formats the value using the given formatter.

impl<Pool> Default for SqlContext<Pool>

fn default() -> Self

Returns the “default value” for a type.

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

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Args: Sync, IdType: Sync, Pool: Sync> FromRequest<Task<Args, SqlContext<Pool>, IdType>> for SqlContext<Pool>

type Error = Infallible

The error type that can occur during extraction.

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

Perform the extraction.

impl<T: DeserializeOwned + Serialize, Pool> MetadataExt<T> for SqlContext<Pool>

type Error = Error

The error type that can occur during extraction or injection.

fn extract(&self) -> Result<T, Self::Error>

Extract metadata of type T.

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

Inject metadata of type T.

impl<Pool> Serialize for SqlContext<Pool>

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

where __S: Serializer,

Serialize this value into the given Serde serializer.