Struct Inspect 

pub struct Inspect<G, N> { /* private fields */ }

inspect: observe without transforming (no metrics of its own).

Trait Implementations

impl<G, N> Clone for Inspect<G, N>

where G: Clone, N: Clone,

fn clone(&self) -> Inspect<G, N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, G, N> Collector<T> for Inspect<G, N>

where G: FnMut(&T), N: Collector<T>,

fn push(&mut self, rec: Record<T>) -> Flow

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

impl<G, N> Debug for Inspect<G, N>

where G: Debug, N: Debug,

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

Formats the value using the given formatter.

impl<G, N> StageLifecycle for Inspect<G, N>

where N: StageLifecycle,

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.