Struct BatchRequest 

pub struct BatchRequest {
    pub logs: Vec<RawEvent>,
    pub chain: String,
    pub concurrency: usize,
    pub chunk_size: usize,
    pub error_mode: ErrorMode,
    pub on_progress: Option<Box<dyn ProgressCallback>>,
}

Configuration for a batch decode job.

Fields

logs: Vec<RawEvent>

The raw events to decode

chain: String

Chain slug — determines which decoder to use

concurrency: usize

Number of parallel Rayon workers (0 = use all available CPUs)

chunk_size: usize

Max events per chunk (memory safety)

error_mode: ErrorMode

How to handle decode errors

on_progress: Option<Box<dyn ProgressCallback>>

Optional progress callback

Implementations

impl BatchRequest

pub fn new(chain: impl Into<String>, logs: Vec<RawEvent>) -> Self

pub fn chunk_size(self, n: usize) -> Self

pub fn error_mode(self, mode: ErrorMode) -> Self

pub fn on_progress<F: Fn(usize, usize) + Send + Sync + 'static>( self, f: F, ) -> Self