Struct StreamStats 

pub struct StreamStats {
    pub current_size: usize,
    pub max_size: usize,
    pub total_written: u64,
    pub bytes_evicted: u64,
    pub closed: bool,
}

Statistics about a bounded stream.

Fields

current_size: usize

Current bytes in buffer.

max_size: usize

Maximum buffer size.

total_written: u64

Total bytes written (lifetime).

bytes_evicted: u64

Bytes evicted due to overflow.

closed: bool

Whether the stream is closed.

Implementations

impl StreamStats

pub fn overflow_marker(&self, label: &str) -> String

Build a loud marker describing this stream’s overflow. Call only when bytes_evicted > 0 — the caller is expected to gate on BoundedStream::has_overflowed first.

label names the stream (“stdout”/“stderr”) in the marker text. Centralized here — not hand-written at each capture site — so the two external-command spawn sites that must stay in sync (kernel.rs::try_execute_external and the test-only twin dispatch.rs::BackendDispatcher::try_external, see CLAUDE.md’s “two spawn sites” gotcha) can’t drift in wording (GH #191).

Trait Implementations

impl Clone for StreamStats

fn clone(&self) -> StreamStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamStats

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamStats

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamStats

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.