Struct CheckpointTask 

pub struct CheckpointTask { /* private fields */ }

Background task that periodically rebuilds the OffsetSyncStore from the target cluster’s offset-syncs topic and then calls run_once.

Implementations

impl CheckpointTask

pub async fn start( params: CheckpointParams, interval: Duration, ) -> Result<Self, ReplicatorError>

Start the checkpoint loop with the given interval.

Each cycle:

1. Reads all records from mm2-offset-syncs.<source>.internal on the TARGET.
2. Builds a fresh OffsetSyncStore.
3. Calls run_once to write translated checkpoints.

Errors in any cycle are logged as warnings; the loop continues until shutdown.

Errors

Returns ReplicatorError only if initial setup fails (currently infallible; error type is reserved for future validation).

pub async fn shutdown(self)

Signal the task to stop and await its completion.