Struct OutputBuffer 

pub struct OutputBuffer { /* private fields */ }

Implementations

impl OutputBuffer

pub fn new( log: StructuredLogBuilder, shell_name: String, shell_marker: String, ) -> Self

Construct an OutputBuffer wired to the given log builder. append/consume_*/clear emit their corresponding buffer events on log while still holding the inner mutex, preventing a race between byte appends and event order. The inner mutex is a std::sync::Mutex - every critical section is pure CPU work, so no .await ever happens under the guard and a blocking lock is correct.

pub async fn append(&self, bytes: &[u8])

pub async fn consume_literal( &self, needle: &str, ) -> Option<(Match<LiteralMatch>, EventSeq)>

Find literal, drain the decoded prefix up to the match end, push the Matched buffer event while still holding the inner lock, and return the match plus the EventSeq of the just-pushed buffer event. All under one lock.

pub async fn consume_regex( &self, re: &Regex, ) -> Option<(Match<RegexMatch>, EventSeq)>

Find regex, drain via split_to, push the Matched buffer event, and return the match plus the EventSeq of the just-pushed buffer event. All under one lock.

Guards against partial-line matches: if the match ends at the buffer boundary and the buffer does not end with a newline, the last line may still be arriving. In that case we return None so the caller waits for more data rather than consuming an incomplete line.

pub async fn fail_check_consume_literal( &self, needle: &str, fail_pattern: Option<&FailPattern>, ) -> Result<Option<(Match<LiteralMatch>, EventSeq)>, FailPatternHit>

Check fail pattern against buffer, then try to consume literal - under one lock. Returns Err if fail pattern found, Ok(Some) if literal consumed, Ok(None) if not found. On success the Matched buffer event is pushed before releasing the lock.

pub async fn fail_check_consume_regex( &self, re: &Regex, fail_pattern: Option<&FailPattern>, ) -> Result<Option<(Match<RegexMatch>, EventSeq)>, FailPatternHit>

Check fail pattern against buffer, then try to consume regex - under one lock. Returns Err if fail pattern found, Ok(Some) if regex consumed, Ok(None) if not found. On success the Matched buffer event is pushed before releasing the lock.

pub async fn multimatch_scan( &self, slots: &mut [PatternSlot], block_entry: usize, ) -> Vec<Option<MultiMatchHit>>

Scan every still-unmatched slot against the current decoded buffer without draining and without checking fail patterns. Returns, per slot index, an Option<MultiMatchHit> (Some iff the slot matched this round). Regex slots respect the partial-line guard.

block_entry is the absolute offset of the multimatch block’s entry point. The scan operates against decoded[block_entry - base ..].

pub async fn drain_to(&self, target: usize)

Drop the prefix of decoded up to absolute offset target without emitting any buffer event. Used at multimatch block exit to advance past max(end_abs) across all pattern hits in a single step.

pub async fn base_offset(&self) -> usize

Current absolute base offset - the byte position in this shell’s lifetime stream where decoded starts. Used by the VM at multimatch block entry so the loop’s scan operates in absolute coordinates that remain stable across in-block Grew appends.

pub fn push_multimatch_matched_event( &self, before: String, matched: String, after: String, ) -> EventSeq

Push a Matched buffer event for a multimatch per-pattern hit. Same before/matched/after shape as single-match, but does not drain - the actual drain happens once at block exit via drain_to. Returns the EventSeq of the just-emitted event.

pub async fn check_fail_pattern( &self, fail_pattern: Option<&FailPattern>, ) -> Option<FailPatternHit>

Check fail pattern against current buffer (peek only, no drain).

pub async fn clear(&self) -> String

Drain the cleanly-decoded portion of the buffer, advancing base. Trailing bytes of an incomplete UTF-8 sequence stay carried over inside Utf8Stream, to be completed by a future append. Emits a Reset buffer event carrying the consumed prefix - byte-identical to the concatenation of Grew payloads emitted since the previous reset - before releasing the lock. Returns the consumed prefix.

pub async fn snapshot_tail(&self, n: usize) -> String

Return the tail of the current buffer (last n chars) as a string.

pub async fn remaining(&self) -> Vec<u8>

Return remaining unmatched buffer data (decoded prefix as bytes). Pending bytes of an incomplete UTF-8 sequence held back by Utf8Stream are not returned.

Trait Implementations

impl Clone for OutputBuffer

fn clone(&self) -> OutputBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.