RingBuffer

Struct RingBuffer 

Source
pub struct RingBuffer { /* private fields */ }
Expand description

A ring buffer for accumulating terminal output.

The buffer supports efficient append operations and automatically discards oldest data when the maximum size is reached.

Implementations§

Source§

impl RingBuffer

Source

pub fn new(max_size: usize) -> Self

Create a new ring buffer with the specified maximum size.

Source

pub fn with_default_capacity() -> Self

Create a new ring buffer with default capacity.

Source

pub fn append(&mut self, data: &[u8])

Append data to the buffer.

If the buffer would exceed its maximum size, oldest data is discarded.

Source

pub fn as_slice(&mut self) -> &[u8]

Get the current buffer contents as a contiguous slice.

Note: This may need to reallocate if the buffer wraps around.

Source

pub fn as_str_lossy(&mut self) -> String

Get the current buffer contents as a string (lossy UTF-8 conversion).

Source

pub fn len(&self) -> usize

Get the current length of the buffer.

Source

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

Source

pub const fn max_size(&self) -> usize

Get the maximum size of the buffer.

Source

pub const fn total_written(&self) -> usize

Get the total bytes written to the buffer.

Source

pub const fn bytes_discarded(&self) -> usize

Get the number of bytes that have been discarded due to overflow.

Source

pub fn clear(&mut self)

Clear the buffer.

Source

pub fn find(&mut self, needle: &[u8]) -> Option<usize>

Find a byte sequence in the buffer.

Returns the position of the first match.

Source

pub fn find_str(&mut self, needle: &str) -> Option<usize>

Find a string in the buffer.

Source

pub fn consume(&mut self, end: usize) -> Vec<u8>

Consume data up to and including the specified position.

Returns the consumed data.

Source

pub fn consume_before(&mut self, pos: usize) -> String

Consume data up to (but not including) the specified position.

Returns the consumed data as a string (lossy conversion).

Source

pub fn consume_until(&mut self, needle: &str) -> Option<(String, String)>

Consume data up to and including a pattern match.

Returns (before_match, matched_text) if found.

Source

pub fn tail(&mut self, n: usize) -> Vec<u8>

Get a slice of the last N bytes in the buffer.

Source

pub fn head(&mut self, n: usize) -> Vec<u8>

Get a slice of the first N bytes in the buffer.

Source

pub fn find_in_tail( &mut self, needle: &[u8], window_size: usize, ) -> Option<usize>

Search within a window at the end of the buffer.

This is more efficient for large buffers when patterns are expected near the end.

Source

pub fn search<F, R>(&mut self, f: F) -> R
where F: FnOnce(&str) -> R,

Apply a function to search the buffer contents.

This is useful for complex pattern matching like regex.

Trait Implementations§

Source§

impl Clone for RingBuffer

Source§

fn clone(&self) -> RingBuffer

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for RingBuffer

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for RingBuffer

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl Write for RingBuffer

Source§

fn write(&mut self, buf: &[u8]) -> Result<usize>

Writes a buffer into this writer, returning how many bytes were written. Read more
Source§

fn flush(&mut self) -> Result<()>

Flushes this output stream, ensuring that all intermediately buffered contents reach their destination. Read more
1.36.0 · Source§

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>

Like write, except that it writes from a slice of buffers. Read more
Source§

fn is_write_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)
Determines if this Writer has an efficient write_vectored implementation. Read more
1.0.0 · Source§

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

Attempts to write an entire buffer into this writer. Read more
Source§

fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>

🔬This is a nightly-only experimental API. (write_all_vectored)
Attempts to write multiple buffers into this writer. Read more
1.0.0 · Source§

fn write_fmt(&mut self, args: Arguments<'_>) -> Result<(), Error>

Writes a formatted string into this writer, returning any error encountered. Read more
1.0.0 · Source§

fn by_ref(&mut self) -> &mut Self
where Self: Sized,

Creates a “by reference” adapter for this instance of Write. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V