Enum FilterPredicate 

pub enum FilterPredicate {
    KeyEquals(String),
    ValueContains(String),
    TopicIs(String),
    TimestampAfter(u64),
    TimestampBefore(u64),
    HeaderMatches(String, String),
    And(Box<FilterPredicate>, Box<FilterPredicate>),
    Or(Box<FilterPredicate>, Box<FilterPredicate>),
    Not(Box<FilterPredicate>),
}

A composable filter predicate for StreamEvent matching.

Variants

KeyEquals(String)

Key must equal this exact string.

ValueContains(String)

Value must contain this substring.

TopicIs(String)

Topic must match exactly.

TimestampAfter(u64)

Timestamp must be greater than or equal to this value (inclusive lower bound).

TimestampBefore(u64)

Timestamp must be less than or equal to this value (inclusive upper bound).

HeaderMatches(String, String)

A header with the given key must have the given value.

And(Box<FilterPredicate>, Box<FilterPredicate>)

Logical AND: both sub-predicates must match.

Or(Box<FilterPredicate>, Box<FilterPredicate>)

Logical OR: at least one sub-predicate must match.

Not(Box<FilterPredicate>)

Logical NOT: the sub-predicate must not match.

Implementations

impl FilterPredicate

pub fn matches(&self, event: &StreamEvent) -> bool

Evaluate this predicate against a single StreamEvent.

pub fn and(self, other: FilterPredicate) -> FilterPredicate

Combine this predicate with another using logical AND.

pub fn or(self, other: FilterPredicate) -> FilterPredicate

Combine this predicate with another using logical OR.

Trait Implementations

impl Clone for FilterPredicate

fn clone(&self) -> FilterPredicate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FilterPredicate

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

Formats the value using the given formatter.

impl Not for FilterPredicate

fn not(self) -> FilterPredicate

Negate this predicate.

type Output = FilterPredicate

The resulting type after applying the ! operator.