Struct BlockRangeScannerBuilder 

pub struct BlockRangeScannerBuilder {
    pub max_block_range: u64,
    pub past_blocks_storage_capacity: RingBufferCapacity,
    pub buffer_capacity: usize,
}

Builder/configuration for the block-range streaming service.

Fields

max_block_range: u64

Maximum number of blocks per streamed range.

past_blocks_storage_capacity: RingBufferCapacity

How many past block hashes to keep in memory for reorg detection.

If set to RingBufferCapacity::Limited(0), reorg detection is disabled.

buffer_capacity: usize

Implementations

impl BlockRangeScannerBuilder

pub fn new() -> Self

Creates a scanner with default configuration.

pub fn max_block_range(self, max_block_range: u64) -> Self

Sets the maximum number of blocks per streamed range.

This controls batching for historical scans and for catch-up in live/sync scanners.

Must be greater than 0.

pub fn past_blocks_storage_capacity( self, past_blocks_storage_capacity: RingBufferCapacity, ) -> Self

Sets how many past block hashes to keep in memory for reorg detection.

If set to RingBufferCapacity::Limited(0), reorg detection is disabled.

pub fn buffer_capacity(self, buffer_capacity: usize) -> Self

Sets the stream buffer capacity.

Controls the maximum number of messages that can be buffered in the stream before backpressure is applied.

Arguments

• buffer_capacity - Maximum number of messages to buffer (must be greater than 0)

pub async fn connect<N: Network>( self, provider: impl IntoRobustProvider<N>, ) -> Result<BlockRangeScanner<N>, ScannerError>

Connects to an existing provider

Errors

Returns an error if the provider connection fails.

Trait Implementations

impl Clone for BlockRangeScannerBuilder

fn clone(&self) -> BlockRangeScannerBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BlockRangeScannerBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BlockRangeScannerBuilder

fn default() -> Self

Returns the “default value” for a type.