Struct AggregatorConfig 

pub struct AggregatorConfig {
    pub header_name: String,
    pub completion: CompletionCondition,
    pub strategy: AggregationStrategy,
    pub max_buckets: Option<usize>,
    pub bucket_ttl: Option<Duration>,
}

Configuration for the Aggregator EIP.

Fields

header_name: String

Name of the header used as correlation key.

completion: CompletionCondition

When to emit the aggregated exchange.

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.

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.