Struct StreamAlphaNode 

pub struct StreamAlphaNode {
    pub stream_name: String,
    pub event_type: Option<String>,
    pub window: Option<WindowSpec>,
    /* private fields */
}

StreamAlphaNode filters events from a named stream

This node:

• Filters events by stream name
• Optionally filters by event type
• Manages time-based windows (sliding, tumbling)
• Evicts expired events automatically

Fields

stream_name: String

Name of the stream to filter

event_type: Option<String>

Optional event type filter

window: Option<WindowSpec>

Window specification (if any)

Implementations

impl StreamAlphaNode

pub fn new( stream_name: impl Into<String>, event_type: Option<String>, window: Option<WindowSpec>, ) -> Self

Create a new StreamAlphaNode

Arguments

• stream_name - Name of the stream to filter
• event_type - Optional event type filter
• window - Optional window specification

Example

use rust_rule_engine::rete::stream_alpha_node::{StreamAlphaNode, WindowSpec};
use rust_rule_engine::streaming::window::WindowType;
use std::time::Duration;

// Node without window
let node = StreamAlphaNode::new("user-events", None, None);

// Node with sliding window
let window = WindowSpec {
    duration: Duration::from_secs(300),
    window_type: WindowType::Sliding,
};
let node = StreamAlphaNode::new("logins", Some("LoginEvent".to_string()), Some(window));

pub fn with_max_events(self, max_events: usize) -> Self

Create with custom max events

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

Process incoming event and return whether it matches

Arguments

• event - The stream event to process

Returns

• true if event matches stream name, event type, and window criteria
• false otherwise

pub fn get_events(&self) -> &VecDeque<StreamEvent>

Get all events currently in the window

Returns

A slice of events that are within the current window

pub fn event_count(&self) -> usize

Get count of events in window

pub fn clear(&mut self)

Clear all events from buffer

pub fn window_stats(&self) -> WindowStats

Get window statistics

Trait Implementations

impl Clone for StreamAlphaNode

fn clone(&self) -> StreamAlphaNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamAlphaNode

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

Formats the value using the given formatter.