Struct CheckpointCoordinator 

pub struct CheckpointCoordinator { /* private fields */ }

Coordinates checkpoints across multiple contexts.

Sends CheckpointBarrier to all contexts, collects CheckpointAck responses, and persists the assembled Checkpoint once all contexts have acknowledged.

Implementations

impl CheckpointCoordinator

pub fn new(manager: CheckpointManager, context_names: Vec<String>) -> Self

Create a new coordinator for the given contexts.

pub fn ack_sender(&self) -> Sender<CheckpointAck>

Get a sender for checkpoint acknowledgments (cloned into each context).

pub fn initiate( &mut self, context_txs: &FxHashMap<String, Sender<ContextMessage>>, )

Initiate a new checkpoint by sending barriers to all contexts.

pub fn receive_ack(&mut self, ack: CheckpointAck) -> Option<Checkpoint>

Receive an acknowledgment. Returns a complete Checkpoint when all contexts have acked.

pub fn try_complete(&mut self) -> Result<(), StoreError>

Try to drain pending acks and complete the checkpoint.

pub fn should_checkpoint(&self) -> bool

Check if a checkpoint should be initiated based on interval.

pub const fn has_pending(&self) -> bool

Whether a checkpoint is currently in progress (waiting for acks).

Trait Implementations

impl Debug for CheckpointCoordinator

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

Formats the value using the given formatter.