Struct StreamConfigBuilder 

pub struct StreamConfigBuilder { /* private fields */ }

Builder for stream processor configuration

Implementations

impl StreamConfigBuilder

pub fn new() -> Self

Create a new stream configuration builder with default values

pub const fn mode(self, mode: StreamMode) -> Self

Set the processing mode

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

Set the buffer size

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

Set the maximum batch size

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

Set the minimum batch size

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

Set the chunk size

pub const fn parallel(self, enable: bool) -> Self

Enable or disable parallel processing

pub const fn workers(self, workers: Option<usize>) -> Self

Set the number of worker threads

pub const fn rate_limit(self, limit: usize) -> Self

Set the rate limit

pub const fn timeout_ms(self, timeout: u64) -> Self

Set the timeout

pub const fn enable_prefetch(self, enable: bool) -> Self

Enable or disable prefetching

pub const fn prefetch_config(self, config: Option<PrefetchConfig>) -> Self

Set the prefetch configuration

pub const fn enable_backpressure(self, enable: bool) -> Self

Enable or disable backpressure handling

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

Set the window size for sliding window mode

pub const fn window_stride(self, stride: usize) -> Self

Set the window stride for sliding window mode

pub fn build(self) -> StreamConfig

Build the configuration

Trait Implementations

impl Clone for StreamConfigBuilder

fn clone(&self) -> StreamConfigBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfigBuilder

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

Formats the value using the given formatter.

impl Default for StreamConfigBuilder

fn default() -> StreamConfigBuilder

Returns the “default value” for a type.