Struct StreamExecutor 

pub struct StreamExecutor { /* private fields */ }

Stream executor manages real-time data streams

Implementations

impl StreamExecutor

pub fn new(plugin_loader: Arc<RwLock<PluginLoader>>) -> Self

Create a new stream executor

pub fn with_evaluator( plugin_loader: Arc<RwLock<PluginLoader>>, evaluator: Arc<dyn ExpressionEvaluator>, ) -> Self

Create a stream executor with an expression evaluator for handler execution

pub fn event_sender(&self) -> Sender<(String, StreamEvent)>

Get event sender for plugins to send events

pub async fn start_stream( &mut self, stream_def: &StreamDef, ctx: &mut ExecutionContext, ) -> Result<()>

Start a stream from a StreamDef

pub fn stop_stream(&mut self, name: &str) -> Result<()>

Stop a running stream

pub fn handle_event( &mut self, stream_name: &str, event: StreamEvent, stream_def: &StreamDef, ctx: &mut ExecutionContext, ) -> Result<()>

Handle an incoming event

pub async fn run_event_loop( &mut self, stream_defs: HashMap<String, StreamDef>, ctx: &mut ExecutionContext, ) -> Result<()>

Run the event loop (call this in an async context)

pub fn list_streams(&self) -> Vec<&str>

Get list of running streams

pub fn is_running(&self, name: &str) -> bool

Check if a stream is running

pub fn get_state(&self, name: &str) -> Option<&StreamState>

Get stream state for inspection