Module checkpoint_decision 

Per-epoch checkpoint commit marker store. Used by the checkpoint coordinator’s 2PC to record the commit decision durably before sinks are told to commit, so recovery can re-establish the verdict after a crash. Lives outside the cluster gate because single-instance also needs it. Durable checkpoint identity, ID allocation, and immutable terminal outcomes.

Re-exports

pub use crate::checkpoint::CheckpointScope;

Structs

CheckpointArtifactInventory

Durable inventory for one checkpoint attempt that may have written artifacts.

CheckpointDecisionHead

Exact local recovery cursor and unresolved artifact inventory.

CheckpointDecisionStore

Durable checkpoint metadata store.

CheckpointOutcome

Single create-once terminal outcome for one epoch.

CheckpointRetentionCursor

Exact position of a crash-resumable local checkpoint cleanup.

CheckpointSinkOpenWitness

Durable proof that every named checkpoint-committable sink may have opened this attempt.

Enums

CheckpointArtifactInventoryUpdateResult

Result of a conditional checkpoint artifact-inventory transition.

CheckpointRetentionState

Durable phase of local checkpoint retention.

CheckpointRetentionUpdateResult

Result of a conditional retention-head transition.

CheckpointVerdict

Irrevocable terminal verdict for one concrete checkpoint attempt.

DecisionError

Errors raised by CheckpointDecisionStore operations.

RecordOutcomeResult

Result of attempting to create a terminal checkpoint outcome.