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 commit marker for checkpoint 2PC.

Recovery needs to distinguish “we decided to commit this epoch and crashed mid-commit” from “we never reached the commit point”. The coordinator writes this marker before sinks are told to commit; presence on restart = re-drive commit, absence = roll back. In cluster mode the marker also carries the leader’s decision across leader re-election.

Structs

CheckpointDecisionStore

Per-epoch commit marker store. Presence means committed; absence means the leader never reached the commit point (safe to abort).

Enums

DecisionError

Errors raised by CheckpointDecisionStore operations.