Struct Aggregator 

pub struct Aggregator { /* private fields */ }

EIP Aggregator: groups messages by a correlation header, completes via a CompletionCondition, and emits the folded result via an AggregationStrategy. Storage is pluggable via GroupStore.

Implementations

impl Aggregator

pub fn new<H>(correlation_header: H, completion_size: usize) -> Aggregator

where H: Into<String>,

Back-compat constructor: size-threshold completion, text-concat strategy, in-memory store.

pub fn with_completion<H>( correlation_header: H, completion: Arc<dyn CompletionCondition>, ) -> Aggregator

where H: Into<String>,

Generic constructor with an arbitrary completion condition. Defaults: ConcatText strategy + InMemoryGroupStore. Override either with Aggregator::with_strategy / Aggregator::with_store.

pub fn weighted<H, F>( correlation_header: H, weight: F, threshold: u64, ) -> Aggregator

where H: Into<String>, F: Fn(&Message) -> u64 + Send + Sync + 'static,

Convenience: weighted-quorum completion (Σ weight(msg) ≥ threshold).

pub fn timed<H>(correlation_header: H, dur: Duration) -> Aggregator

where H: Into<String>,

Convenience: lazy timeout completion (see ByTimeout).

pub fn when<H, F>(correlation_header: H, predicate: F) -> Aggregator

where H: Into<String>, F: Fn(&[Message]) -> bool + Send + Sync + 'static,

Convenience: predicate completion.

pub fn with_strategy(self, strategy: Arc<dyn AggregationStrategy>) -> Aggregator

Replace the aggregation strategy. Returns self for chaining.

pub fn with_store(self, store: Arc<dyn GroupStore>) -> Aggregator

Replace the group store (e.g. swap in a persistent impl). Returns self for chaining.

pub fn clear_store(&self)

Clear every in-progress group. Intended for test isolation; not usually needed in production.

Trait Implementations

impl Clone for Aggregator

fn clone(&self) -> Aggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Aggregator

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

Formats the value using the given formatter.

impl Processor for Aggregator

fn process<'life0, 'life1, 'async_trait>( &'life0 self, exchange: &'life1 mut Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Aggregator: 'async_trait,