Struct LogLineProcessor 

pub struct LogLineProcessor { /* private fields */ }

Structured processor for NDJSON / structured-log files.

Implementations

impl LogLineProcessor

pub fn new() -> Self

Trait Implementations

impl Default for LogLineProcessor

fn default() -> Self

Returns the “default value” for a type.

impl Processor for LogLineProcessor

fn name(&self) -> &'static str

Unique name for this processor (e.g. "json", "yaml", "key_value").

fn can_handle(&self, _content: &[u8], profile: &FileTypeProfile) -> bool

Quick heuristic: can this processor handle the given content?

fn process( &self, content: &[u8], profile: &FileTypeProfile, store: &MappingStore, ) -> Result<Vec<u8>>

Process the content, replacing matched field values one-way.

fn supports_streaming(&self) -> bool

Whether this processor supports bounded-memory streaming via process_stream.

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.