Struct StreamingProcessorConfig 

pub struct StreamingProcessorConfig {
    pub trade_channel_capacity: usize,
    pub bar_channel_capacity: usize,
    pub memory_threshold_bytes: usize,
    pub backpressure_timeout: Duration,
    pub circuit_breaker_threshold: f64,
    pub circuit_breaker_timeout: Duration,
}

Configuration for production streaming

Fields

trade_channel_capacity: usize

Channel capacity for trade input

bar_channel_capacity: usize

Channel capacity for completed bars

memory_threshold_bytes: usize

Memory usage threshold in bytes

backpressure_timeout: Duration

Backpressure timeout

circuit_breaker_threshold: f64

Circuit breaker error rate threshold (0.0-1.0)

circuit_breaker_timeout: Duration

Circuit breaker timeout before retry

Trait Implementations

impl Clone for StreamingProcessorConfig

fn clone(&self) -> StreamingProcessorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingProcessorConfig

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

Formats the value using the given formatter.

impl Default for StreamingProcessorConfig

fn default() -> Self

Returns the “default value” for a type.