Struct CheckpointResult 

pub struct CheckpointResult {
    pub success: bool,
    pub checkpoint_id: u64,
    pub epoch: u64,
    pub duration: Duration,
    pub error: Option<String>,
    pub failure_disposition: Option<CheckpointFailureDisposition>,
}

Result of a checkpoint attempt.

Fields

success: bool

Whether this checkpoint reached its durable commit point and its source cut may be acknowledged.

A successful checkpoint can still carry Self::error when opening the successor sink epoch failed. In that case the committed cut remains valid, but the pipeline must stop before accepting more writes.

checkpoint_id: u64

Checkpoint ID assigned to this attempt.

epoch: u64

Epoch number.

duration: Duration

Wall time for the full checkpoint cycle.

error: Option<String>

Failure reason, or a terminal continuation error after a durable commit.

success == false means the source cut must not be acknowledged. success == true with an error means the source cut must be acknowledged and the pipeline must then fault before any subsequent write.

failure_disposition: Option<CheckpointFailureDisposition>

Runtime action required for a failed attempt. Successful attempts always use None.

Implementations

impl CheckpointResult

pub fn continuation_error(&self) -> Option<&str>

Return the terminal error that prevents this pipeline from continuing after a durable checkpoint commit.

pub fn requires_recovery(&self) -> bool

Whether processing must stop until the in-doubt durable decision is reconciled.

Trait Implementations

impl Clone for CheckpointResult

fn clone(&self) -> CheckpointResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointResult

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CheckpointResult

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CheckpointResult

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

where __S: Serializer,

Serialize this value into the given Serde serializer.