use super::types::{
AdvancedQoSConfig, LearningRateAdaptation, RealTimeConfig, StreamPriority, StreamingConfig,
};
impl Default for StreamingConfig {
fn default() -> Self {
Self {
buffer_size: 32,
latency_budget_ms: 10,
adaptive_learning_rate: true,
drift_threshold: 0.1,
drift_window_size: 1000,
gradient_compression: false,
compression_ratio: 0.5,
async_updates: false,
max_staleness: 10,
memory_efficient: true,
memory_budget_mb: 100,
lr_adaptation: LearningRateAdaptation::Adagrad,
adaptive_batching: true,
dynamic_buffer_sizing: true,
enable_priority_scheduling: false,
advanced_drift_detection: true,
enable_prediction: false,
qos_enabled: false,
multi_stream_coordination: false,
predictive_streaming: true,
stream_fusion: true,
advanced_qos_config: AdvancedQoSConfig::default(),
real_time_config: RealTimeConfig::default(),
pipeline_parallelism_degree: 2,
adaptive_resource_allocation: true,
distributed_streaming: false,
processingpriority: StreamPriority::Normal,
}
}
}