Struct BackpressureConfig 

pub struct BackpressureConfig {
    pub max_queue_depth: usize,
    pub chunk_size: usize,
    pub flush_timeout: Option<Duration>,
}

Configuration for RealtimePipeline.

Fields

max_queue_depth: usize

Maximum number of items buffered in the pipeline queue before backpressure kicks in. RealtimePipeline::send blocks; RealtimePipeline::try_send drops the item and increments RealtimeMetrics::items_dropped.

chunk_size: usize

Number of items accumulated before calling StreamingPipeline::process_chunk.

flush_timeout: Option<Duration>

How long the worker waits for the next item before flushing a partial chunk.

Some(d) bounds end-to-end latency at the cost of occasional small chunk calls. None flushes only when a full chunk is available or the input is closed, which is more efficient for bulk/batch workloads.

Trait Implementations

impl Clone for BackpressureConfig

fn clone(&self) -> BackpressureConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureConfig

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

Formats the value using the given formatter.

impl Default for BackpressureConfig

fn default() -> Self

Returns the “default value” for a type.