Struct CheckpointCoordinator 

pub struct CheckpointCoordinator { /* private fields */ }

Checkpoint coordinator.

Implementations

impl CheckpointCoordinator

pub fn new(config: CheckpointConfig) -> Self

Create a new checkpoint coordinator.

pub async fn trigger_checkpoint(&self) -> Result<u64>

Trigger a new checkpoint.

pub async fn complete_checkpoint( &self, checkpoint_id: u64, success: bool, ) -> Result<()>

Complete a checkpoint.

pub async fn active_count(&self) -> usize

Get active checkpoint count.

pub async fn completed_count(&self) -> usize

Get completed checkpoint count.

pub async fn latest_checkpoint(&self) -> Option<u64>

Get the latest completed checkpoint ID.

pub async fn clear_old_checkpoints(&self, keep_count: usize)

Clear old checkpoints.

pub async fn start_periodic_checkpointing(self: Arc<Self>)

Start periodic checkpointing.