Struct StreamNode 

pub struct StreamNode {
    pub id: String,
    pub processor: Arc<dyn StreamProcessor>,
    pub backpressure_config: BackpressureConfig,
    pub chunk_config: Option<ChunkConfig>,
    pub collect_results: bool,
}

Stream node for processing data streams

Fields

id: String

processor: Arc<dyn StreamProcessor>

backpressure_config: BackpressureConfig

chunk_config: Option<ChunkConfig>

collect_results: bool

Implementations

impl StreamNode

pub fn new(id: impl Into<String>, processor: Arc<dyn StreamProcessor>) -> Self

Create a new stream node

pub fn with_backpressure(self, config: BackpressureConfig) -> Self

Configure backpressure

pub fn with_chunking(self, config: ChunkConfig) -> Self

Enable chunked processing for large datasets

pub fn collect_results(self, collect: bool) -> Self

Set whether to collect all results (default: true) If false, only the last result is stored

pub async fn process_stream( &self, data: Vec<Value>, ctx: &Context, ) -> RuleResult

Process a stream of data

Trait Implementations

impl Clone for StreamNode

fn clone(&self) -> StreamNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamNode

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

Formats the value using the given formatter.

impl Node for StreamNode

fn id(&self) -> &str

fn node_type(&self) -> NodeType

fn run<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = RuleResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,