Struct Checkpoint 

pub struct Checkpoint {
    pub last_completed_step: String,
    pub cursor_step: String,
    pub cursor: Vec<u8>,
    pub updated_at_ms: i64,
    pub schema_version: u32,
    pub step_set_hash: String,
    pub crashes_by_step: HashMap<String, u32>,
}

step replay Step replay. River persists this only after the worker returns, which loses it in exactly the mid-step crash the feature exists for; Sidekiq autosaves every 5s. Here the checkpoint rides the lease renewal that is already happening, so step boundaries are exact and cursor updates are bounded by the renewal interval.

Fields

last_completed_step: String

cursor_step: String

the step a cursor belongs to, if any

cursor: Vec<u8>

opaque, caller-serialized

updated_at_ms: i64

schema_version: u32

payload versioning × step replay: what the step set looked like when this was written. A resumed job whose step set no longer matches goes to UNDECODABLE rather than silently restarting from step one and re-running completed side effects. No other queue has to answer this, because no other queue has both step replay and payload versioning.

step_set_hash: String

crashes_by_step: HashMap<String, u32>

crash quarantine step-level crash attribution

Trait Implementations

impl Clone for Checkpoint

fn clone(&self) -> Checkpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Checkpoint

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

Formats the value using the given formatter.

impl Default for Checkpoint

fn default() -> Self

Returns the “default value” for a type.

impl Message for Checkpoint

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for Checkpoint

fn eq(&self, other: &Checkpoint) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Checkpoint