Struct ParallelPipelineConfig 

pub struct ParallelPipelineConfig {
    pub num_workers: usize,
    pub morsel_size: usize,
    pub chunk_size: usize,
    pub preserve_order: bool,
    pub pressure_level: PressureLevel,
}

Configuration for parallel pipeline execution.

Fields

num_workers: usize

Number of worker threads.

morsel_size: usize

Base morsel size (adjusted for memory pressure).

chunk_size: usize

Chunk size for processing within morsels.

preserve_order: bool

Whether to preserve output ordering.

pressure_level: PressureLevel

Memory pressure level (affects morsel sizing).

Implementations

impl ParallelPipelineConfig

pub fn for_testing() -> Self

Creates config for testing with limited workers.

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

Sets the number of workers.

pub fn with_pressure(self, level: PressureLevel) -> Self

Sets memory pressure level.

pub fn effective_morsel_size(&self) -> usize

Returns effective morsel size based on pressure.

Trait Implementations

impl Clone for ParallelPipelineConfig

fn clone(&self) -> ParallelPipelineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelPipelineConfig

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

Formats the value using the given formatter.

impl Default for ParallelPipelineConfig

fn default() -> Self

Returns the “default value” for a type.