Struct WriteBuffer 

pub struct WriteBuffer { /* private fields */ }

Session-scoped write buffer.

Writes are queued via push() and flushed to the store in one transaction via drain(). The buffer is NOT thread-safe — it is owned by a single agent loop.

Implementations

impl WriteBuffer

pub fn new(capacity: usize) -> Self

Create a new WriteBuffer with the given capacity.

When capacity is reached, push() signals the caller to flush.

pub fn push(&mut self, write: BufferedWrite) -> bool

Queue a write operation.

Returns true if the buffer has reached capacity and should be flushed before the next push().

pub fn drain(&mut self) -> Vec<BufferedWrite>

Drain all pending writes, returning them in insertion order.

After this call, the buffer is empty and ready for the next turn.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool