Struct AggregatorConfigBuilder 

pub struct AggregatorConfigBuilder { /* private fields */ }

Builder for AggregatorConfig.

Implementations

impl AggregatorConfigBuilder

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

Emit when bucket has N exchanges.

pub fn complete_when<F>(self, predicate: F) -> Self

where F: Fn(&[Exchange]) -> bool + Send + Sync + 'static,

Emit when predicate returns true for the current bucket.

pub fn complete_on_timeout(self, duration: Duration) -> Self

Emit when the bucket has been inactive for the given duration.

pub fn complete_on_size_or_timeout(self, size: usize, timeout: Duration) -> Self

Emit when the bucket reaches size OR has been inactive for timeout.

pub fn force_completion_on_stop(self, enabled: bool) -> Self

Enable force-completion of pending buckets when the route is stopped.

pub fn discard_on_timeout(self, enabled: bool) -> Self

Discard bucket contents on timeout instead of emitting the aggregated exchange.

pub fn correlate_by(self, header: impl Into<String>) -> Self

Override the correlation strategy with a header-based key.

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

Override the default CollectAll aggregation strategy.

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

Set the maximum number of correlation key buckets. When the limit is reached, new correlation keys are rejected with an error.

pub fn bucket_ttl(self, ttl: Duration) -> Self

Set the time-to-live for inactive buckets. Buckets that haven’t been updated for this duration will be evicted.

pub fn build(self) -> AggregatorConfig

Build the config. Panics if no completion condition was set.