Index _ | A | B | C | D | E | F | G | H | I | K | L | M | N | O | P | R | S | T | V | W | X _ __del__() (base.kafka_handler.KafkaConsumeHandler method) (base.kafka_handler.KafkaProduceHandler method) __format__() (inspector.inspector.EnsembleModels method) (train.train.DatasetEnum method) (train.train.ModelEnum method) __init__() (base.clickhouse_kafka_sender.ClickHouseKafkaSender method) (base.kafka_handler.ExactlyOnceKafkaConsumeHandler method) (base.kafka_handler.ExactlyOnceKafkaProduceHandler method) (base.kafka_handler.KafkaConsumeHandler method) (base.kafka_handler.KafkaHandler method) (base.kafka_handler.KafkaProduceHandler method) (base.kafka_handler.SimpleKafkaConsumeHandler method) (base.kafka_handler.SimpleKafkaProduceHandler method) (monitoring.monitoring_agent.MonitoringAgent method) (train.dataset.Dataset method) (train.dataset.DatasetLoader method) (train.explainer.Explainer method) (train.explainer.Plotter method) (train.feature.Processor method) (train.model.Pipeline method) (train.train.DetectorTraining method) __len__() (train.dataset.Dataset method) A add() (monitoring.clickhouse_batch_sender.ClickHouseBatchSender method) add_message() (logcollector.batch_handler.BufferedBatch method) (logcollector.batch_handler.BufferedBatchSender method) add_options() (in module train.train) B bambenek_dataset (train.dataset.DatasetLoader property) base module base.clickhouse_kafka_sender module base.kafka_handler module base.log_config module base.logline_handler module base.utils module brokers (base.kafka_handler.KafkaConsumeHandler attribute) BufferedBatch (class in logcollector.batch_handler) (class in src.logcollector.batch_handler) BufferedBatchSender (class in logcollector.batch_handler) (class in src.logcollector.batch_handler) C cast_bambenek() (in module train.dataset) cast_cic() (in module train.dataset) cast_dga() (in module train.dataset) cast_dgarchive() (in module train.dataset) cast_dgta() (in module train.dataset) cast_heicloud() (in module train.dataset) check_relevance() (base.logline_handler.ListItem method) (base.logline_handler.LoglineHandler method) CIC (train.train.DatasetEnum attribute) cic_dataset (train.dataset.DatasetLoader property) clear_data() (detector.detector.Detector method) (inspector.inspector.Inspector method) (prefilter.prefilter.Prefilter method) ClickHouseBatchSender (class in monitoring.clickhouse_batch_sender) ClickHouseKafkaSender (class in base.clickhouse_kafka_sender) columns (monitoring.clickhouse_batch_sender.Table attribute) COMBINE (train.train.DatasetEnum attribute) commit_transaction_with_retry() (base.kafka_handler.ExactlyOnceKafkaProduceHandler method) complete_batch() (logcollector.batch_handler.BufferedBatch method) consume() (base.kafka_handler.ExactlyOnceKafkaConsumeHandler method) (base.kafka_handler.KafkaConsumeHandler method) (base.kafka_handler.SimpleKafkaConsumeHandler method) consume_as_json() (base.kafka_handler.KafkaConsumeHandler method) consume_as_object() (base.kafka_handler.ExactlyOnceKafkaConsumeHandler method) consumer (base.kafka_handler.KafkaConsumeHandler attribute) create_plots_binary() (train.explainer.Plotter method) create_plots_multiclass() (train.explainer.Plotter method) CustomHandler (class in base.log_config) D Dataset (class in train.dataset) DatasetEnum (class in train.train) DatasetLoader (class in train.dataset) detect() (detector.detector.Detector method) detector module Detector (class in detector.detector) (class in src.detector.detector) detector.detector module DetectorTraining (class in train.train) dga_dataset (train.dataset.DatasetLoader property) DGARCHIVE (train.train.DatasetEnum attribute) dgarchive_dataset (train.dataset.DatasetLoader property) DGTA (train.train.DatasetEnum attribute) dgta_dataset (train.dataset.DatasetLoader property) E EnsembleModels (class in inspector.inspector) ExactlyOnceKafkaConsumeHandler (class in base.kafka_handler) ExactlyOnceKafkaProduceHandler (class in base.kafka_handler) explain() (train.model.Pipeline method) (train.train.DetectorTraining method) Explainer (class in train.explainer) F fdr_metric() (train.model.Model method) (train.model.XGBoostModel method) fetch() (logcollector.collector.LogCollector method) fetch_from_file() (logserver.server.LogServer method) fetch_from_kafka() (logserver.server.LogServer method) FieldType (class in base.logline_handler) filter_by_error() (prefilter.prefilter.Prefilter method) format() (base.log_config.CustomHandler method) G GBM_CLASSIFIER (train.train.ModelEnum attribute) get_and_fill_data() (detector.detector.Detector method) (inspector.inspector.Inspector method) (prefilter.prefilter.Prefilter method) get_logger() (in module base.log_config) get_message_count_for_batch() (logcollector.batch_handler.BufferedBatch method) get_message_count_for_batch_key() (logcollector.batch_handler.BufferedBatch method) get_message_count_for_buffer() (logcollector.batch_handler.BufferedBatch method) get_message_count_for_buffer_key() (logcollector.batch_handler.BufferedBatch method) get_stored_keys() (logcollector.batch_handler.BufferedBatch method) get_timestamp_as_str() (base.logline_handler.Timestamp method) H heicloud_dataset (train.dataset.DatasetLoader property) hyperparam_fit() (train.model.Pipeline method) I insert() (base.clickhouse_kafka_sender.ClickHouseKafkaSender method) (monitoring.clickhouse_batch_sender.ClickHouseBatchSender method) insert_all() (monitoring.clickhouse_batch_sender.ClickHouseBatchSender method) inspect() (inspector.inspector.Inspector method) inspector module Inspector (class in inspector.inspector) (class in src.inspector.inspector) inspector.inspector module interpret_model() (train.explainer.Explainer method) IpAddress (class in base.logline_handler) K kafka_delivery_report() (in module base.utils) KafkaConsumeHandler (class in base.kafka_handler) KafkaHandler (class in base.kafka_handler) KafkaMessageFetchException KafkaProduceHandler (class in base.kafka_handler) L LightGBMModel (class in train.model) ListItem (class in base.logline_handler) load_config() (in module base.log_config) logcollector module LogCollector (class in logcollector.collector) (class in src.logcollector.collector) logcollector.batch_handler module logcollector.collector module LoglineHandler (class in base.logline_handler) logserver module LogServer (class in logserver.server) (class in src.logserver.server) logserver.server module M main() (in module detector.detector) (in module inspector.inspector) (in module logcollector.collector) (in module logserver.server) (in module monitoring.monitoring_agent) (in module prefilter.prefilter) Model (class in train.model) ModelEnum (class in train.train) module base base.clickhouse_kafka_sender base.kafka_handler base.log_config base.logline_handler base.utils detector detector.detector inspector inspector.inspector logcollector logcollector.batch_handler logcollector.collector logserver logserver.server monitoring monitoring.clickhouse_batch_sender monitoring.monitoring_agent prefilter prefilter.prefilter train train.dataset train.explainer train.feature train.model train.train version monitoring module monitoring.clickhouse_batch_sender module monitoring.monitoring_agent module MonitoringAgent (class in monitoring.monitoring_agent) N name (monitoring.clickhouse_batch_sender.Table attribute) normalize_ipv4_address() (in module base.utils) normalize_ipv6_address() (in module base.utils) O objective() (train.model.LightGBMModel method) (train.model.Model method) (train.model.RandomForestModel method) (train.model.XGBoostModel method) P Pipeline (class in train.model) Plotter (class in train.explainer) predict() (train.model.Model method) (train.model.Pipeline method) prefilter module Prefilter (class in prefilter.prefilter) (class in src.prefilter.prefilter) prefilter.prefilter module prepare_all_tables() (in module monitoring.monitoring_agent) preprocess() (in module train.dataset) Processor (class in train.feature) produce() (base.kafka_handler.ExactlyOnceKafkaProduceHandler method) (base.kafka_handler.KafkaProduceHandler method) (base.kafka_handler.SimpleKafkaProduceHandler method) R RANDOM_FOREST_CLASSIFIER (train.train.ModelEnum attribute) RandomForestModel (class in train.model) RegEx (class in base.logline_handler) S send() (logcollector.collector.LogCollector method) (logserver.server.LogServer method) send_data() (inspector.inspector.Inspector method) send_filtered_data() (prefilter.prefilter.Prefilter method) send_warning() (detector.detector.Detector method) setup_config() (in module base.utils) SimpleKafkaConsumeHandler (class in base.kafka_handler) SimpleKafkaProduceHandler (class in base.kafka_handler) start() (logcollector.collector.LogCollector method) (logserver.server.LogServer method) (monitoring.monitoring_agent.MonitoringAgent method) T Table (class in monitoring.clickhouse_batch_sender) test() (train.train.DetectorTraining method) Timestamp (class in base.logline_handler) TooManyFailedAttemptsError train module train() (train.model.LightGBMModel method) (train.model.Model method) (train.model.RandomForestModel method) (train.model.XGBoostModel method) (train.train.DetectorTraining method) train.dataset module train.explainer module train.feature module train.model module train.train module train_test_val_split() (train.model.Pipeline method) transform() (train.feature.Processor method) V validate() (base.logline_handler.FieldType method) (base.logline_handler.IpAddress method) (base.logline_handler.ListItem method) (base.logline_handler.RegEx method) (base.logline_handler.Timestamp method) validate_host() (in module base.utils) validate_logline() (base.logline_handler.LoglineHandler method) validate_logline_and_get_fields_as_json() (base.logline_handler.LoglineHandler method) validate_port() (in module base.utils) verify() (monitoring.clickhouse_batch_sender.Table method) version module VOTE (inspector.inspector.EnsembleModels attribute) W WEIGHT (inspector.inspector.EnsembleModels attribute) WrongChecksum X XG_BOOST_CLASSIFIER (train.train.ModelEnum attribute) XGBoostModel (class in train.model)
