pub struct PassthroughProcessor<R, L> { /* private fields */ }Expand description
A no-op processor that passes records through unchanged.
Implementations§
Trait Implementations§
Source§impl<R, L> Default for PassthroughProcessor<R, L>
impl<R, L> Default for PassthroughProcessor<R, L>
Source§impl<R: Send + Sync, L: Send + Sync> PostProcessor for PassthroughProcessor<R, L>
impl<R: Send + Sync, L: Send + Sync> PostProcessor for PassthroughProcessor<R, L>
Source§fn process(
&mut self,
_record: &mut Self::Record,
_context: &ProcessContext,
) -> SynthResult<Vec<Self::Label>>
fn process( &mut self, _record: &mut Self::Record, _context: &ProcessContext, ) -> SynthResult<Vec<Self::Label>>
Process a single record, potentially modifying it and generating labels. Read more
Source§fn is_enabled(&self) -> bool
fn is_enabled(&self) -> bool
Check if this processor is enabled.
Source§fn stats(&self) -> ProcessorStats
fn stats(&self) -> ProcessorStats
Get processing statistics.
Source§fn reset_stats(&mut self)
fn reset_stats(&mut self)
Reset statistics (for testing or between batches).
Source§fn process_batch(
&mut self,
records: &mut [Self::Record],
base_context: &ProcessContext,
) -> SynthResult<Vec<Self::Label>>
fn process_batch( &mut self, records: &mut [Self::Record], base_context: &ProcessContext, ) -> SynthResult<Vec<Self::Label>>
Process a batch of records. Read more
Auto Trait Implementations§
impl<R, L> Freeze for PassthroughProcessor<R, L>
impl<R, L> RefUnwindSafe for PassthroughProcessor<R, L>where
R: RefUnwindSafe,
L: RefUnwindSafe,
impl<R, L> Send for PassthroughProcessor<R, L>
impl<R, L> Sync for PassthroughProcessor<R, L>
impl<R, L> Unpin for PassthroughProcessor<R, L>
impl<R, L> UnwindSafe for PassthroughProcessor<R, L>where
R: UnwindSafe,
L: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more