Struct sqlxmq::Checkpoint

pub struct Checkpoint<'a> { /* fields omitted */ }

Type used to checkpoint a running job.

Implementations

impl<'a> Checkpoint<'a>

pub fn new_keep_alive(duration: Duration) -> Self

Construct a new checkpoint which also keeps the job alive for the specified interval.

pub fn new() -> Self

Construct a new checkpoint.

pub fn set_extra_retries(&mut self, extra_retries: usize) -> &mut Self

Add extra retries to the current job.

pub fn set_raw_json(&mut self, raw_json: &'a str) -> &mut Self

Specify a new raw JSON payload.

pub fn set_raw_bytes(&mut self, raw_bytes: &'a [u8]) -> &mut Self

Specify a new raw binary payload.

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

Specify a new JSON payload.

Trait Implementations

impl<'a> Clone for Checkpoint<'a>

fn clone(&self) -> Checkpoint<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Checkpoint<'a>

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

Formats the value using the given formatter.

impl<'a> Default for Checkpoint<'a>

fn default() -> Checkpoint<'a>

Returns the “default value” for a type.