Struct AggregatorConfig 

pub struct AggregatorConfig {
    pub header_name: String,
    pub completion: CompletionMode,
    pub correlation: CorrelationStrategy,
    pub strategy: AggregationStrategy,
    pub max_buckets: Option<usize>,
    pub bucket_ttl: Option<Duration>,
    pub force_completion_on_stop: bool,
    pub discard_on_timeout: bool,
}

Configuration for the Aggregator EIP.

Fields

header_name: String

Name of the header used as correlation key.

completion: CompletionMode

When to emit the aggregated exchange.

correlation: CorrelationStrategy

Strategy for determining correlation keys.

strategy: AggregationStrategy

How to combine the bucket into one exchange.

max_buckets: Option<usize>

Maximum number of correlation key buckets (memory protection). When limit is reached, new correlation keys are rejected.

bucket_ttl: Option<Duration>

Time-to-live for inactive buckets (memory protection). Buckets not updated for this duration are evicted.

force_completion_on_stop: bool

Force-complete all pending buckets when the route is stopped.

discard_on_timeout: bool

Discard bucket contents on timeout instead of emitting.

Implementations

impl AggregatorConfig

pub fn correlate_by(header: impl Into<String>) -> AggregatorConfigBuilder

Start building config with correlation key extracted from the named header.

Trait Implementations

impl Clone for AggregatorConfig

fn clone(&self) -> AggregatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.