Module streaming

Module streaming 

Source

Re-exports§

pub use concept_drift::ConceptDriftDetector;
pub use concept_drift::DriftDetectorConfig;
pub use concept_drift::DriftEvent;
pub use concept_drift::DriftStatus;
pub use enhanced_adaptive_lr::AdaptationStatistics;
pub use enhanced_adaptive_lr::AdaptiveLRConfig;
pub use enhanced_adaptive_lr::EnhancedAdaptiveLRController;
pub use low_latency::LowLatencyConfig;
pub use low_latency::LowLatencyMetrics;
pub use low_latency::LowLatencyOptimizer;
pub use streaming_metrics::MetricsSample;
pub use streaming_metrics::MetricsSummary;
pub use streaming_metrics::StreamingMetricsCollector;

Modules§

adaptive_streaming
concept_drift
enhanced_adaptive_lr
low_latency
streaming_metrics

Structs§

AdaptiveResourceManager
Adaptive resource manager
AdvancedQoSConfig
Advanced Quality of Service configuration
AdvancedQoSManager
Advanced QoS manager for quality of service guarantees
FusedOptimizationStep
Fused optimization step
MultiStreamCoordinator
Multi-stream coordinator for synchronizing multiple data streams
PipelineExecutionManager
Pipeline execution manager for parallel stream processing
PipelineStage
Pipeline stage
PredictionModel
Prediction model for streaming data
PredictiveStreamingEngine
Predictive streaming engine for anticipating data patterns
QoSStatus
Quality of Service status
RTOptimizationResult
Real-time optimization result
RTOptimizationState
Real-time optimization state
RealTimeConfig
Real-time optimization configuration
RealTimeMetrics
Real-time metrics
RealTimeOptimizer
Real-time performance optimizer
ResourceAllocation
Resource allocation result
ResourceConstraints
Resource constraints
ResourceUsage
Current resource usage
ServiceLevelObjective
Service level objective
StageCoordinator
Stage coordination
StageMetrics
Stage metrics
StreamConfig
Stream configuration for individual streams
StreamFusionOptimizer
Stream fusion optimizer for combining multiple optimization streams
StreamingConfig
Streaming optimization configuration
StreamingDataPoint
Streaming data point
StreamingHealthStatus
Health status of streaming optimizer
StreamingMetrics
Streaming performance metrics
StreamingOptimizer
Streaming gradient descent optimizer
SyncBarrier
Synchronization barrier

Enums§

ConsensusAlgorithm
Consensus algorithms for distributed optimization
CoordinationStrategy
Coordination strategies for pipeline stages
FusionStrategy
Fusion strategies for combining optimization streams
InterruptStrategy
Interrupt handling strategies for real-time processing
LearningRateAdaptation
Learning rate adaptation strategies for streaming
LoadBalancingStrategy
Load balancing strategies for multi-stream processing
QoSMetric
Quality of Service metrics
QoSViolation
Quality of Service violation types
ResourceAllocationStrategy
Resource allocation strategies
ResourceReservationStrategy
Resource reservation strategies
StreamPriority
Stream processing priority levels