ingest_rate.h

#ifndef _INGEST_RATE_H
#define _INGEST_RATE_H
/*
 * Fledge reading ingest rate.
 *
 * Copyright (c) 2024 Dianomic Systems
 *
 * Released under the Apache 2.0 Licence
 *
 * Author: Mark Riddoch
 */
#include <logger.h>
#include <vector>
#include <queue>
#include <chrono>
#include <mutex>
#include <condition_variable>
#include <filter_plugin.h>
#include <filter_pipeline.h>
#include <asset_tracking.h>
#include <service_handler.h>
#include <set>
#include <ingest.h>

#define IGRSAMPLES  10  // The number of samples used to calculate initial average

class IngestRate {
    public:
        IngestRate(ManagementClient *mgmtClient, const std::string& service);
        ~IngestRate();
        void        ingest(unsigned int numberReadings);
        void        periodic();
        void        updateConfig(int interval, int factor);
        void        relearn();
    private:
        void        updateCounters();
    private:
        ManagementClient    *m_mgmtClient;
        std::string     m_service;
        int         m_currentInterval;
        int         m_numIntervals;
        unsigned long       m_thisInterval;
        double          m_mean;
        double          m_dsq;
        unsigned long       m_count;
        double          m_factor;
        std::mutex      m_mutex;
        bool            m_alerted;
        bool            m_primed;
};
#endif