Struct KernelEventLog 

pub struct KernelEventLog { /* private fields */ }

Thread-safe ring buffer for kernel runtime events.

Captures boot events and any post-boot events (service starts/stops, agent spawns, health checks, errors). Holds at most capacity events — when full, the oldest event is evicted.

Used by the daemon to serve kernel.logs / kernel.logs_stream RPC requests. Live subscribers receive entries as they are ingested (WEFT-434); each entry carries a monotonic BootEvent::seq.

Implementations

impl KernelEventLog

pub fn new() -> Self

Create a new event log with the default capacity (1024).

pub fn with_capacity(capacity: usize) -> Self

Create a new event log with a specific capacity.

pub fn push(&self, event: BootEvent)

Push an event into the ring buffer and fan out to live subscribers.

Assigns a monotonic BootEvent::seq (starting at 1). The write lock is released before subscriber notification so a slow consumer cannot block ingest.

pub fn info(&self, source: &str, message: impl Into<String>)

Push a simple info event with a source tag and message.

pub fn warn(&self, source: &str, message: impl Into<String>)

Push a warning event.

pub fn error(&self, source: &str, message: impl Into<String>)

Push an error event.

pub fn subscribe(&self) -> (u64, Receiver<BootEvent>)

Subscribe to real-time log entries (WEFT-434).

Returns a subscription id (for Self::unsubscribe) and a receiver that yields every event ingested after the subscribe call. The channel is bounded; a slow consumer is dropped from the fan-out set on the next failed try_send.

pub fn unsubscribe(&self, id: u64)

Drop a live subscriber. Idempotent.

pub fn subscriber_count(&self) -> usize

Number of active live subscribers.

pub fn last_seq(&self) -> u64

Highest sequence number assigned so far (0 if none pushed).

pub fn info_with_chain( &self, source: &str, message: impl Into<String>, chain: Option<&ChainManager>, )

Push an info event and optionally append to the local chain.

pub fn ingest_boot_log(&self, boot_log: &BootLog)

Ingest all events from a BootLog (used to seed boot events).

pub fn tail(&self, n: usize) -> Vec<BootEvent>

Get the last n events (or all if n is 0 or exceeds count).

pub fn filter_level(&self, min_level: &LogLevel, n: usize) -> Vec<BootEvent>

Get all events matching a minimum log level.

pub fn len(&self) -> usize

Current number of events in the buffer.

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

Trait Implementations

impl Debug for KernelEventLog

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

Formats the value using the given formatter.

impl Default for KernelEventLog

fn default() -> Self

Returns the “default value” for a type.