Struct SplitTerminal 

pub struct SplitTerminal<SrcF: RecFamily, G> { /* private fields */ }

The chain’s split terminal. Runs the route closure over each record and aggregates the branches’ lifecycle (relieve/flush/fatal). See the module docs.

Trait Implementations

impl<'buf, SrcF, G> Collector<<SrcF as RecFamily>::Rec<'buf>> for SplitTerminal<SrcF, G>

where SrcF: RecFamily, G: for<'b> FnMut(SrcF::Rec<'b>, &mut SplitEmitter<'_>),

fn push(&mut self, rec: Record<SrcF::Rec<'buf>>) -> Flow

Push one record. Flow::Blocked propagates up to the boundary.

impl<SrcF: RecFamily, G> Debug for SplitTerminal<SrcF, G>

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

Formats the value using the given formatter.

impl<SrcF: RecFamily, G> StageLifecycle for SplitTerminal<SrcF, G>

fn on_batch_end(&mut self, elapsed: Duration)

Flush per-batch metric accumulators. elapsed is the chain-level batch duration: per-stage attribution inside one inlined loop is not measurable without per-record clocks, so every stage reports the chain figure, keeping the histograms comparable.

fn take_fatal(&mut self) -> Option<FatalError>

Take the first fatal error recorded by any stage.

fn relieve(&mut self) -> Flow

Let the terminal stage drain parked output. Flow::Blocked means it is still backed up and the chain must not accept new payloads.

fn flush_terminal(&mut self) -> Flow

Seal and hand off all terminal buffers, partial chunks included. Flow::Blocked means not everything could be sent; retry later.