p2pfl.management.node_monitor module¶ Node monitor. class p2pfl.management.node_monitor.NodeMonitor(report_fn)[source]¶ Bases: Thread Node monitor thread. Parameters: node_addr – Node address. metric_report_callback – Metric report callback. get_logs()[source]¶ Get the logs. Return type: Dict[datetime, Dict[str, float]] run()[source]¶ Run the node monitor. Return type: None set_report_fn(report_fn)[source]¶ Set the report function. Return type: None stop()[source]¶ Stop the node monitor. Return type: None