Struct StreamChangelogBuffer 

pub struct StreamChangelogBuffer { /* private fields */ }

A pre-allocated ring buffer for changelog entries.

Uses a simple write/read index scheme. Not thread-safe on its own — intended to be used behind the StreamCheckpointManager mutex.

Implementations

impl StreamChangelogBuffer

pub fn new(capacity: usize, policy: OverflowPolicy) -> Self

Creates a new changelog buffer with the given capacity.

pub fn push(&mut self, entry: StreamChangelogEntry) -> bool

Pushes an entry into the buffer.

Returns true if the entry was stored, false if dropped due to overflow policy.

pub fn pop(&mut self) -> Option<StreamChangelogEntry>

Pops the oldest entry from the buffer.

pub fn drain(&mut self, max: usize, out: &mut Vec<StreamChangelogEntry>)

Drains up to max entries into the provided vector.

pub fn drain_all(&mut self, out: &mut Vec<StreamChangelogEntry>)

Drains all entries into the provided vector.

pub fn len(&self) -> usize

Returns the number of entries in the buffer.

pub fn is_empty(&self) -> bool

Returns true if the buffer is empty.

pub fn is_full(&self) -> bool

Returns true if the buffer is full.

pub fn capacity(&self) -> usize

Returns the buffer capacity.

pub fn overflow_count(&self) -> u64

Returns the total number of overflows since creation.

Trait Implementations

impl Debug for StreamChangelogBuffer

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

Formats the value using the given formatter.