kcenon::monitoring::circuit_breaker_registry Class Reference

Circuit breaker registry. More...

#include <fault_tolerance_manager.h>

Collaboration diagram for kcenon::monitoring::circuit_breaker_registry:

Public Member Functions
void	register_circuit_breaker (const std::string &name, std::shared_ptr< circuit_breaker > breaker)
std::shared_ptr< circuit_breaker >	get_circuit_breaker (const std::string &name)
void	remove_circuit_breaker (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::shared_ptr< circuit_breaker > >	registry_

Detailed Description

Circuit breaker registry.

Definition at line 270 of file fault_tolerance_manager.h.

Member Function Documentation

clear()

void kcenon::monitoring::circuit_breaker_registry::clear ( )

inline

Definition at line 301 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::circuit_breaker_registry::get_all_names ( ) const

inline

Definition at line 291 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_circuit_breaker()

std::shared_ptr< circuit_breaker > kcenon::monitoring::circuit_breaker_registry::get_circuit_breaker ( const std::string & name )

inline

Definition at line 277 of file fault_tolerance_manager.h.

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

References mutex_, and registry_.

register_circuit_breaker()

void kcenon::monitoring::circuit_breaker_registry::register_circuit_breaker ( const std::string & name, std::shared_ptr< circuit_breaker > breaker )

inline

Definition at line 272 of file fault_tolerance_manager.h.

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

References mutex_, and registry_.

remove_circuit_breaker()

void kcenon::monitoring::circuit_breaker_registry::remove_circuit_breaker ( const std::string & name )

inline

Definition at line 286 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::circuit_breaker_registry::mutex_

mutableprivate

Definition at line 307 of file fault_tolerance_manager.h.

Referenced by clear(), get_all_names(), get_circuit_breaker(), register_circuit_breaker(), and remove_circuit_breaker().

registry_

std::unordered_map<std::string, std::shared_ptr<circuit_breaker> > kcenon::monitoring::circuit_breaker_registry::registry_

private

Definition at line 308 of file fault_tolerance_manager.h.

Referenced by clear(), get_all_names(), get_circuit_breaker(), register_circuit_breaker(), and remove_circuit_breaker().

---

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

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