kcenon::monitoring::alert_deduplicator Class Reference

Deduplicates alerts based on fingerprint. More...

#include <alert_pipeline.h>

Collaboration diagram for kcenon::monitoring::alert_deduplicator:

Public Member Functions
	alert_deduplicator (std::chrono::milliseconds cache_duration)
	Construct with cache duration.
bool	is_duplicate (const alert &a)
	Check if alert is a duplicate.
void	mark_seen (const alert &a)
	Mark alert as seen.
void	reset ()
	Clear deduplication cache.

Private Member Functions
void	cleanup_expired ()

Private Attributes
std::chrono::milliseconds	cache_duration_
std::mutex	mutex_
std::unordered_map< std::string, std::chrono::steady_clock::time_point >	seen_
std::unordered_map< std::string, alert_state >	last_state_

Detailed Description

Deduplicates alerts based on fingerprint.

Maintains a cache of recently seen alerts to prevent duplicate notifications for the same alert condition.

Examples

alert_pipeline_example.cpp.

Definition at line 511 of file alert_pipeline.h.

Constructor & Destructor Documentation

alert_deduplicator()

kcenon::monitoring::alert_deduplicator::alert_deduplicator ( std::chrono::milliseconds cache_duration )

inlineexplicit

Construct with cache duration.

Parameters

cache_duration

How long to remember alerts

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 517 of file alert_pipeline.h.

        : cache_duration_(cache_duration) {}

Member Function Documentation

cleanup_expired()

void kcenon::monitoring::alert_deduplicator::cleanup_expired ( )

inlineprivate

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 569 of file alert_pipeline.h.

                           {
        auto now = std::chrono::steady_clock::now();
        for (auto it = seen_.begin(); it != seen_.end(); ) {
            if (now - it->second > cache_duration_) {
                last_state_.erase(it->first);
                it = seen_.erase(it);
            } else {
                ++it;
            }
        }
    }

References cache_duration_, last_state_, and seen_.

Referenced by is_duplicate().

Here is the caller graph for this function:

is_duplicate()

bool kcenon::monitoring::alert_deduplicator::is_duplicate ( const alert & a )

inline

Check if alert is a duplicate.

Parameters

a	Alert to check

Returns

True if duplicate

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 525 of file alert_pipeline.h.

                                      {
        std::lock_guard<std::mutex> lock(mutex_);
 
        cleanup_expired();
 
        auto fingerprint = a.fingerprint();
        auto it = seen_.find(fingerprint);
 
        if (it == seen_.end()) {
            seen_[fingerprint] = std::chrono::steady_clock::now();
            return false;
        }
 
        // Same state is duplicate
        auto state_it = last_state_.find(fingerprint);
        if (state_it != last_state_.end() && state_it->second == a.state) {
            return true;
        }
 
        // State changed - not duplicate
        last_state_[fingerprint] = a.state;
        return false;
    }

References cleanup_expired(), kcenon::monitoring::alert::fingerprint(), last_state_, mutex_, seen_, and kcenon::monitoring::alert::state.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

mark_seen()

void kcenon::monitoring::alert_deduplicator::mark_seen ( const alert & a )

inline

Mark alert as seen.

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 552 of file alert_pipeline.h.

                                   {
        std::lock_guard<std::mutex> lock(mutex_);
        auto fingerprint = a.fingerprint();
        seen_[fingerprint] = std::chrono::steady_clock::now();
        last_state_[fingerprint] = a.state;
    }

References kcenon::monitoring::alert::fingerprint(), last_state_, mutex_, seen_, and kcenon::monitoring::alert::state.

Here is the call graph for this function:

reset()

void kcenon::monitoring::alert_deduplicator::reset ( )

inline

Clear deduplication cache.

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 562 of file alert_pipeline.h.

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

References last_state_, mutex_, and seen_.

Referenced by main().

Here is the caller graph for this function:

Member Data Documentation

cache_duration_

std::chrono::milliseconds kcenon::monitoring::alert_deduplicator::cache_duration_

private

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 581 of file alert_pipeline.h.

Referenced by cleanup_expired().

last_state_

std::unordered_map<std::string, alert_state> kcenon::monitoring::alert_deduplicator::last_state_

private

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 584 of file alert_pipeline.h.

Referenced by cleanup_expired(), is_duplicate(), mark_seen(), and reset().

mutex_

std::mutex kcenon::monitoring::alert_deduplicator::mutex_

mutableprivate

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 582 of file alert_pipeline.h.

Referenced by is_duplicate(), mark_seen(), and reset().

seen_

std::unordered_map<std::string, std::chrono::steady_clock::time_point> kcenon::monitoring::alert_deduplicator::seen_

private

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/alert/alert_pipeline.h.

Definition at line 583 of file alert_pipeline.h.

Referenced by cleanup_expired(), is_duplicate(), mark_seen(), and reset().

---

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

• include/kcenon/monitoring/alert/alert_pipeline.h