AlertManager.h

Go to the documentation of this file.

#pragma once
#include "Common.h"
#include "Data/AlertEvent.h"
 
namespace RumPi
{
    class AlertManager
    {
    protected:
        std::mutex                          myMutex;
 
        std::map<std::size_t, std::function<void(const AlertEvent&)>> mySubscribers;
 
        std::map<std::string, EAlertLevel>  myLastLevels;
 
        std::size_t                         myNextSubscriberId;
 
        EAlertLevel Evaluate(const float value, const float warningThreshold, const float alertThreshold, const bool higherIsWorse);
 
        std::string BuildMessage(const std::string& metricName, const float value, const float threshold);
 
        void CopySubscribersLocked(std::vector<std::function<void(const AlertEvent&)>>& outSubscribers) const;
 
    private:
        AlertManager();
 
        virtual ~AlertManager();
 
    public:
        static AlertManager& GetInstance();
 
        std::size_t Subscribe(std::function<void(const AlertEvent&)> callback);
 
        void Unsubscribe(std::size_t subscription);
 
        void Check(const std::string& metricName, const float value, const float warningThreshold, const float alertThreshold, const bool higherIsWorse);
 
        void Report(const EAlertLevel level, const std::string& message);
 
        static std::string LevelToString(const EAlertLevel level);
 
        AlertManager(const AlertManager&) = delete;
        AlertManager& operator=(const AlertManager&) = delete;
    };
} // namespace RumPi