Struct LogAggregator 

pub struct LogAggregator { /* private fields */ }

Main log aggregator

Implementations

impl LogAggregator

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

pub async fn start(&self) -> RragResult<()>

pub async fn stop(&self) -> RragResult<()>

pub async fn is_healthy(&self) -> bool

pub fn logger(&self) -> &Arc<StructuredLogger>

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

pub async fn get_stats(&self) -> LogStats

pub fn subscribe_to_stream(&self) -> Receiver<LogEntry>

pub async fn add_log_entry(&self, entry: LogEntry) -> RragResult<()>

pub async fn log( &self, level: LogLevel, message: impl Into<String>, component: impl Into<String>, ) -> RragResult<()>

Convenience method for creating a log entry and adding it