Sends alerts to multiple notifiers. More...

#include <alert_notifiers.h>

Inheritance diagram for kcenon::monitoring::multi_notifier:

Collaboration diagram for kcenon::monitoring::multi_notifier:

Public Member Functions
	multi_notifier (std::string notifier_name)
	Construct with name.

void	add_notifier (std::shared_ptr< alert_notifier > notifier)
	Add a child notifier.

std::string	name () const override
	Get notifier name.

common::VoidResult	notify (const alert &a) override
	Send a notification for an alert.

common::VoidResult	notify_group (const alert_group &group) override
	Send a notification for an alert group.

bool	is_ready () const override
	Check if notifier is ready.

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

Static Private Member Functions
static std::string	join_strings (const std::vector< std::string > &strings, const std::string &delimiter)

Private Attributes
std::string	name_

std::mutex	mutex_

std::vector< std::shared_ptr< alert_notifier > >	notifiers_

Detailed Description

Sends alerts to multiple notifiers.

Wraps multiple notifiers and sends alerts to all of them. Collects results from all notifiers.

Definition at line 365 of file alert_notifiers.h.

Constructor & Destructor Documentation

◆ multi_notifier()

kcenon::monitoring::multi_notifier::multi_notifier ( std::string notifier_name )

inlineexplicit

Construct with name.

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

Definition at line 370 of file alert_notifiers.h.

371 : name_(std::move(notifier_name)) {}

kcenon::monitoring::multi_notifier::name_

std::string name_

Definition alert_notifiers.h:439

Member Function Documentation

◆ add_notifier()

void kcenon::monitoring::multi_notifier::add_notifier ( std::shared_ptr< alert_notifier > notifier )

inline

Add a child notifier.

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

Definition at line 376 of file alert_notifiers.h.

                                                              {
        std::lock_guard<std::mutex> lock(mutex_);
        notifiers_.push_back(std::move(notifier));
    }

References mutex_, and notifiers_.

◆ is_ready()

bool kcenon::monitoring::multi_notifier::is_ready ( ) const

inlineoverridevirtual

Check if notifier is ready.

Returns: True if ready to send notifications

Implements kcenon::monitoring::alert_notifier.

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

Definition at line 423 of file alert_notifiers.h.

                                   {
        std::lock_guard<std::mutex> lock(mutex_);
        return !notifiers_.empty();
    }

References mutex_, and notifiers_.

◆ join_strings()

static std::string kcenon::monitoring::multi_notifier::join_strings	(	const std::vector< std::string > &	strings,
		const std::string &	delimiter )

inlinestaticprivate

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

Definition at line 429 of file alert_notifiers.h.

                                                                {
        std::ostringstream oss;
        for (size_t i = 0; i < strings.size(); ++i) {
            if (i > 0) oss << delimiter;
            oss << strings[i];
        }
        return oss.str();
    }

Referenced by notify(), and notify_group().

Here is the caller graph for this function:

◆ name()

std::string kcenon::monitoring::multi_notifier::name ( ) const

inlineoverridevirtual

Get notifier name.

Returns: Notifier name

Implements kcenon::monitoring::alert_notifier.

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

Definition at line 381 of file alert_notifiers.h.

381{ return name_; }

References name_.

◆ notify()

common::VoidResult kcenon::monitoring::multi_notifier::notify ( const alert & a )

inlineoverridevirtual

Send a notification for an alert.

Parameters

a	Alert to notify about

Returns: Result indicating success or failure

Implements kcenon::monitoring::alert_notifier.

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

Definition at line 383 of file alert_notifiers.h.

                                                     {
        std::lock_guard<std::mutex> lock(mutex_);
 
        std::vector<std::string> failures;
        for (const auto& notifier : notifiers_) {
            if (notifier && notifier->is_ready()) {
                auto result = notifier->notify(a);
                if (!result.is_ok()) {
                    failures.push_back(notifier->name());
                }
            }
        }
 
        if (!failures.empty()) {
            return common::VoidResult::err(static_cast<int>(monitoring_error_code::operation_failed),
                                   "Failed notifiers: " + join_strings(failures, ", "));
        }
        return common::ok();
    }

References join_strings(), mutex_, notifiers_, and kcenon::monitoring::operation_failed.

Here is the call graph for this function:

◆ notify_group()

common::VoidResult kcenon::monitoring::multi_notifier::notify_group ( const alert_group & group )

inlineoverridevirtual

Send a notification for an alert group.

Parameters

group Alert group to notify about

Returns: Result indicating success or failure

Implements kcenon::monitoring::alert_notifier.

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

Definition at line 403 of file alert_notifiers.h.

                                                                     {
        std::lock_guard<std::mutex> lock(mutex_);
 
        std::vector<std::string> failures;
        for (const auto& notifier : notifiers_) {
            if (notifier && notifier->is_ready()) {
                auto result = notifier->notify_group(group);
                if (!result.is_ok()) {
                    failures.push_back(notifier->name());
                }
            }
        }
 
        if (!failures.empty()) {
            return common::VoidResult::err(static_cast<int>(monitoring_error_code::operation_failed),
                                   "Failed notifiers: " + join_strings(failures, ", "));
        }
        return common::ok();
    }