Coordinates multiple resource management components. More...

#include <resource_manager.h>

Collaboration diagram for kcenon::monitoring::resource_manager:

Public Member Functions
	resource_manager (const std::string &name)

common::Result< bool >	add_rate_limiter (const std::string &name, const rate_limit_config &config)
	Add a rate limiter.

rate_limiter *	get_rate_limiter (const std::string &name)
	Get a rate limiter by name.

common::Result< bool >	add_memory_quota (const std::string &name, const resource_quota &quota)
	Add a memory quota manager.

memory_quota_manager *	get_memory_quota (const std::string &name)
	Get a memory quota manager by name.

common::Result< bool >	add_cpu_throttler (const std::string &name, const cpu_throttle_config &config)
	Add a CPU throttler.

cpu_throttler *	get_cpu_throttler (const std::string &name)
	Get a CPU throttler by name.

common::Result< bool >	is_healthy () const
	Check if all resources are healthy.

std::unordered_map< std::string, resource_metrics >	get_all_metrics () const
	Get metrics for all managed resources.

Private Attributes
std::string	name_

std::unordered_map< std::string, std::unique_ptr< rate_limiter > >	rate_limiters_

std::unordered_map< std::string, std::unique_ptr< memory_quota_manager > >	memory_quotas_

std::unordered_map< std::string, std::unique_ptr< cpu_throttler > >	cpu_throttlers_

std::mutex	mutex_

Detailed Description

Coordinates multiple resource management components.

Definition at line 459 of file resource_manager.h.

Constructor & Destructor Documentation

◆ resource_manager()

kcenon::monitoring::resource_manager::resource_manager ( const std::string & name )

inlineexplicit

Definition at line 461 of file resource_manager.h.

461: name_(name) {}

kcenon::monitoring::resource_manager::name_

std::string name_

Definition resource_manager.h:591

Member Function Documentation

◆ add_cpu_throttler()

common::Result< bool > kcenon::monitoring::resource_manager::add_cpu_throttler	(	const std::string &	name,
		const cpu_throttle_config &	config )

inline

Add a CPU throttler.

Parameters

name	Name for the throttler
config	CPU throttle configuration

Returns: Success or error if name already exists

Definition at line 528 of file resource_manager.h.

                                                                                                   {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (cpu_throttlers_.find(name) != cpu_throttlers_.end()) {
            return common::make_error<bool>(static_cast<int>(monitoring_error_code::already_exists),
                                   "CPU throttler '" + name + "' already exists");
        }
 
        cpu_throttlers_[name] = std::make_unique<cpu_throttler>(name, config);
        return common::ok(true);
    }

References kcenon::monitoring::already_exists, cpu_throttlers_, and mutex_.

◆ add_memory_quota()

common::Result< bool > kcenon::monitoring::resource_manager::add_memory_quota	(	const std::string &	name,
		const resource_quota &	quota )

inline

Add a memory quota manager.

Parameters

name	Name for the manager
quota	Resource quota configuration

Returns: Success or error if name already exists

Definition at line 499 of file resource_manager.h.

                                                                                            {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (memory_quotas_.find(name) != memory_quotas_.end()) {
            return common::make_error<bool>(static_cast<int>(monitoring_error_code::already_exists),
                                   "Memory quota '" + name + "' already exists");
        }
 
        memory_quotas_[name] = std::make_unique<memory_quota_manager>(name, quota);
        return common::ok(true);
    }

References kcenon::monitoring::already_exists, memory_quotas_, and mutex_.

◆ add_rate_limiter()

common::Result< bool > kcenon::monitoring::resource_manager::add_rate_limiter	(	const std::string &	name,
		const rate_limit_config &	config )

inline

Add a rate limiter.

Parameters

name	Name for the limiter
config	Rate limit configuration

Returns: Success or error if name already exists

Definition at line 469 of file resource_manager.h.

                                                                                                {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (rate_limiters_.find(name) != rate_limiters_.end()) {
            return common::make_error<bool>(static_cast<int>(monitoring_error_code::already_exists),
                                   "Rate limiter '" + name + "' already exists");
        }
 
        rate_limiters_[name] = std::make_unique<token_bucket_limiter>(
            name, config.rate_per_second, config.burst_capacity, config.strategy);
        return common::ok(true);
    }

References kcenon::monitoring::already_exists, kcenon::monitoring::rate_limit_config::burst_capacity, mutex_, rate_limiters_, kcenon::monitoring::rate_limit_config::rate_per_second, and kcenon::monitoring::rate_limit_config::strategy.

◆ get_all_metrics()

std::unordered_map< std::string, resource_metrics > kcenon::monitoring::resource_manager::get_all_metrics ( ) const

inline

Get metrics for all managed resources.

Returns: Map of resource name to metrics

