Struct BlockTracker

pub struct BlockTracker { /* private fields */ }

BlockTracker is responsible for monitoring the sequence of processed blocks across different networks and identifying any gaps or irregularities in block processing.

Gap detection is per-execution and doesn’t require shared state, so we don’t track fetched blocks in shared history. Only processed blocks are tracked for duplicate/out-of-order detection.

Trait Implementations

impl BlockTrackerTrait for BlockTracker

fn new(history_size: usize) -> Self

Creates a new BlockTracker instance.

Arguments

• history_size - The maximum number of recent blocks to track per network
• storage - Optional storage implementation for persisting missed block information

Returns

A new BlockTracker instance

fn get_last_block<'life0, 'life1, 'async_trait>( &'life0 self, network_slug: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves the most recently processed block number for a given network.

Arguments

• network_slug - The unique identifier for the network

Returns

Returns Some(block_number) if blocks have been processed for the network, otherwise returns None.

fn detect_missing_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _network: &'life1 Network, fetched_blocks: &'life2 [BlockType], ) -> Pin<Box<dyn Future<Output = Vec<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Detects missing blocks in a batch of fetched blocks

fn check_processed_block<'life0, 'life1, 'async_trait>( &'life0 self, network: &'life1 Network, block_number: u64, ) -> Pin<Box<dyn Future<Output = BlockCheckResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Checks a processed block for duplicates or out-of-order issues

fn reset_expected_next<'life0, 'life1, 'async_trait>( &'life0 self, network: &'life1 Network, start_block: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Resets the expected next block number for a network to a new starting point. This should be called at the start of each process_new_blocks execution to synchronize expected_next with the start_block.

impl Clone for BlockTracker

fn clone(&self) -> BlockTracker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.