kcenon::monitoring::retry_executor_registry Class Reference

Retry executor registry. More...

#include <fault_tolerance_manager.h>

Collaboration diagram for kcenon::monitoring::retry_executor_registry:

Public Member Functions
template<typename T >
void	register_executor (const std::string &name, std::shared_ptr< retry_executor< T > > executor)
template<typename T >
std::shared_ptr< retry_executor< T > >	get_executor (const std::string &name)
void	remove_executor (const std::string &name)
std::vector< std::string >	get_all_names () const
void	clear ()

Private Attributes
std::mutex	mutex_
std::unordered_map< std::string, std::any >	registry_

Detailed Description

Retry executor registry.

Definition at line 314 of file fault_tolerance_manager.h.

Member Function Documentation

clear()

void kcenon::monitoring::retry_executor_registry::clear ( )

inline

Definition at line 347 of file fault_tolerance_manager.h.

                 {
        std::lock_guard<std::mutex> lock(mutex_);
        registry_.clear();
    }

References mutex_, and registry_.

Referenced by FaultToleranceTest::TearDown().

Here is the caller graph for this function:

get_all_names()

std::vector< std::string > kcenon::monitoring::retry_executor_registry::get_all_names ( ) const

inline

Definition at line 337 of file fault_tolerance_manager.h.

                                               {
        std::lock_guard<std::mutex> lock(mutex_);
        std::vector<std::string> names;
        names.reserve(registry_.size());
        for (const auto& pair : registry_) {
            names.push_back(pair.first);
        }
        return names;
    }

References mutex_, and registry_.

get_executor()

template<typename T >

std::shared_ptr< retry_executor< T > > kcenon::monitoring::retry_executor_registry::get_executor ( const std::string & name )

inline

Definition at line 323 of file fault_tolerance_manager.h.

                                                                         {
        std::lock_guard<std::mutex> lock(mutex_);
        auto it = registry_.find(name);
        if (it != registry_.end()) {
            return std::any_cast<std::shared_ptr<retry_executor<T>>>(it->second);
        }
        return nullptr;
    }

References mutex_, and registry_.

register_executor()

template<typename T >

void kcenon::monitoring::retry_executor_registry::register_executor ( const std::string & name, std::shared_ptr< retry_executor< T > > executor )

inline

Definition at line 317 of file fault_tolerance_manager.h.

                                                                                             {
        std::lock_guard<std::mutex> lock(mutex_);
        registry_[name] = std::move(executor);
    }

References mutex_, and registry_.

remove_executor()

void kcenon::monitoring::retry_executor_registry::remove_executor ( const std::string & name )

inline

Definition at line 332 of file fault_tolerance_manager.h.

                                                {
        std::lock_guard<std::mutex> lock(mutex_);
        registry_.erase(name);
    }

References mutex_, and registry_.

Member Data Documentation

mutex_

std::mutex kcenon::monitoring::retry_executor_registry::mutex_

mutableprivate

Definition at line 353 of file fault_tolerance_manager.h.

Referenced by clear(), get_all_names(), get_executor(), register_executor(), and remove_executor().

registry_

std::unordered_map<std::string, std::any> kcenon::monitoring::retry_executor_registry::registry_

private

Definition at line 354 of file fault_tolerance_manager.h.

Referenced by clear(), get_all_names(), get_executor(), register_executor(), and remove_executor().

---

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

• include/kcenon/monitoring/reliability/fault_tolerance_manager.h