Struct RedisContext 

pub struct RedisContext {
    pub max_attempts: u32,
    pub lock_by: Option<String>,
    pub meta: Map<String, Value>,
}

The context for a redis storage job

Fields

max_attempts: u32

The maximum number of attempts for the task

lock_by: Option<String>

The worker that has locked the task, if any

meta: Map<String, Value>

Additional metadata associated with the task

Trait Implementations

impl<Conn: ConnectionLike + Send + Clone + 'static, Res, Encode> Acknowledge<Res, RedisContext, Ulid> for RedisAck<Conn, Encode>

where Encode: Codec<Res, Compact = Vec<u8>>,

type Future = Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send>>

The future returned by the ack method

type Error = RedisError

The error type returned by the acknowledgment process

fn ack( &mut self, res: &Result<Res, BoxDynError>, parts: &Parts<RedisContext, Ulid>, ) -> Self::Future

Acknowledge the result of a task processing

impl Clone for RedisContext

fn clone(&self) -> RedisContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisContext

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

Formats the value using the given formatter.

impl Default for RedisContext

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RedisContext

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Args: Sync> FromRequest<Task<Args, RedisContext, Ulid>> for RedisContext

type Error = Infallible

The error type that can occur during extraction.

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

Perform the extraction.

impl<T: Serialize + DeserializeOwned> MetadataExt<T> for RedisContext

type Error = Error

The error type that can occur during extraction or injection.

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

Extract metadata of type T.

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

Inject metadata of type T.

impl Serialize for RedisContext

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

where __S: Serializer,

Serialize this value into the given Serde serializer.