Struct BufferManager 

pub struct BufferManager<W: IoWrite> { /* private fields */ }

Manages buffered writing with automatic flushing and memory limits

Implementations

impl<W: IoWrite> BufferManager<W>

pub fn new(writer: W, max_buffer_size: usize) -> IoResult<Self>

Create a new buffer manager with default configuration

pub fn new_with_config(writer: W, config: BufferConfig) -> IoResult<Self>

Create a new buffer manager with custom configuration

pub fn set_flush_callback(&mut self, callback: FlushCallback)

Set a callback to be called when buffers are flushed

pub fn write_chunk(&mut self, data: &[u8]) -> IoResult<()>

Write a chunk of data to the buffer

pub fn flush_current_buffer(&mut self) -> IoResult<()>

Flush the current buffer to the queue

pub fn flush_oldest_buffer(&mut self) -> IoResult<()>

Flush the oldest buffer to the writer

pub fn flush_all(&mut self) -> IoResult<()>

Flush all buffers to the writer

pub fn current_memory_usage(&self) -> usize

Get current memory usage in bytes

pub fn current_buffer_size(&self) -> usize

Get current buffer size

pub fn total_bytes_written(&self) -> usize

Get total bytes written so far

pub fn peak_buffer_size(&self) -> usize

Get peak buffer size reached

pub fn total_flushes(&self) -> usize

Get total number of flushes performed

pub fn queued_buffer_count(&self) -> usize

Get number of buffers currently queued

pub fn is_near_capacity(&self) -> bool

Check if buffers are near capacity

pub fn get_stats(&self) -> BufferStats

Get buffer statistics

Trait Implementations

impl<W: IoWrite> Drop for BufferManager<W>

fn drop(&mut self)

Ensure all buffers are flushed when dropped