Struct StreamingEngineBuilder 

pub struct StreamingEngineBuilder { /* private fields */ }

Builder for StreamingEngine with fluent API

Implementations

impl StreamingEngineBuilder

pub fn new() -> Self

Create a new builder

pub fn window_size(self, duration: StdDuration) -> Self

Set window size

pub fn slide_interval(self, duration: StdDuration) -> Self

Set slide interval (for sliding windows)

pub fn tumbling_windows(self) -> Self

Use tumbling windows (no overlap)

pub fn max_buffer_size(self, size: usize) -> Self

Set max buffer size

pub fn batch_size(self, size: usize) -> Self

Set batch size

pub fn max_concurrency(self, concurrency: usize) -> Self

Set max concurrency

pub fn detection_interval(self, interval: usize) -> Self

Set detection interval

pub fn discovery_config(self, config: OptimizedConfig) -> Self

Set discovery config

pub fn build(self) -> StreamingEngine

Build the streaming engine

Trait Implementations

impl Default for StreamingEngineBuilder

fn default() -> Self

Returns the “default value” for a type.