Struct apalis_core::PushJob

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

Fields

id: Uuid

job: Vec<u8>

retries: i64

Implementations

impl PushJob

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

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

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

Formats the value using the given formatter.

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

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

Deserialize this value from the given Serde deserializer.

impl Drop for PushJob

fn drop(&mut self)

Executes the destructor for this type.

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

fn from(job: J) -> Self

Performs the conversion.

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

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

Serialize this value into the given Serde serializer.