Base interface for rate limiters. More...

#include <resource_manager.h>

Inheritance diagram for kcenon::monitoring::rate_limiter:

Collaboration diagram for kcenon::monitoring::rate_limiter:

Public Member Functions
virtual	~rate_limiter ()=default

virtual bool	try_acquire (size_t count=1)=0
	Try to acquire tokens.

template<typename Func >
auto	execute (Func &&func) -> decltype(func())
	Execute a function with rate limiting.

virtual const std::string &	get_name () const =0
	Get the name of this rate limiter.

Detailed Description

Base interface for rate limiters.

Definition at line 170 of file resource_manager.h.

Constructor & Destructor Documentation

◆ ~rate_limiter()

virtual kcenon::monitoring::rate_limiter::~rate_limiter ( )

virtualdefault

Member Function Documentation

◆ execute()

template<typename Func >

auto kcenon::monitoring::rate_limiter::execute ( Func && func ) -> decltype(func())

inline

Execute a function with rate limiting.

Template Parameters

Func	Function type that returns common::Result<T>

Parameters

func	Function to execute

Returns: Result of the function or error if rate limited

Definition at line 188 of file resource_manager.h.

                                                  {
        using result_type = decltype(func());
        using value_type = typename result_type::value_type;
 
        if (!try_acquire(1)) {
            return common::make_error<value_type>(static_cast<int>(monitoring_error_code::resource_exhausted),
                                          "Rate limit exceeded for '" + get_name() + "'");
        }
        return func();
    }