Struct WatchFilter 

pub struct WatchFilter {
    pub domains: Option<Vec<String>>,
    pub experience_types: Option<Vec<ExperienceType>>,
    pub min_importance: Option<f32>,
}

Filter for narrowing which watch events a subscriber receives.

All fields are optional. When multiple fields are set, they are combined with AND logic: an event must match all specified criteria.

Filters are applied on the sender side before channel delivery, so subscribers only receive events they care about.

Example

use pulsedb::WatchFilter;

let filter = WatchFilter {
    domains: Some(vec!["security".to_string()]),
    min_importance: Some(0.7),
    ..Default::default()
};
let stream = db.watch_experiences_filtered(collective_id, filter)?;

Fields

domains: Option<Vec<String>>

Only emit events for experiences in these domains. If None, all domains match.

experience_types: Option<Vec<ExperienceType>>

Only emit events for these experience types. If None, all types match.

min_importance: Option<f32>

Only emit events for experiences with importance >= this threshold. If None, all importance levels match.

Trait Implementations

impl Clone for WatchFilter

fn clone(&self) -> WatchFilter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatchFilter

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

Formats the value using the given formatter.

impl Default for WatchFilter

fn default() -> WatchFilter

Returns the “default value” for a type.