Struct DagCheckpointCoordinator 

pub struct DagCheckpointCoordinator { /* private fields */ }

Ring 1 checkpoint coordinator.

Orchestrates the checkpoint lifecycle:

1. trigger_checkpoint() — creates a barrier
2. Barrier propagates through the DAG (external to this struct)
3. on_node_snapshot_complete() — each node reports its state
4. finalize_checkpoint() — produces a DagCheckpointSnapshot

Implementations

impl DagCheckpointCoordinator

pub fn new( source_nodes: Vec<NodeId>, all_nodes: Vec<NodeId>, config: DagCheckpointConfig, ) -> Self

Creates a new checkpoint coordinator.

Arguments

• source_nodes — DAG source node IDs (barrier injection points)
• all_nodes — all node IDs in the DAG
• config — checkpoint configuration

pub fn trigger_checkpoint(&mut self) -> Result<CheckpointBarrier, DagError>

Triggers a new checkpoint by creating a barrier.

Errors

Returns DagError::CheckpointInProgress if a checkpoint is already in flight.

pub fn on_node_snapshot_complete( &mut self, node_id: NodeId, state: OperatorState, ) -> bool

Records that a node has completed its snapshot.

Returns true if all nodes have now reported (checkpoint is ready to finalize).

pub fn finalize_checkpoint(&mut self) -> Result<DagCheckpointSnapshot, DagError>

Finalizes the current checkpoint, producing a snapshot.

Errors

Returns DagError::NoCheckpointInProgress if no checkpoint is active. Returns DagError::CheckpointIncomplete if not all nodes have reported.

pub fn is_checkpoint_in_progress(&self) -> bool

Returns whether a checkpoint is currently in progress.

pub fn completed_snapshots(&self) -> &[DagCheckpointSnapshot]

Returns completed snapshots.

pub fn latest_snapshot(&self) -> Option<&DagCheckpointSnapshot>

Returns the latest completed snapshot (if any).

pub fn current_epoch(&self) -> u64

Returns the current epoch counter (next epoch to be assigned).

pub fn source_nodes(&self) -> &[NodeId]

Returns the source node IDs.

Trait Implementations

impl Debug for DagCheckpointCoordinator

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

Formats the value using the given formatter.