csle_collector.snort_ids_manager.threads package

Submodules

csle_collector.snort_ids_manager.threads.snort_ids_monitor_thread module

class csle_collector.snort_ids_manager.threads.snort_ids_monitor_thread.SnortIDSMonitorThread(kafka_ip: str, kafka_port: int, ip: str, hostname: str, log_file_path: str, time_step_len_seconds: int)[source]

Bases: threading.Thread

Thread that collects the Snort IDS statistics and pushes it to Kafka periodically

run() → None[source]

Main loop of the thread. Parses the IDS log and pushes it to Kafka periodically

Returns: None

Module contents