Struct BackfillEngine 

pub struct BackfillEngine { /* private fields */ }

Parallel backfill engine.

Construct with BackfillEngine::new and execute with BackfillEngine::run.

Implementations

impl BackfillEngine

pub fn new( config: BackfillConfig, provider: Arc<dyn BlockDataProvider>, filter: EventFilter, chain: impl Into<String>, ) -> Self

Create a new engine. The provider is shared across all worker tasks.

pub async fn progress(&self) -> BackfillProgress

Return a snapshot of the current progress.

Safe to call from any task while [run] is executing.

pub async fn run(&self) -> Result<BackfillResult, IndexerError>

Execute the backfill.

Spawns up to config.concurrency concurrent worker tasks, each processing one segment at a time. Blocks until all segments have either completed or exhausted their retry budget.