Enum CorrelationStrategy 

pub enum CorrelationStrategy {
    HeaderName(String),
    Expression {
        expr: String,
        language: String,
    },
    Fn(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>),
}

Strategy for correlating exchanges into aggregation buckets.

Variants

HeaderName(String)

Correlate by the value of a named header.

Expression

Correlate by evaluating an expression using a language registry.

Fields

expr: String

language: String

Fn(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>)

Correlate using a custom function.

Trait Implementations

impl Clone for CorrelationStrategy

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CorrelationStrategy

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

Formats the value using the given formatter.