Struct ProcessingStats 

pub struct ProcessingStats {

    pub lines_read: usize,
    pub lines_output: usize,
    pub lines_filtered: usize,
    pub lines_errors: usize,
    pub events_created: usize,
    pub events_output: usize,
    pub events_filtered: usize,
    pub late_events: usize,
    pub files_processed: usize,
    pub files_failed_to_open: usize,
    pub failed_file_samples: Vec<String>,
    pub recoverable_error_samples: Vec<String>,
    pub script_executions: usize,
    pub errors: usize,
    pub processing_time: Duration,
    pub start_time: Option<Instant>,
    pub discovered_levels: BTreeSet<String>,
    pub discovered_keys: BTreeSet<String>,
    pub discovered_levels_output: BTreeSet<String>,
    pub discovered_keys_output: BTreeSet<String>,
    pub first_timestamp: Option<DateTime<Utc>>,
    pub last_timestamp: Option<DateTime<Utc>>,
    pub first_result_timestamp: Option<DateTime<Utc>>,
    pub last_result_timestamp: Option<DateTime<Utc>>,
    pub timestamp_detected_events: usize,
    pub timestamp_parsed_events: usize,
    pub timestamp_absent_events: usize,
    pub timestamp_fields: IndexMap<String, TimestampFieldStat>,
    pub timestamp_override_field: Option<String>,
    pub timestamp_override_format: Option<String>,
    pub timestamp_override_failed: bool,
    pub timestamp_override_warning: Option<String>,
    pub yearless_timestamps: usize,
    pub detected_format: Option<String>,
    pub detected_format_counts: IndexMap<String, usize>,
    pub cascade_format_counts: IndexMap<String, usize>,
    pub assertion_failures: usize,
    pub assertion_failures_by_expr: HashMap<String, usize>,
}

Statistics collected during log processing

Fields

lines_read: usize

lines_output: usize

lines_filtered: usize

lines_errors: usize

events_created: usize

events_output: usize

events_filtered: usize

late_events: usize

files_processed: usize

files_failed_to_open: usize

failed_file_samples: Vec<String>

recoverable_error_samples: Vec<String>

script_executions: usize

errors: usize

processing_time: Duration

start_time: Option<Instant>

discovered_levels: BTreeSet<String>

discovered_keys: BTreeSet<String>

discovered_levels_output: BTreeSet<String>

discovered_keys_output: BTreeSet<String>

first_timestamp: Option<DateTime<Utc>>

last_timestamp: Option<DateTime<Utc>>

first_result_timestamp: Option<DateTime<Utc>>

last_result_timestamp: Option<DateTime<Utc>>

timestamp_detected_events: usize

timestamp_parsed_events: usize

timestamp_absent_events: usize

timestamp_fields: IndexMap<String, TimestampFieldStat>

timestamp_override_field: Option<String>

timestamp_override_format: Option<String>

timestamp_override_failed: bool

timestamp_override_warning: Option<String>

yearless_timestamps: usize

detected_format: Option<String>

detected_format_counts: IndexMap<String, usize>

cascade_format_counts: IndexMap<String, usize>

Per-format event counts when running in cascade mode. Empty otherwise. Keyed by the short format name used in _format (e.g. “json”, “line”).

assertion_failures: usize

assertion_failures_by_expr: HashMap<String, usize>

Implementations

impl ProcessingStats

pub fn new() -> Self

pub fn extract_discovered_from_tracking( &mut self, tracking_data: &HashMap<String, Dynamic>, )

Extract discovered levels and keys from tracking data (for sequential processing)

pub fn format_stats(&self, _multiline_enabled: bool) -> String

Format stats according to the specification

pub fn format_stats_for_signal( &self, _multiline_enabled: bool, include_line_counts: bool, ) -> String

Format stats for signal handlers

include_line_counts should only be true when we have accurate mid-run counters (e.g., sequential mode). Parallel mode uses partial stats, so keep line counts suppressed there to avoid misleading zeros.

pub fn has_errors(&self) -> bool

Check if any errors occurred during processing

pub fn format_error_summary(&self) -> String

Format a concise error summary for default output (when errors occur)

Trait Implementations

impl Clone for ProcessingStats

fn clone(&self) -> ProcessingStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessingStats

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

Formats the value using the given formatter.

impl Default for ProcessingStats

fn default() -> ProcessingStats

Returns the “default value” for a type.