Struct BackfillConfig 

pub struct BackfillConfig {
    pub from_block: u64,
    pub to_block: u64,
    pub concurrency: usize,
    pub segment_size: u64,
    pub batch_size: u64,
    pub retry_attempts: u32,
    pub retry_delay: Duration,
}

Configuration for the parallel backfill engine.

Fields

from_block: u64

First block to index (inclusive).

to_block: u64

Last block to index (inclusive).

concurrency: usize

Maximum number of segments processed in parallel.

segment_size: u64

Number of blocks in each parallel work unit (segment).

batch_size: u64

Number of blocks fetched in a single RPC call within a segment.

retry_attempts: u32

How many times to retry a failed segment before giving up.

retry_delay: Duration

Base delay between retries; doubles on each attempt (exponential back-off).

Implementations

impl BackfillConfig

pub fn validate(&self) -> Result<(), IndexerError>

Validate that the config is internally consistent.

pub fn segments(&self) -> Vec<BackfillSegment>

Divide the configured block range into ordered BackfillSegments.

Trait Implementations

impl Clone for BackfillConfig

fn clone(&self) -> BackfillConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackfillConfig

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

Formats the value using the given formatter.

impl Default for BackfillConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BackfillConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BackfillConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.