Struct DistributedLogger 

pub struct DistributedLogger { /* private fields */ }

Distributed logger that coordinates with multiple nodes

Implementations

impl DistributedLogger

pub fn new( logger_name: &str, nodeid: NodeId, max_entries: usize, aggregation_window: Duration, default_rate_limit: f64, ) -> Self

Create a new distributed logger

pub fn log_adaptive( &self, level: LogLevel, message: &str, context: Option<HashMap<String, String>>, )

Log a message with adaptive rate limiting

pub fn error_adaptive(&self, message: &str)

Convenience methods for different log levels

pub fn warn_adaptive(&self, message: &str)

pub fn info_adaptive(&self, message: &str)

pub fn debug_adaptive(&self, message: &str)

pub fn get_aggregatedlogs(&self) -> Vec<DistributedLogEntry>

Get aggregated log entries

pub fn get_rate_stats(&self) -> HashMap<String, RateLimitStats>

Get rate limiting statistics for all loggers

pub fn get_aggregation_stats(&self) -> AggregationStats

Get aggregation statistics

pub fn exportlogs_json(&self) -> Result<String, Box<dyn Error>>

Export logs to JSON format

pub fn clear_aggregated_data(&self)

Clear all aggregated data