Struct SplitterConfig 

pub struct SplitterConfig {
    pub expression: SplitExpression,
    pub aggregation: AggregationStrategy,
    pub parallel: bool,
    pub parallel_limit: Option<usize>,
    pub stop_on_exception: bool,
    pub max_fragments: usize,
}

Configuration for the Splitter EIP.

Fields

expression: SplitExpression

Expression that splits an exchange into fragments.

aggregation: AggregationStrategy

How to aggregate fragment results.

parallel: bool

Whether to process fragments in parallel.

parallel_limit: Option<usize>

Maximum number of parallel fragments (None = unlimited).

stop_on_exception: bool

Whether to stop processing on the first exception.

In parallel mode this only affects aggregation (the first error is propagated), not in-flight futures — join_all cannot cancel already-spawned work.

max_fragments: usize

Maximum number of fragments materialized by expression (DoS cap, R3-M4).

The eager splitter materializes the whole Vec<Exchange> before processing; this cap rejects a split that would explode memory. Default 100_000. For unbounded/lazy input use StreamingSplitter.

Implementations

impl SplitterConfig

pub fn new(expression: SplitExpression) -> Self

Create a new splitter config with the given split expression.

pub fn aggregation(self, strategy: AggregationStrategy) -> Self

Set the aggregation strategy for combining fragment results.

pub fn parallel(self, parallel: bool) -> Self

Enable or disable parallel fragment processing.

pub fn parallel_limit(self, limit: usize) -> Self

Set the maximum number of concurrent fragments in parallel mode.

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

Control whether processing stops on the first fragment error.

In parallel mode this only affects aggregation — see the field-level doc comment for details.

pub fn max_fragments(self, max: usize) -> Self

Set the maximum number of fragments the eager splitter will materialize.

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

Validates the configuration.

Returns Err(CamelError::Config) if parallel_limit is set to 0, which would cause a Semaphore::new(0) panic at runtime.

Trait Implementations

impl Clone for SplitterConfig

fn clone(&self) -> SplitterConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SplitterConfig

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

Formats the value using the given formatter.