Struct CheckpointManager 

pub struct CheckpointManager { /* private fields */ }

Manages checkpoint reads/writes for an indexer.

Implementations

impl CheckpointManager

pub fn new( store: Box<dyn CheckpointStore>, chain_id: impl Into<String>, indexer_id: impl Into<String>, save_interval: u64, ) -> Self

pub async fn load(&self) -> Result<Option<Checkpoint>, IndexerError>

Load the saved checkpoint (returns None if none exists).

pub async fn maybe_save( &mut self, block_number: u64, block_hash: &str, ) -> Result<(), IndexerError>

Conditionally save a checkpoint every save_interval blocks.

Call this after each block is successfully processed.

pub async fn force_save( &self, block_number: u64, block_hash: &str, ) -> Result<(), IndexerError>

Immediately save a checkpoint (used on shutdown / reorg recovery).