Struct RunningJob

pub struct RunningJob(pub Arc<RunningJobData>);

Information about a running job.

Tuple Fields

0: Arc<RunningJobData>

Methods from Deref<Target = RunningJobData>

pub async fn checkpoint_blob( &self, new_payload: Vec<u8>, ) -> Result<OffsetDateTime>

Checkpoint the task, replacing the payload with the passed in value.

pub async fn checkpoint_json<T: Serialize>( &self, new_payload: T, ) -> Result<OffsetDateTime>

Checkpoint the task, replacing the payload with the passed in value.

pub async fn heartbeat(&self) -> Result<OffsetDateTime>

Tell the queue that the task is still running.

pub fn is_expired(&self) -> bool

Return if the task is past the expiration time or not.

pub fn json_payload<'a, T: Deserialize<'a>>(&'a self) -> Result<T>

Deserialize a JSON payload into the requested type.

pub async fn complete<T: Serialize + Send + Debug>( &self, info: T, ) -> Result<(), Error>

Mark the job as successful.

pub async fn fail<T: Serialize + Send + Debug>( &self, info: T, ) -> Result<(), Error>

Mark the job as failed.

Trait Implementations

impl Clone for RunningJob

fn clone(&self) -> RunningJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunningJob

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

Formats the value using the given formatter.

impl Deref for RunningJob

type Target = RunningJobData

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Display for RunningJob

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

Formats the value using the given formatter.