Struct TryMap 

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

try_map: fallible transform with a per-stage ErrorPolicy. Skip drops the record (releasing its ack share) and counts it; Fail records a fatal error — the batch aborts and the pipeline stops.

Trait Implementations

impl<G: Clone, N: Clone> Clone for TryMap<G, N>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<In, Out, E, G, N> Collector<In> for TryMap<G, N>

where G: FnMut(In) -> Result<Out, E>, E: Display, N: Collector<Out>,

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

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

impl<G: Debug, N: Debug> Debug for TryMap<G, N>

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

Formats the value using the given formatter.

impl<G, N: StageLifecycle> StageLifecycle for TryMap<G, N>

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.