Struct PipelineConfig 

pub struct PipelineConfig {
    pub tick_duration: Duration,
    pub batch_size: usize,
    pub channel_buffer: usize,
    pub inject_anomalies: bool,
    pub anomaly_config: AnomalyInjectionConfig,
}

Configuration for the data pipeline.

Fields

tick_duration: Duration

How often to emit batches

batch_size: usize

Entries per batch

channel_buffer: usize

Channel buffer size

inject_anomalies: bool

Enable anomaly injection

anomaly_config: AnomalyInjectionConfig

Anomaly injection configuration

Implementations

impl PipelineConfig

pub fn fast() -> Self

Create a fast configuration for testing.

pub fn educational() -> Self

Create a slow configuration for educational demos.

Trait Implementations

impl Clone for PipelineConfig

fn clone(&self) -> PipelineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineConfig

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

Formats the value using the given formatter.

impl Default for PipelineConfig

fn default() -> Self

Returns the “default value” for a type.