Definition at line 571 of file resource_manager.h.

                                                                          {
        std::lock_guard<std::mutex> lock(mutex_);
        std::unordered_map<std::string, resource_metrics> all_metrics;
 
        for (const auto& [name, limiter] : rate_limiters_) {
            all_metrics["rate_" + name] = resource_metrics{};
        }
 
        for (const auto& [name, manager] : memory_quotas_) {
            all_metrics["memory_" + name] = manager->get_metrics();
        }
 
        for (const auto& [name, throttler] : cpu_throttlers_) {
            all_metrics["cpu_" + name] = throttler->get_metrics();
        }
 
        return all_metrics;
    }

References cpu_throttlers_, memory_quotas_, mutex_, and rate_limiters_.

◆ get_cpu_throttler()

cpu_throttler * kcenon::monitoring::resource_manager::get_cpu_throttler ( const std::string & name )

inline

Get a CPU throttler by name.

Parameters

name	Name of the throttler

Returns: Pointer to the throttler or nullptr if not found

Definition at line 545 of file resource_manager.h.

                                                            {
        std::lock_guard<std::mutex> lock(mutex_);
        auto it = cpu_throttlers_.find(name);
        return it != cpu_throttlers_.end() ? it->second.get() : nullptr;
    }

References cpu_throttlers_, and mutex_.

◆ get_memory_quota()

memory_quota_manager * kcenon::monitoring::resource_manager::get_memory_quota ( const std::string & name )

inline

Get a memory quota manager by name.

Parameters

name	Name of the manager

Returns: Pointer to the manager or nullptr if not found

Definition at line 516 of file resource_manager.h.

                                                                  {
        std::lock_guard<std::mutex> lock(mutex_);
        auto it = memory_quotas_.find(name);
        return it != memory_quotas_.end() ? it->second.get() : nullptr;
    }

References memory_quotas_, and mutex_.

◆ get_rate_limiter()

rate_limiter * kcenon::monitoring::resource_manager::get_rate_limiter ( const std::string & name )

inline

Get a rate limiter by name.

Parameters

name	Name of the limiter

Returns: Pointer to the limiter or nullptr if not found

Definition at line 487 of file resource_manager.h.

                                                          {
        std::lock_guard<std::mutex> lock(mutex_);
        auto it = rate_limiters_.find(name);
        return it != rate_limiters_.end() ? it->second.get() : nullptr;
    }

References mutex_, and rate_limiters_.

◆ is_healthy()

common::Result< bool > kcenon::monitoring::resource_manager::is_healthy ( ) const

inline

Check if all resources are healthy.

Returns: Success with health status

Definition at line 555 of file resource_manager.h.

                                          {
        std::lock_guard<std::mutex> lock(mutex_);
 
        for (const auto& [name, manager] : memory_quotas_) {
            if (manager->is_over_critical_threshold()) {
                return common::ok(false);
            }
        }
 
        return common::ok(true);
    }

References memory_quotas_, and mutex_.

Member Data Documentation

◆ cpu_throttlers_

std::unordered_map<std::string, std::unique_ptr<cpu_throttler> > kcenon::monitoring::resource_manager::cpu_throttlers_

private

Definition at line 594 of file resource_manager.h.

Referenced by add_cpu_throttler(), get_all_metrics(), and get_cpu_throttler().

◆ memory_quotas_

std::unordered_map<std::string, std::unique_ptr<memory_quota_manager> > kcenon::monitoring::resource_manager::memory_quotas_

private

Definition at line 593 of file resource_manager.h.

Referenced by add_memory_quota(), get_all_metrics(), get_memory_quota(), and is_healthy().

◆ mutex_

std::mutex kcenon::monitoring::resource_manager::mutex_

mutableprivate

Definition at line 595 of file resource_manager.h.

Referenced by add_cpu_throttler(), add_memory_quota(), add_rate_limiter(), get_all_metrics(), get_cpu_throttler(), get_memory_quota(), get_rate_limiter(), and is_healthy().

◆ name_

std::string kcenon::monitoring::resource_manager::name_

private

Definition at line 591 of file resource_manager.h.

◆ rate_limiters_

std::unordered_map<std::string, std::unique_ptr<rate_limiter> > kcenon::monitoring::resource_manager::rate_limiters_

private

Definition at line 592 of file resource_manager.h.

Referenced by add_rate_limiter(), get_all_metrics(), and get_rate_limiter().

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

include/kcenon/monitoring/reliability/resource_manager.h

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ resource_manager()

Member Function Documentation

◆ add_cpu_throttler()

◆ add_memory_quota()

◆ add_rate_limiter()

◆ get_all_metrics()

◆ get_cpu_throttler()

◆ get_memory_quota()

◆ get_rate_limiter()

◆ is_healthy()

Member Data Documentation

◆ cpu_throttlers_

◆ memory_quotas_

◆ mutex_

◆ name_

◆ rate_limiters_