perfmonitors.h

#ifndef _PERFMONITOR_H
#define _PERFMONITOR_H
/*
 * Fledge performance monitor
 *
 * Copyright (c) 2023 Dianomic Systems
 *
 * Released under the Apache 2.0 Licence
 *
 * Author: Mark Riddoch, Massimiliano Pinto
 */
#include <thread>
#include <storage_client.h>
#include <unordered_map>
#include <insert.h>
#include <mutex>
#include <condition_variable>

class PerfMon {
    public:
        PerfMon(const std::string& name);
        void        addValue(long value);
        int     getValues(InsertValues& values);
    private:
        std::string m_name;
        long        m_average;
        long        m_min;
        long        m_max;
        int     m_samples;
        std::mutex  m_mutex;
};
class PerformanceMonitor {
    public:
        PerformanceMonitor(const std::string& service, StorageClient *storage);
        // Write data to storage
        virtual void writeData(const std::string& table, const InsertValues& values)
        {
            // Write data via storage client
            if (m_storage != NULL)
            {
                m_storage->insertTable(table, values);
            }
            else
            {
                Logger::getLogger()->error("Failed to save performace monitor data: "\
                        "storage client is null for servide '%s'",
                        m_service.c_str());
            }
        };
        virtual ~PerformanceMonitor();
        inline void     collect(const std::string& name, long value)
                    {
                        if (m_collecting)
                        {
                            doCollection(name, value);
                        }
                    };
        void            setCollecting(bool state);
        void            writeThread();
        bool            isCollecting() { return m_collecting; };
    private:
        void            doCollection(const std::string& name, long value);
    private:
        std::string     m_service;
        StorageClient       *m_storage;
        std::thread     *m_thread;
        bool            m_collecting;
        std::unordered_map<std::string, PerfMon *>
                    m_monitors;
        std::condition_variable m_cv;
        std::mutex      m_mutex;
};
#endif