csle_collector.five_g_cu_manager.threads package

Submodules

csle_collector.five_g_cu_manager.threads.five_g_cu_monitor_thread module

class csle_collector.five_g_cu_manager.threads.five_g_cu_monitor_thread.FiveGCUMonitorThread(kafka_ip: str, kafka_port: int, ip: str, hostname: str, time_step_len_seconds: int, cu_port: int = 55556)

Bases: Thread

Thread that collects the 5G CU (Central Unit) 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

stop() → None

Stops the thread and closes the WebSocket :return: None

Module contents