Struct StreamCheckpointManager 

pub struct StreamCheckpointManager { /* private fields */ }

Coordinates checkpoint lifecycle for streaming sources and sinks.

Disabled by default. When enabled via StreamCheckpointConfig, the manager captures atomic counters from registered sources to produce consistent StreamCheckpoint snapshots.

Implementations

impl StreamCheckpointManager

pub fn new(config: StreamCheckpointConfig) -> Self

Creates a new checkpoint manager.

If config validation fails, the manager is created in disabled state.

pub fn disabled() -> Self

Creates a disabled (no-op) manager.

pub fn is_enabled(&self) -> bool

Returns whether checkpointing is enabled.

pub fn register_source( &mut self, name: &str, sequence: Arc<AtomicU64>, watermark: Arc<AtomicI64>, )

Registers a source for checkpoint tracking.

The sequence and watermark atomics are shared with the live Source — reading them is lock-free.

pub fn register_sink(&mut self, name: &str, position: u64)

Registers a sink for checkpoint tracking.

pub fn trigger(&mut self) -> Option<u64>

Triggers a checkpoint, capturing current source/sink state.

Returns the checkpoint ID, or None if checkpointing is disabled.

pub fn checkpoint(&mut self) -> Result<Option<u64>, CheckpointError>

Creates a checkpoint and returns the checkpoint ID.

Errors

Returns CheckpointError::Disabled if checkpointing is not enabled.

pub fn restore(&self) -> Result<&StreamCheckpoint, CheckpointError>

Returns the most recent checkpoint for restore.

Errors

Returns CheckpointError::Disabled if checkpointing is not enabled, or CheckpointError::NoCheckpoint if no checkpoint exists.

pub fn get_checkpoint(&self, id: u64) -> Option<&StreamCheckpoint>

Returns a checkpoint by ID.

pub fn last_checkpoint_id(&self) -> Option<u64>

Returns the ID of the most recent checkpoint.

pub fn changelog(&self) -> Option<&StreamChangelogBuffer>

Returns a reference to the changelog buffer, if configured.

pub fn changelog_mut(&mut self) -> Option<&mut StreamChangelogBuffer>

Returns a mutable reference to the changelog buffer.

pub fn epoch(&self) -> u64

Returns the current epoch.

Trait Implementations

impl Debug for StreamCheckpointManager

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

Formats the value using the given formatter.