Struct CheckpointController 

pub struct CheckpointController { /* private fields */ }

Coordinator that drives checkpoint rounds across the operator topology.

Implementations

impl CheckpointController

pub fn new( config: CheckpointControllerConfig, propagator: Arc<MarkerPropagator>, store: Arc<dyn CheckpointStore>, ) -> Self

Build a controller.

pub fn config(&self) -> &CheckpointControllerConfig

Configuration accessor.

pub fn propagator(&self) -> &Arc<MarkerPropagator>

Marker propagator handle (so operator code can re-use the same propagator).

pub fn register_operator(&self, op: OperatorId)

Register an operator with the controller.

pub fn open(&self) -> Marker

Open a new checkpoint round.

pub async fn commit_snapshot( &self, snapshot: OperatorSnapshot, ) -> CheckpointResult<bool>

Acknowledge a snapshot from an operator.

pub fn progress(&self, cp: CheckpointId) -> Option<CheckpointProgress>

Fetch the current progress snapshot for a checkpoint.

pub fn forget(&self, cp: CheckpointId)

Drop progress for an old checkpoint (used when retiring rounds).

pub async fn latest_committed(&self) -> CheckpointResult<Option<CheckpointId>>

Latest checkpoint id known to the underlying store.

pub fn opened_rounds(&self) -> u64

Number of rounds opened by the controller so far.

pub fn store(&self) -> &Arc<dyn CheckpointStore>

Snapshot store reference for callers that need to load on recovery.