Struct LogService 

pub struct LogService { /* private fields */ }

Structured logging service with ring buffer and query support.

Stores log entries in a bounded ring buffer (oldest evicted when full). Supports query by PID, service, level, time range, and trace ID. Real-time subscribers receive entries via mpsc channels.

Implementations

impl LogService

pub fn new(max_entries: usize) -> Self

Create a new log service with the given capacity.

pub fn with_default_capacity() -> Self

Create a log service with default capacity (100,000).

pub fn ingest(&self, entry: LogEntry)

Ingest a log entry.

Stores in the ring buffer and fans out to all subscribers. Write lock is released before subscriber notification to prevent blocking on slow consumers.

pub fn log(&self, level: LogLevel, message: impl Into<String>, pid: Option<Pid>)

Log a convenience method: ingest with level, message, and optional PID.

pub fn query(&self, query: &LogQuery) -> Vec<LogEntry>

Query log entries matching the given criteria.

pub fn subscribe(&self) -> (String, Receiver<LogEntry>)

Subscribe to real-time log entries.

Returns a receiver that will receive all new log entries. The subscription ID can be used to unsubscribe.

pub fn unsubscribe(&self, id: &str)

Unsubscribe from real-time log entries.

pub fn len(&self) -> usize

Number of log entries currently stored.

pub fn is_empty(&self) -> bool

Whether the log buffer is empty.

pub fn capacity(&self) -> usize

Maximum capacity of the ring buffer.

pub fn subscriber_count(&self) -> usize

Number of active subscribers.

pub fn clear(&self)

Clear all log entries.

Trait Implementations

impl Default for LogService

fn default() -> Self

Returns the “default value” for a type.