Struct StreamConfig 

pub struct StreamConfig {

    pub mode: StreamMode,
    pub buffersize: usize,
    pub max_batch_size: usize,
    pub min_batch_size: usize,
    pub chunk_size: usize,
    pub parallel: bool,
    pub workers: Option<usize>,
    pub rate_limit: usize,
    pub timeout_ms: u64,
    pub enable_prefetch: bool,
    pub prefetch_config: Option<PrefetchConfig>,
    pub enable_backpressure: bool,
    pub windowsize: usize,
    pub window_stride: usize,
}

Stream processor configuration

Fields

mode: StreamMode

Processing mode

buffersize: usize

Buffer size in elements

max_batch_size: usize

Maximum batch size for processing

min_batch_size: usize

Minimum batch size for processing

chunk_size: usize

Chunk size for chunked processing

parallel: bool

Whether to use parallel processing

workers: Option<usize>

Number of worker threads for parallel processing

rate_limit: usize

Maximum processing rate (items per second, 0 for unlimited)

timeout_ms: u64

Timeout for waiting for data (milliseconds, 0 for none)

enable_prefetch: bool

Whether to enable prefetching

prefetch_config: Option<PrefetchConfig>

Prefetch configuration

enable_backpressure: bool

Whether to enable backpressure handling

windowsize: usize

Window size for sliding window mode

window_stride: usize

Window stride for sliding window mode

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> Self

Returns the “default value” for a type.