Mock monitoring implementation for demonstration. More...

#include <mock_monitoring.h>

Inheritance diagram for mock_monitoring:

Collaboration diagram for mock_monitoring:

Classes
struct	monitoring_stats

Public Member Functions
	mock_monitoring ()

	~mock_monitoring ()

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

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

kcenon::common::Result< kcenon::common::interfaces::metrics_snapshot >	get_metrics () override

kcenon::common::Result< kcenon::common::interfaces::health_check_result >	check_health () override

kcenon::common::VoidResult	reset () override

bool	is_active () const

void	start ()

void	stop ()

monitoring_stats	get_stats () const

Private Member Functions
void	collect_loop ()

Private Attributes
kcenon::common::interfaces::metrics_snapshot	current_snapshot_

std::deque< kcenon::common::interfaces::metrics_snapshot >	history_

std::mutex	mutex_

std::atomic< bool >	active_

std::thread	collection_thread_

std::atomic< std::uint64_t >	total_collections_

const size_t	max_history_

Detailed Description

Mock monitoring implementation for demonstration.

In a real application, this would be replaced with: #include <monitoring_system/monitoring.h> using monitoring_module::monitoring;

Note: Issue #312: Updated to implement common::interfaces::IMonitor

Definition at line 23 of file mock_monitoring.h.

Constructor & Destructor Documentation

◆ mock_monitoring()

mock_monitoring::mock_monitoring ( )

inline

Definition at line 25 of file mock_monitoring.h.

        : active_(false)
        , total_collections_(0)
        , max_history_(100) {
    }

◆ ~mock_monitoring()

mock_monitoring::~mock_monitoring ( )

inline

Definition at line 31 of file mock_monitoring.h.

                       {
        stop();
    }

References stop().

Here is the call graph for this function:

Member Function Documentation

◆ check_health()

kcenon::common::Result< kcenon::common::interfaces::health_check_result > mock_monitoring::check_health ( )

inlineoverride

Definition at line 57 of file mock_monitoring.h.

                                                                                          {
        kcenon::common::interfaces::health_check_result result;
        result.status = active_.load()
            ? kcenon::common::interfaces::health_status::healthy
            : kcenon::common::interfaces::health_status::unknown;
        result.message = active_.load() ? "Monitoring active" : "Monitoring inactive";
        return kcenon::common::ok(result);
    }

References active_.

◆ collect_loop()

void mock_monitoring::collect_loop ( )

inlineprivate

Definition at line 103 of file mock_monitoring.h.

                        {
        while (active_.load()) {
            std::this_thread::sleep_for(std::chrono::milliseconds(500));
 
            if (active_.load()) {
                std::lock_guard<std::mutex> lock(mutex_);
 
                // Store snapshot in history
                history_.push_back(current_snapshot_);
                if (history_.size() > max_history_) {
                    history_.pop_front();
                }
 
                total_collections_.fetch_add(1);
            }
        }
    }

References active_, current_snapshot_, history_, max_history_, mutex_, and total_collections_.

Referenced by start().

Here is the caller graph for this function:

◆ get_metrics()

kcenon::common::Result< kcenon::common::interfaces::metrics_snapshot > mock_monitoring::get_metrics ( )

inlineoverride

Definition at line 52 of file mock_monitoring.h.

                                                                                      {
        std::lock_guard<std::mutex> lock(mutex_);
        return kcenon::common::ok(current_snapshot_);
    }

References current_snapshot_, and mutex_.

◆ get_stats()

monitoring_stats mock_monitoring::get_stats ( ) const

inline

Definition at line 98 of file mock_monitoring.h.

                                       {
        return {total_collections_.load()};
    }

References total_collections_.

◆ is_active()

bool mock_monitoring::is_active ( ) const

inline

Definition at line 74 of file mock_monitoring.h.

                           {
        return active_.load();
    }

References active_.

◆ record_metric() [1/2]

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

inlineoverride

