alertAggregator.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_RTCSUPERVISOR_ALERTAGGREGATOR_HPP
#define RTCTK_RTCSUPERVISOR_ALERTAGGREGATOR_HPP
 
#include "rtctk/componentFramework/alertServiceIf.hpp"
#include "rtctk/componentFramework/oldbIf.hpp"
 
#include <map>
#include <mutex>
#include <string>
 
namespace rtctk::rtcSupervisor {
 
class AlertAggregator {
public:
    using AlertServiceIf = componentFramework::AlertServiceIf;
    using AlertSource = componentFramework::AlertSource;
    using OldbIf = componentFramework::OldbIf;
    using ObjectList = std::vector<std::string>;
 
    AlertAggregator(AlertServiceIf& alerts, OldbIf& oldb, const ObjectList& objects);
    virtual ~AlertAggregator();
 
private:
    void OnAlertStatusChanged(const std::string& id, bool status);
 
    struct ObjectInfo {
        componentFramework::RepositorySubscriberIf::SubscriptionId subscription_id;
        AlertSource alert_source;
    };
 
    AlertServiceIf& m_alerts;
    OldbIf& m_oldb;
    std::mutex m_mutex;
    std::map<std::string, ObjectInfo> m_objects;
};
 
}  // namespace rtctk::rtcSupervisor
 
#endif  // RTCTK_RTCSUPERVISOR_STATUSESTIMATOR_HPP