Struct StreamingConfig 

pub struct StreamingConfig {
    pub buffer_config: BufferConfig,
    pub drift_config: DriftConfig,
    pub performance_config: PerformanceConfig,
    pub resource_config: ResourceConfig,
    pub meta_learning_config: MetaLearningConfig,
    pub anomaly_config: AnomalyConfig,
    pub learning_rate_config: LearningRateConfig,
}

Main configuration for adaptive streaming optimization

Fields

buffer_config: BufferConfig

Buffer management configuration

drift_config: DriftConfig

Drift detection configuration

performance_config: PerformanceConfig

Performance tracking configuration

resource_config: ResourceConfig

Resource management configuration

meta_learning_config: MetaLearningConfig

Meta-learning configuration

anomaly_config: AnomalyConfig

Anomaly detection configuration

learning_rate_config: LearningRateConfig

Learning rate adaptation configuration

Implementations

impl StreamingConfig

Validation methods for configuration

pub fn validate(&self) -> Result<(), String>

Validates the configuration for consistency and feasibility

pub fn low_latency() -> Self

Creates a configuration optimized for low-latency streaming

pub fn high_throughput() -> Self

Creates a configuration optimized for high-throughput streaming

pub fn memory_efficient() -> Self

Creates a configuration optimized for memory-constrained environments

Trait Implementations

impl Clone for StreamingConfig

fn clone(&self) -> StreamingConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingConfig

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

Formats the value using the given formatter.

impl Default for StreamingConfig

fn default() -> StreamingConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamingConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamingConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.