Struct AdaptiveBuffer 

pub struct AdaptiveBuffer<A: Float + Send + Sync> { /* private fields */ }

Adaptive buffer for managing streaming data with quality-based retention

Implementations

impl<A: Float + Default + Clone + Send + Sync + Sum + Debug> AdaptiveBuffer<A>

pub fn new(config: &StreamingConfig) -> Result<Self, String>

Creates a new adaptive buffer

pub fn add_batch( &mut self, batch: Vec<StreamingDataPoint<A>>, ) -> Result<(), String>

Adds a batch of data points to the buffer

pub fn get_batch_for_processing( &mut self, ) -> Result<Vec<StreamingDataPoint<A>>, String>

Gets a batch of data for processing

pub fn current_size(&self) -> usize

Gets current buffer size (total items across all buffers)

pub fn time_since_last_processing(&self) -> Duration

Gets time since last processing

pub fn get_quality_metrics(&self) -> BufferQualityMetrics<A>

Gets current buffer quality metrics

pub fn compute_size_adaptation( &self, performance_tracker: &PerformanceTracker<A>, ) -> Result<Option<Adaptation<A>>, String>

Computes size adaptation based on performance feedback

pub fn apply_size_adaptation( &mut self, adaptation: &Adaptation<A>, ) -> Result<(), String>

Applies size adaptation to the buffer

pub fn last_size_change(&self) -> f32

Gets the last size change amount

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

Resets the buffer to initial state

pub fn get_diagnostics(&self) -> BufferDiagnostics

Gets diagnostic information