Struct BlockHandlerScheduler 

pub struct BlockHandlerScheduler { /* private fields */ }

Manages block-level handler scheduling and execution.

The scheduler maintains a list of interval handlers (which fire every N blocks) and setup handlers (which fire once). It determines when each handler should run and executes them in registration order.

Implementations

impl BlockHandlerScheduler

pub fn new() -> Self

Create a new empty scheduler.

pub fn register_interval(&mut self, handler: Arc<dyn IntervalHandler>)

Register an interval handler.

Handlers are executed in registration order when their interval is due.

pub fn register_setup(&mut self, handler: Arc<dyn SetupHandler>)

Register a setup handler.

Setup handlers run once during run_setup, in registration order.

pub async fn run_setup( &mut self, ctx: &IndexContext, ) -> Result<(), IndexerError>

Run all setup handlers once.

This method is idempotent — calling it more than once has no effect. Returns an error if any setup handler fails.

pub async fn run_block( &self, block: &BlockSummary, ctx: &IndexContext, ) -> Result<(), IndexerError>

Run all interval handlers that are due for the given block.

A handler fires when block.number % handler.interval() == 0. Handlers are executed in registration order.

pub fn should_run_interval( &self, handler: &dyn IntervalHandler, block_number: u64, ) -> bool

Check whether an interval handler should fire at the given block number.

Returns true if block_number % interval == 0. An interval of 0 is treated as “never fire” to avoid division by zero.

pub fn is_setup_complete(&self) -> bool

Returns whether setup has been completed.

pub fn interval_handler_count(&self) -> usize

Returns the number of registered interval handlers.

pub fn setup_handler_count(&self) -> usize

Returns the number of registered setup handlers.

Trait Implementations

impl Default for BlockHandlerScheduler

fn default() -> Self

Returns the “default value” for a type.