Struct StreamConfig 

pub struct StreamConfig {
    pub enabled_streams: HashSet<StreamType>,
    pub event_types: Option<HashSet<String>>,
    pub event_types_exclude: Option<HashSet<String>>,
    pub event_levels: Option<HashSet<String>>,
    pub metric_names: Option<HashSet<String>>,
    pub metric_phases: Option<HashSet<String>>,
    pub timeline_phases: Option<HashSet<String>>,
    pub sample_rate: f64,
    pub max_events_per_poll: Option<usize>,
    pub deduplicate: bool,
    pub poll_interval_seconds: f64,
}

Configuration for stream filtering and behavior.

Fields

enabled_streams: HashSet<StreamType>

Which stream types to enable.

event_types: Option<HashSet<String>>

Whitelist of event types to include (None = include all).

event_types_exclude: Option<HashSet<String>>

Blacklist of event types to exclude.

event_levels: Option<HashSet<String>>

Filter by event levels (e.g., “error”, “warning”, “info”).

metric_names: Option<HashSet<String>>

Filter metrics by name.

metric_phases: Option<HashSet<String>>

Filter metrics by phase.

timeline_phases: Option<HashSet<String>>

Filter timeline entries by phase.

sample_rate: f64

Sampling rate (0.0-1.0) for events.

max_events_per_poll: Option<usize>

Maximum events to return per poll.

deduplicate: bool

Enable deduplication.

poll_interval_seconds: f64

Polling interval in seconds.

Implementations

impl StreamConfig

pub fn all() -> Self

Create a config that includes all streams with no filtering.

pub fn with_default_filters() -> Self

Create a config with sensible default filters.

pub fn minimal() -> Self

Create a minimal config (status only).

pub fn errors_only() -> Self

Create a config for errors and warnings only.

pub fn metrics_only() -> Self

Create a config for metrics only.

pub fn enable_stream(self, stream_type: StreamType) -> Self

Enable a specific stream type.

pub fn disable_stream(self, stream_type: StreamType) -> Self

Disable a specific stream type.

pub fn include_event_type(self, event_type: impl Into<String>) -> Self

Add an event type to the whitelist.

pub fn exclude_event_type(self, event_type: impl Into<String>) -> Self

Add an event type to the blacklist.

pub fn with_levels(self, levels: Vec<&str>) -> Self

Filter by event levels.

pub fn with_metric_phases(self, phases: Vec<&str>) -> Self

Filter metrics by phase.

pub fn with_timeline_phases(self, phases: Vec<&str>) -> Self

Filter timeline entries by phase.

pub fn with_interval(self, seconds: f64) -> Self

Set the polling interval.

pub fn with_sample_rate(self, rate: f64) -> Self

Set the sample rate.

pub fn without_deduplication(self) -> Self

Disable deduplication.

pub fn is_stream_enabled(&self, stream_type: StreamType) -> bool

Check if a stream type is enabled.

pub fn should_include_event(&self, event: &Value) -> bool

Check if an event should be included based on filters.

pub fn should_include_metric(&self, metric: &Value) -> bool

Check if a metric should be included based on filters.

pub fn should_include_timeline(&self, entry: &Value) -> bool

Check if a timeline entry should be included based on filters.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> Self

Returns the “default value” for a type.