inspector.plugins package

Submodules

inspector.plugins.no_inspector module

class inspector.plugins.no_inspector.NoInspector(consume_topic, produce_topics, config)

Bases: InspectorBase

inspect() → None

Executes the anomaly detection process with validation and fallback handling.

This method: 1. Validates that model configurations exist 2. Logs a warning if multiple models are configured (only first is used) 3. Retrieves the models through _get_models() 4. Calls inspect_anomalies() to perform the actual detection

Raises:

NotImplementedError – If no model configurations are provided

inspect_anomalies() → None

subnet_is_suspicious() → bool

inspector.plugins.stream_ad_inspector module

class inspector.plugins.stream_ad_inspector.StreamADInspector(consume_topic, produce_topics, config)

Bases: InspectorBase

inspect_anomalies()

subnet_is_suspicious() → bool