Struct TimeboundCircularBuffer

pub struct TimeboundCircularBuffer<const S: usize, P>
where
    P: CuMsgPayload,
{
    pub inner: CircularBuffer<S, CuMsg<P>>,
}

An augmented circular buffer that allows for time-based operations.

Fields

inner: CircularBuffer<S, CuMsg<P>>

Implementations

impl<const S: usize, P> TimeboundCircularBuffer<S, P>

where P: CuMsgPayload,

pub fn new() -> Self

pub fn iter_window( &self, start_time: CuTime, end_time: CuTime, ) -> impl Iterator<Item = &CuMsg<P>>

Gets a slice of messages that fall within the given time range. In case of a Tov::Range, the message is included if its start and end time fall within the range.

pub fn purge(&mut self, time_horizon: CuTime)

Remove all the messages that are older than the given time horizon.

pub fn most_recent_time(&self) -> CuResult<Option<CuTime>>

Get the most recent time of the messages in the buffer.

pub fn push(&mut self, msg: CuMsg<P>)

Push a message into the buffer.

Trait Implementations

impl<const S: usize, P> Default for TimeboundCircularBuffer<S, P>

where P: CuMsgPayload,

fn default() -> Self

Returns the “default value” for a type.