Trigger based on statistical anomaly detection. More...

#include <alert_triggers.h>

Inheritance diagram for kcenon::monitoring::anomaly_trigger:

Collaboration diagram for kcenon::monitoring::anomaly_trigger:

Public Member Functions
	anomaly_trigger (double sensitivity=3.0, size_t window_size=100, size_t min_samples=10)
	Construct an anomaly trigger.

bool	evaluate (double value) const override
	Evaluate the trigger condition.

std::string	type_name () const override
	Get trigger type name.

std::string	description () const override
	Get human-readable description.

double	current_mean () const
	Get current mean of historical values.

double	current_stddev () const
	Get current standard deviation.

void	reset ()
	Clear historical data.

Public Member Functions inherited from kcenon::monitoring::alert_trigger
virtual	~alert_trigger ()=default

Private Member Functions
double	mean () const

double	standard_deviation (double mean_val) const

Private Attributes
double	sensitivity_

size_t	window_size_

size_t	min_samples_

std::mutex	mutex_

std::deque< double >	history_

Detailed Description

Trigger based on statistical anomaly detection.

Uses statistical methods to detect values that deviate significantly from normal behavior. Maintains a sliding window of historical values and triggers when the current value exceeds a configurable number of standard deviations from the mean.

Definition at line 392 of file alert_triggers.h.

Constructor & Destructor Documentation

◆ anomaly_trigger()

kcenon::monitoring::anomaly_trigger::anomaly_trigger	(	double	sensitivity = 3.0,
		size_t	window_size = 100,
		size_t	min_samples = 10 )

inlineexplicit

Construct an anomaly trigger.

Parameters

sensitivity	Number of standard deviations for anomaly
window_size	Number of samples for baseline calculation
min_samples	Minimum samples before detection starts

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 400 of file alert_triggers.h.

        : sensitivity_(sensitivity)
        , window_size_(window_size)
        , min_samples_(min_samples) {}

Member Function Documentation

◆ current_mean()

double kcenon::monitoring::anomaly_trigger::current_mean ( ) const

inline

Get current mean of historical values.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 447 of file alert_triggers.h.

                                {
        std::lock_guard<std::mutex> lock(mutex_);
        return mean();
    }

References mean(), and mutex_.

Here is the call graph for this function:

◆ current_stddev()

double kcenon::monitoring::anomaly_trigger::current_stddev ( ) const

inline

Get current standard deviation.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 455 of file alert_triggers.h.

                                  {
        std::lock_guard<std::mutex> lock(mutex_);
        return standard_deviation(mean());
    }

References mean(), mutex_, and standard_deviation().

Here is the call graph for this function:

◆ description()

std::string kcenon::monitoring::anomaly_trigger::description ( ) const

inlineoverridevirtual

Get human-readable description.

Returns: Description string

Implements kcenon::monitoring::alert_trigger.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 440 of file alert_triggers.h.

                                           {
        return "value > " + std::to_string(sensitivity_) + " std devs from mean";
    }

References sensitivity_.

◆ evaluate()

bool kcenon::monitoring::anomaly_trigger::evaluate ( double value ) const

inlineoverridevirtual

Evaluate the trigger condition.

Parameters

value Current metric value

Returns: True if trigger condition is met

Implements kcenon::monitoring::alert_trigger.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 407 of file alert_triggers.h.

                                               {
        std::lock_guard<std::mutex> lock(mutex_);
 
        // Add to history
        if (history_.size() >= window_size_) {
            history_.pop_front();
        }
        history_.push_back(value);
 
        // Need minimum samples for statistics
        if (history_.size() < min_samples_) {
            return false;
        }
 
        // Calculate statistics
        double mean_val = mean();
        double stddev = standard_deviation(mean_val);
 
        // Avoid division by zero or very small stddev
        if (stddev < 1e-10) {
            return false;
        }
 
        // Calculate z-score
        double z_score = std::abs(value - mean_val) / stddev;
 
        return z_score > sensitivity_;
    }

References history_, mean(), min_samples_, mutex_, sensitivity_, standard_deviation(), and window_size_.

Here is the call graph for this function:

◆ mean()

double kcenon::monitoring::anomaly_trigger::mean ( ) const

inlineprivate

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 469 of file alert_triggers.h.

                        {
        if (history_.empty()) {
            return 0.0;
        }
        double sum = std::accumulate(history_.begin(), history_.end(), 0.0);
        return sum / static_cast<double>(history_.size());
    }

References history_.

Referenced by current_mean(), current_stddev(), and evaluate().

Here is the caller graph for this function:

◆ reset()

void kcenon::monitoring::anomaly_trigger::reset ( )

inline

Clear historical data.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 463 of file alert_triggers.h.

                 {
        std::lock_guard<std::mutex> lock(mutex_);
        history_.clear();
    }

References history_, and mutex_.

◆ standard_deviation()

double kcenon::monitoring::anomaly_trigger::standard_deviation ( double mean_val ) const

inlineprivate

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 477 of file alert_triggers.h.

                                                     {
        if (history_.size() < 2) {
            return 0.0;
        }
        double sq_sum = 0.0;
        for (double val : history_) {
            double diff = val - mean_val;
            sq_sum += diff * diff;
        }
        return std::sqrt(sq_sum / static_cast<double>(history_.size() - 1));
    }

References history_.

Referenced by current_stddev(), and evaluate().

Here is the caller graph for this function:

◆ type_name()

std::string kcenon::monitoring::anomaly_trigger::type_name ( ) const

inlineoverridevirtual

Get trigger type name.

Returns: Type name string

Implements kcenon::monitoring::alert_trigger.

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 436 of file alert_triggers.h.

                                         {
        return "anomaly";
    }

Member Data Documentation

◆ history_

std::deque<double> kcenon::monitoring::anomaly_trigger::history_

mutableprivate

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 494 of file alert_triggers.h.

Referenced by evaluate(), mean(), reset(), and standard_deviation().

◆ min_samples_

size_t kcenon::monitoring::anomaly_trigger::min_samples_

private

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 491 of file alert_triggers.h.

Referenced by evaluate().

◆ mutex_

std::mutex kcenon::monitoring::anomaly_trigger::mutex_

mutableprivate

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 493 of file alert_triggers.h.

Referenced by current_mean(), current_stddev(), evaluate(), and reset().

◆ sensitivity_

double kcenon::monitoring::anomaly_trigger::sensitivity_

private

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 489 of file alert_triggers.h.

Referenced by description(), and evaluate().

◆ window_size_

size_t kcenon::monitoring::anomaly_trigger::window_size_

private

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_triggers.h.

Definition at line 490 of file alert_triggers.h.

Referenced by evaluate().

The documentation for this class was generated from the following file:

include/kcenon/monitoring/alert/alert_triggers.h

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ anomaly_trigger()

Member Function Documentation

◆ current_mean()

◆ current_stddev()

◆ description()

◆ evaluate()

◆ mean()

◆ reset()

◆ standard_deviation()

◆ type_name()

Member Data Documentation

◆ history_

◆ min_samples_

◆ mutex_

◆ sensitivity_

◆ window_size_