Example 6: Aggregating monitor pattern. More...

Inheritance diagram for aggregating_monitor:

Collaboration diagram for aggregating_monitor:

Public Member Functions
void	add_monitor (std::shared_ptr< IMonitor > monitor)

common::VoidResult	record_metric (const std::string &name, double value) override

common::VoidResult	record_metric (const std::string &name, double value, const std::unordered_map< std::string, std::string > &tags) override

common::Result< metrics_snapshot >	get_metrics () override

common::Result< health_check_result >	check_health () override

common::VoidResult	reset () override

size_t	monitor_count () const

Private Attributes
std::vector< std::shared_ptr< IMonitor > >	monitors_

std::mutex	mutex_

Detailed Description

Example 6: Aggregating monitor pattern.

Examples: monitor_factory_pattern_example.cpp.

Definition at line 301 of file monitor_factory_pattern_example.cpp.

Member Function Documentation

◆ add_monitor()

void aggregating_monitor::add_monitor ( std::shared_ptr< IMonitor > monitor )

inline

Examples: monitor_factory_pattern_example.cpp.

Definition at line 307 of file monitor_factory_pattern_example.cpp.

                                                      {
        std::lock_guard<std::mutex> lock(mutex_);
        monitors_.push_back(monitor);
    }

References monitors_, and mutex_.

◆ check_health()

common::Result< health_check_result > aggregating_monitor::check_health ( )

inlineoverride

Examples: monitor_factory_pattern_example.cpp.

Definition at line 351 of file monitor_factory_pattern_example.cpp.

                                                              {
        health_check_result result;
        result.timestamp = std::chrono::system_clock::now();
        result.status = health_status::healthy;
        result.message = "Aggregating monitor";
 
        return common::ok(std::move(result));
    }

References kcenon::monitoring::health_check_result::message, kcenon::monitoring::health_check_result::status, and kcenon::monitoring::health_check_result::timestamp.

◆ get_metrics()

common::Result< metrics_snapshot > aggregating_monitor::get_metrics ( )

inlineoverride

Examples: monitor_factory_pattern_example.cpp.

Definition at line 332 of file monitor_factory_pattern_example.cpp.

                                                          {
        std::lock_guard<std::mutex> lock(mutex_);
 
        metrics_snapshot combined;
        combined.source_id = "aggregating_monitor";
        combined.capture_time = std::chrono::system_clock::now();
 
        for (auto& monitor : monitors_) {
            auto result = monitor->get_metrics();
            if (result) {
                for (const auto& metric : result.value().metrics) {
                    combined.metrics.push_back(metric);
                }
            }
        }
 
        return common::ok(std::move(combined));
    }

References kcenon::monitoring::metrics_snapshot::capture_time, kcenon::monitoring::metrics_snapshot::metrics, monitors_, mutex_, kcenon::monitoring::metrics_snapshot::source_id, and kcenon::monitoring::metric::value.

◆ monitor_count()

size_t aggregating_monitor::monitor_count ( ) const

inline

Examples: monitor_factory_pattern_example.cpp.

Definition at line 368 of file monitor_factory_pattern_example.cpp.

                                 {
        std::lock_guard<std::mutex> lock(mutex_);
        return monitors_.size();
    }

References monitors_, and mutex_.

◆ record_metric() [1/2]

common::VoidResult aggregating_monitor::record_metric	(	const std::string &	name,
		double	value )

inlineoverride

Examples: monitor_factory_pattern_example.cpp.

Definition at line 312 of file monitor_factory_pattern_example.cpp.

                                                                                 {
        std::lock_guard<std::mutex> lock(mutex_);
        for (auto& monitor : monitors_) {
            monitor->record_metric(name, value);
        }
        return common::ok();
    }

References monitors_, and mutex_.

◆ record_metric() [2/2]

common::VoidResult aggregating_monitor::record_metric	(	const std::string &	name,
		double	value,
		const std::unordered_map< std::string, std::string > &	tags )

inlineoverride

Definition at line 320 of file monitor_factory_pattern_example.cpp.

    {
        std::lock_guard<std::mutex> lock(mutex_);
        for (auto& monitor : monitors_) {
            monitor->record_metric(name, value, tags);
        }
        return common::ok();
    }

References monitors_, and mutex_.

◆ reset()

common::VoidResult aggregating_monitor::reset ( )

inlineoverride

Examples: monitor_factory_pattern_example.cpp.

Definition at line 360 of file monitor_factory_pattern_example.cpp.

                                      {
        std::lock_guard<std::mutex> lock(mutex_);
        for (auto& monitor : monitors_) {
            monitor->reset();
        }
        return common::ok();
    }