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 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.