csle_collector.host_manager.threads package

Submodules

csle_collector.host_manager.threads.host_monitor_thread module

class csle_collector.host_manager.threads.host_monitor_thread.HostMonitorThread(kafka_ip: str, kafka_port: int, ip: str, hostname: str, time_step_len_seconds: int)[source]

Bases: threading.Thread

Thread that collects the Host statistics and pushes it to Kafka periodically

run() → None[source]

Main loop of the thread. Parses log files and metrics on the host and pushes it to Kafka periodically

Returns: None

Module contents