csle_collector.five_g_du_manager.threads package

Submodules

csle_collector.five_g_du_manager.threads.five_g_du_monitor_thread module

class csle_collector.five_g_du_manager.threads.five_g_du_monitor_thread.FiveGDUMonitorThread(kafka_ip: str, kafka_port: int, ip: str, hostname: str, time_step_len_seconds: int, du_port: int = 55555)

Bases: Thread

Thread that collects the 5G DU statistics via WebSockets and pushes them to Kafka periodically.

run() → None

Main loop: 1. Starts the WS client in background. 2. Loops every time_step_len_seconds to push buffered metrics to Kafka.

Returns

None

Module contents