Struct StreamConfig 

pub struct StreamConfig {
    pub buffer_size: usize,
    pub window_duration: Duration,
    pub max_events_per_window: usize,
    pub max_windows: usize,
    pub window_type: WindowType,
    pub analytics_cache_ttl_ms: u64,
    pub processing_interval: Duration,
}

Configuration for stream rule engine

Fields

buffer_size: usize

Buffer size for incoming events

window_duration: Duration

Window duration for aggregations

max_events_per_window: usize

Maximum events per window

max_windows: usize

Maximum number of windows to keep

window_type: WindowType

Window type (sliding, tumbling, etc.)

analytics_cache_ttl_ms: u64

Cache TTL for analytics

processing_interval: Duration

Processing interval for rule evaluation

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.