p2pfl.management.node_monitor moduleΒΆ

Node monitor.

class p2pfl.management.node_monitor.NodeMonitor(node_addr, metric_report_callback)[source]ΒΆ

Bases: Thread

Node monitor thread.

Parameters:
  • node_addr – Node address.

  • metric_report_callback – Metric report callback.

run()[source]ΒΆ

Run the node monitor.

Return type:

None

stop()[source]ΒΆ

Stop the node monitor.

Return type:

None