pub struct JsonLinesProcessor;Expand description
Structured processor for NDJSON / JSON Lines files.
Trait Implementations§
Source§impl Processor for JsonLinesProcessor
impl Processor for JsonLinesProcessor
Source§fn name(&self) -> &'static str
fn name(&self) -> &'static str
Unique name for this processor (e.g.
"json", "yaml", "key_value").Source§fn can_handle(&self, content: &[u8], profile: &FileTypeProfile) -> bool
fn can_handle(&self, content: &[u8], profile: &FileTypeProfile) -> bool
Quick heuristic: can this processor handle the given content? Read more
Source§fn supports_streaming(&self) -> bool
fn supports_streaming(&self) -> bool
Whether this processor supports bounded-memory streaming via
process_stream. Read moreSource§fn process(
&self,
content: &[u8],
profile: &FileTypeProfile,
store: &MappingStore,
) -> Result<Vec<u8>>
fn process( &self, content: &[u8], profile: &FileTypeProfile, store: &MappingStore, ) -> Result<Vec<u8>>
Process the content, replacing matched field values one-way. Read more
Source§fn process_stream(
&self,
reader: &mut dyn Read,
writer: &mut dyn Write,
profile: &FileTypeProfile,
store: &MappingStore,
) -> Result<()>
fn process_stream( &self, reader: &mut dyn Read, writer: &mut dyn Write, profile: &FileTypeProfile, store: &MappingStore, ) -> Result<()>
Process content from a reader, writing sanitized output to a writer. Read more
Auto Trait Implementations§
impl Freeze for JsonLinesProcessor
impl RefUnwindSafe for JsonLinesProcessor
impl Send for JsonLinesProcessor
impl Sync for JsonLinesProcessor
impl Unpin for JsonLinesProcessor
impl UnsafeUnpin for JsonLinesProcessor
impl UnwindSafe for JsonLinesProcessor
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more