Struct LogCollector 

pub struct LogCollector { /* private fields */ }

Log collector that subscribes to DDS log topics.

Implementations

impl LogCollector

pub fn new(config: LogConfig) -> Result<Self>

Create a new log collector.

pub fn stats(&self) -> &CollectorStats

Get collector statistics.

pub fn process(&mut self, entry: LogEntry) -> Result<()>

Process a single log entry.

pub fn flush(&mut self) -> Result<()>

Flush output.

pub fn is_running(&self) -> bool

Check if collector is running.

pub fn stop(&self)

Stop the collector.

pub fn stop_handle(&self) -> StopHandle

Get a handle to stop the collector from another thread.

pub fn run(&mut self) -> Result<()>

Run the collector (blocking).

This would subscribe to DDS topics and process incoming logs.

pub fn run_with_callback<F>(&mut self, callback: F) -> Result<()>

where F: FnMut(&LogEntry),

Run with a callback for each log entry (for testing/integration).