Struct BlockTracker

pub struct BlockTracker<S> { /* private fields */ }

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

It maintains a history of recently processed blocks for each network and can optionally persist information about missed blocks using the provided storage implementation.

Type Parameters

• S - A type that implements the BlockStorage trait for persisting missed block information

Trait Implementations

impl<S: BlockStorage> BlockTrackerTrait<S> for BlockTracker<S>

fn new(history_size: usize, storage: Option<Arc<S>>) -> 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 record_block<'life0, 'life1, 'async_trait>( &'life0 self, network: &'life1 Network, block_number: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Records a processed block and identifies any gaps in block sequence.

This method performs several checks:

• Detects gaps between the last processed block and the current block
• Identifies out-of-order or duplicate blocks
• Stores information about missed blocks if storage is configured

Arguments

• network - The network information for the processed block
• block_number - The block number being recorded

Warning

This method will log warnings for out-of-order blocks and errors for missed blocks.

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.

impl<S: Clone> Clone for BlockTracker<S>

fn clone(&self) -> BlockTracker<S>

Returns a copy of the value.

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

Performs copy-assignment from source.