Struct LogAggregator 

pub struct LogAggregator { /* private fields */ }

Aggregates log entries from local and remote mesh nodes.

Stores entries per node and provides a merged, time-ordered query interface.

Implementations

impl LogAggregator

pub fn new(local_node_id: String) -> Self

Create a new log aggregator for the given local node.

pub fn log_local(&self, level: &str, message: &str, source: &str)

Add a local log entry.

pub fn add_remote(&self, entry: RemoteLogEntry)

Add a remote log entry received from a mesh peer.

pub fn add_remote_batch(&self, entries: Vec<RemoteLogEntry>)

Add a batch of remote log entries.

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

Query logs with optional filters, merged by timestamp.

pub fn entries_for_node(&self, node_id: &str) -> Vec<RemoteLogEntry>

Get all entries for a specific node.

pub fn total_entries(&self) -> usize

Total number of log entries across all nodes.

pub fn known_nodes(&self) -> Vec<String>

List all known node IDs.