optirs_core/streaming/
streamingconfig_traits.rs1use super::types::{
12 AdvancedQoSConfig, LearningRateAdaptation, RealTimeConfig, StreamPriority, StreamingConfig,
13};
14
15impl Default for StreamingConfig {
16 fn default() -> Self {
17 Self {
18 buffer_size: 32,
19 latency_budget_ms: 10,
20 adaptive_learning_rate: true,
21 drift_threshold: 0.1,
22 drift_window_size: 1000,
23 gradient_compression: false,
24 compression_ratio: 0.5,
25 async_updates: false,
26 max_staleness: 10,
27 memory_efficient: true,
28 memory_budget_mb: 100,
29 lr_adaptation: LearningRateAdaptation::Adagrad,
30 adaptive_batching: true,
31 dynamic_buffer_sizing: true,
32 enable_priority_scheduling: false,
33 advanced_drift_detection: true,
34 enable_prediction: false,
35 qos_enabled: false,
36 multi_stream_coordination: false,
37 predictive_streaming: true,
38 stream_fusion: true,
39 advanced_qos_config: AdvancedQoSConfig::default(),
40 real_time_config: RealTimeConfig::default(),
41 pipeline_parallelism_degree: 2,
42 adaptive_resource_allocation: true,
43 distributed_streaming: false,
44 processingpriority: StreamPriority::Normal,
45 }
46 }
47}