Struct BatchOptions 

pub struct BatchOptions {
    pub parallelism: usize,
    pub memory_limit_per_worker: usize,
    pub progress_interval: Duration,
    pub stop_on_error: bool,
    pub progress_callback: Option<Arc<dyn ProgressCallback>>,
    pub job_timeout: Option<Duration>,
}

Options for batch processing

Fields

parallelism: usize

Number of parallel workers

memory_limit_per_worker: usize

Maximum memory per worker (bytes)

progress_interval: Duration

Progress update interval

stop_on_error: bool

Whether to stop on first error

progress_callback: Option<Arc<dyn ProgressCallback>>

Progress callback

job_timeout: Option<Duration>

Timeout for individual jobs

Implementations

impl BatchOptions

pub fn with_parallelism(self, parallelism: usize) -> Self

Set the number of parallel workers

pub fn with_memory_limit(self, bytes: usize) -> Self

Set memory limit per worker

pub fn with_progress_callback<F>(self, callback: F) -> Self

where F: Fn(&ProgressInfo) + Send + Sync + 'static,

Set progress callback

pub fn stop_on_error(self, stop: bool) -> Self

Set whether to stop on first error

pub fn with_job_timeout(self, timeout: Duration) -> Self

Set job timeout

Trait Implementations

impl Clone for BatchOptions

fn clone(&self) -> BatchOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for BatchOptions

fn default() -> Self

Returns the “default value” for a type.