Struct ReplayBuffer 

pub struct ReplayBuffer { /* private fields */ }

An in-memory event replay buffer.

Events are appended sequentially. When the buffer exceeds max_capacity the oldest event is evicted automatically. A cursor tracks the current read position; seek / read operations advance it.

Implementations

impl ReplayBuffer

pub fn new(max_capacity: usize) -> Self

Create a new ReplayBuffer with the given maximum capacity.

When max_capacity is 0 the buffer has no effective limit (usize::MAX).

pub fn append(&mut self, event: StreamEvent) -> Result<(), ReplayError>

Append a new event to the buffer.

If the buffer is at max_capacity the oldest event is evicted and the cursor is adjusted so it never points past the start.

pub fn seek(&mut self, pos: SeekPosition) -> Result<usize, ReplayError>

Move the read cursor to pos.

Returns the new cursor position on success.

pub fn read_next(&mut self) -> Option<&StreamEvent>

Read the event at the current cursor position and advance the cursor.

Returns None when the cursor is past the last event.

pub fn read_batch(&mut self, count: usize) -> Vec<&StreamEvent>

Read up to count events starting at the current cursor, advancing the cursor past each returned event.

pub fn reset(&mut self)

Reset the cursor to the beginning of the buffer.

pub fn events_remaining(&self) -> usize

Number of events remaining from the cursor to the end of the buffer.

pub fn stats(&self) -> ReplayStats

Snapshot of current buffer statistics.

pub fn len(&self) -> usize

Total number of events currently stored in the buffer.

pub fn is_empty(&self) -> bool

Returns true if the buffer contains no events.