Struct LockFreeEngine 

pub struct LockFreeEngine { /* private fields */ }

The near-lock-free ingestion engine.

Owns the ring buffer, flusher thread, and TUI metrics counters. Access the global instance via ENGINE.

Implementations

impl LockFreeEngine

pub fn new(capacity: usize) -> Self

Create a new engine with the given buffer capacity and spawn the flusher.

Panics

Panics if the OS cannot spawn the background flusher thread.

pub fn ingest(&self, event: LogEvent)

Appends an event to the ring buffer.

If the buffer is full, the oldest event is evicted to make room. Dropped events are tracked via TuiMetrics::dropped_events.

The event, level, error and format counters are updated as the flusher drains each event (or when one is dropped), so they trail ingest by at most one flush.

pub fn set_filter(&self, level: u8)

Sets the global log level filter.

pub fn filter_level(&self) -> u8

Returns the current global log level filter.

pub fn inc_format(&self, format: LogFormat)

Increments the format counter in the TUI metrics.

The engine counts each event’s format itself as it drains it; call this only for records that bypass Self::ingest.

pub fn inc_spans(&self)

Increments the active span count in the TUI metrics.

pub fn dec_spans(&self)

Decrements the active span count in the TUI metrics.

pub fn active_spans(&self) -> usize

Returns the current number of active spans.

pub fn apply_config(&self, config: &Config)

Applies configuration settings to the engine.

Sets the log level filter from the config. File sink construction and rotation are handled by the flusher thread at startup via PlatformSink::from_config.

pub fn shutdown(&self)

Safely halts the background thread, flushing pending logs.

Signals the flusher thread to stop and waits for it to finish draining any remaining events from the queue.

Trait Implementations

impl Debug for LockFreeEngine

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

Formats the value using the given formatter.