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.

Structs

CheckpointDecisionStore

Durable checkpoint metadata store.

CheckpointOutcome

Single create-once terminal outcome for one epoch.

CheckpointSinkOpenWitness

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

OutcomeRetentionBoundary

Scalar continuity boundary for outcome retention.

RecoveryCapsuleGcStep

Result of one bounded cluster recovery-capsule maintenance step.

Enums

CheckpointScope

Runtime scope of a durable checkpoint outcome.

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.