Struct EventFilter 

pub struct EventFilter { /* private fields */ }

Event filter builder for creating complex event filters

Implementations

impl EventFilter

pub fn new() -> Self

Create a new event filter

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

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

Add a predicate to the filter

pub fn by_subject(self, pattern: String) -> Self

Filter events by subject pattern

pub fn by_predicate(self, pattern: String) -> Self

Filter events by predicate pattern

pub fn by_graph(self, graph_name: String) -> Self

Filter events by graph

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

Test if an event matches all predicates

pub fn filter_batch(&self, events: Vec<StreamEvent>) -> Vec<StreamEvent>

Filter a batch of events

Trait Implementations

impl Default for EventFilter

fn default() -> Self

Returns the “default value” for a type.