Definition at line 35 of file mock_monitoring.h.

                                                                                       {
        std::lock_guard<std::mutex> lock(mutex_);
        current_snapshot_.add_metric(name, value);
        return kcenon::common::ok();
    }

References current_snapshot_, and mutex_.

◆ record_metric() [2/2]

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

inlineoverride

Definition at line 41 of file mock_monitoring.h.

                                                                     {
        std::lock_guard<std::mutex> lock(mutex_);
        kcenon::common::interfaces::metric_value mv(name, value);
        mv.tags = tags;
        current_snapshot_.metrics.push_back(mv);
        return kcenon::common::ok();
    }

References current_snapshot_, and mutex_.

◆ reset()

kcenon::common::VoidResult mock_monitoring::reset ( )

inlineoverride

Definition at line 66 of file mock_monitoring.h.

                                            {
        std::lock_guard<std::mutex> lock(mutex_);
        current_snapshot_ = {};
        history_.clear();
        total_collections_.store(0);
        return kcenon::common::ok();
    }

References current_snapshot_, history_, mutex_, and total_collections_.

◆ start()

void mock_monitoring::start ( )

inline

Definition at line 78 of file mock_monitoring.h.

                 {
        if (!active_.exchange(true)) {
            std::cout << "[MockMonitoring] Started" << std::endl;
            collection_thread_ = std::thread(&mock_monitoring::collect_loop, this);
        }
    }

References active_, collect_loop(), and collection_thread_.

Here is the call graph for this function:

◆ stop()

void mock_monitoring::stop ( )

inline

Definition at line 85 of file mock_monitoring.h.

                {
        if (active_.exchange(false)) {
            if (collection_thread_.joinable()) {
                collection_thread_.join();
            }
            std::cout << "[MockMonitoring] Stopped" << std::endl;
        }
    }

References active_, and collection_thread_.

Referenced by ~mock_monitoring().

Here is the caller graph for this function:

Member Data Documentation

◆ active_

std::atomic<bool> mock_monitoring::active_

private

Definition at line 126 of file mock_monitoring.h.

Referenced by check_health(), collect_loop(), is_active(), start(), and stop().

◆ collection_thread_

std::thread mock_monitoring::collection_thread_

private

Definition at line 127 of file mock_monitoring.h.

Referenced by start(), and stop().

◆ current_snapshot_

kcenon::common::interfaces::metrics_snapshot mock_monitoring::current_snapshot_

private

Definition at line 122 of file mock_monitoring.h.

Referenced by collect_loop(), get_metrics(), record_metric(), record_metric(), and reset().

◆ history_

std::deque<kcenon::common::interfaces::metrics_snapshot> mock_monitoring::history_

private

Definition at line 123 of file mock_monitoring.h.

Referenced by collect_loop(), and reset().

◆ max_history_

const size_t mock_monitoring::max_history_

private

Definition at line 129 of file mock_monitoring.h.

Referenced by collect_loop().

◆ mutex_

std::mutex mock_monitoring::mutex_

mutableprivate

Definition at line 124 of file mock_monitoring.h.

Referenced by collect_loop(), get_metrics(), record_metric(), record_metric(), and reset().

◆ total_collections_

std::atomic<std::uint64_t> mock_monitoring::total_collections_

private

Definition at line 128 of file mock_monitoring.h.

Referenced by collect_loop(), get_stats(), and reset().

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

examples/integration_example/mock_monitoring.h

Classes

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ mock_monitoring()

◆ ~mock_monitoring()

Member Function Documentation

◆ check_health()

◆ collect_loop()

◆ get_metrics()

◆ get_stats()

◆ is_active()

◆ record_metric() [1/2]

◆ record_metric() [2/2]

◆ reset()

◆ start()

◆ stop()

Member Data Documentation

◆ active_

◆ collection_thread_

◆ current_snapshot_

◆ history_

◆ max_history_

◆ mutex_

◆ total_collections_