Struct akka_projection_rs::consumer_filter::Filter
source · pub struct Filter { /* private fields */ }
Expand description
A collection of criteria
Implementations§
source§impl Filter
impl Filter
pub fn new( topic_tag_prefix: Tag, max_tags: usize, max_regex_entity_ids: usize, max_entity_ids: usize, max_topics: usize ) -> Self
sourcepub fn matches<Envelope>(&self, envelope: &Envelope) -> boolwhere
Envelope: WithPersistenceId + WithTags,
pub fn matches<Envelope>(&self, envelope: &Envelope) -> boolwhere Envelope: WithPersistenceId + WithTags,
A function that matches an envelope with criteria and passes it through if matched.
sourcepub fn update(&mut self, criteria: Vec<FilterCriteria>)
pub fn update(&mut self, criteria: Vec<FilterCriteria>)
Updates the filter given commands to add or remove new criteria.
Trait Implementations§
Auto Trait Implementations§
impl RefUnwindSafe for Filter
impl Send for Filter
impl Sync for Filter
impl Unpin for Filter
impl UnwindSafe for Filter
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more