Struct Filter 

pub struct Filter<P, N> { /* private fields */ }

filter: drop records failing the predicate. A drop releases the record’s ack share — it counts as success for the batch.

Trait Implementations

impl<P, N> Clone for Filter<P, N>

where P: Clone, N: Clone,

fn clone(&self) -> Filter<P, N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, P, N> Collector<T> for Filter<P, N>

where P: FnMut(&T) -> bool, N: Collector<T>,

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

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

impl<P, N> Debug for Filter<P, N>

where P: Debug, N: Debug,

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

Formats the value using the given formatter.

impl<P, N> StageLifecycle for Filter<P, 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.