Struct apalis::PushJob

pub struct PushJob {
    pub id: Uuid,
    pub job: Vec<u8, Global>,
    pub retries: i64,
    // some fields omitted
}

Fields

id: Uuid

job: Vec<u8, Global>

retries: i64

Implementations

impl PushJob

pub fn new<J>(id: Uuid, job: J) -> PushJob where
    J: Job, 

pub async fn handle<C, J>(&'_ mut self, ctx: &'_ mut JobContext<C>) where
    C: Consumer + Actor,
    J: JobHandler<C>, 

pub fn state(&self) -> &JobState

pub fn ack(&mut self)

pub fn reject(&mut self)

Trait Implementations

impl Debug for PushJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PushJob

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

Deserialize this value from the given Serde deserializer.

impl Drop for PushJob

pub fn drop(&mut self)

Executes the destructor for this type.

impl<J> From<J> for PushJob where
    J: Job, 

pub fn from(job: J) -> PushJob

Performs the conversion.

impl<J> Handler<PushJob> for RedisProducer<J> where
    J: 'static + Job, 

Implementation of Actix Handler to push job.

type Result = Pin<Box<dyn Future<Output = Result<JobState, Error>> + 'static, Global>>

The type of value that this handler will return.

pub fn handle(
    &mut self,
    msg: PushJob,
    &mut <RedisProducer<J> as Actor>::Context
) -> <RedisProducer<J> as Handler<PushJob>>::Result

This method is called for every message received by this actor.

impl Message for PushJob

type Result = Result<JobState, Error>

The type of value that this message will resolved with if it is successful.

impl Serialize for PushJob

pub 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.