Struct StreamEngine 

pub struct StreamEngine { /* private fields */ }

Unified stream processing engine.

Implementations

impl StreamEngine

pub fn new() -> Self

pub fn create_processor( &mut self, name: &str, workflow_id: &str, source: StreamSource, window: Option<ProcessingWindow>, max_queue_size: usize, ) -> WorkflowResult<String>

Create a stream processor.

pub fn start(&mut self, stream_id: &str) -> WorkflowResult<()>

Start consuming from a stream.

pub fn pause(&mut self, stream_id: &str) -> WorkflowResult<()>

Pause stream consumption.

pub fn stop(&mut self, stream_id: &str) -> WorkflowResult<()>

Stop a stream processor.

pub fn checkpoint( &mut self, stream_id: &str, offset: u64, items_processed: u64, ) -> WorkflowResult<()>

Force checkpoint at current position.

pub fn add_fork( &mut self, stream_id: &str, name: &str, condition: &str, target_workflow_id: &str, ) -> WorkflowResult<String>

Add a fork to split stream by condition.

pub fn get_processor(&self, stream_id: &str) -> WorkflowResult<&StreamProcessor>

Get processor status.

pub fn list_processors(&self) -> Vec<&StreamProcessor>

List all processors.

Trait Implementations

impl Default for StreamEngine

fn default() -> Self

Returns the “default value” for a type.