Struct FixedWindowBuffer 

pub struct FixedWindowBuffer { /* private fields */ }

A bounded ring buffer storing the most recent capacity observations.

When the buffer is full, pushing a new value overwrites the oldest entry. Useful for fixed-window training or replay where only recent data matters.

Space complexity: O(capacity).

Examples

use rill_ml::drift::FixedWindowBuffer;

let mut buf = FixedWindowBuffer::new(3).unwrap();
buf.push(1.0).unwrap();
buf.push(2.0).unwrap();
buf.push(3.0).unwrap();
assert_eq!(buf.mean(), Some(2.0));

// Overwrites the oldest entry (1.0).
buf.push(4.0).unwrap();
assert_eq!(buf.mean(), Some(3.0)); // (2 + 3 + 4) / 3

Implementations

impl FixedWindowBuffer

pub fn new(capacity: usize) -> Result<Self, RillError>

Create a new buffer with the given capacity.

capacity must be greater than zero.

pub const fn capacity(&self) -> usize

The maximum number of elements the buffer can hold.

pub const fn len(&self) -> usize

The current number of elements stored.

pub const fn is_empty(&self) -> bool

Whether the buffer is empty.

pub const fn is_full(&self) -> bool

Whether the buffer is at capacity.

pub fn push(&mut self, value: f64) -> Result<(), RillError>

Push a new value, overwriting the oldest entry if full.

value must be finite.

pub fn mean(&self) -> Option<f64>

The mean of the stored values, or None if empty.

pub fn iter(&self) -> impl Iterator<Item = &f64>

Iterate over the stored values in insertion order (oldest to newest).

pub fn reset(&mut self)

Reset to the empty state.

Trait Implementations

impl Clone for FixedWindowBuffer

fn clone(&self) -> FixedWindowBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FixedWindowBuffer

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

Formats the value using the given formatter.