17 #include <condition_variable> 18 #include <filter_plugin.h> 19 #include <filter_pipeline.h> 20 #include <asset_tracking.h> 21 #include <service_handler.h> 25 #define IGRSAMPLES 10 // The number of samples used to calculate initial average 53 void ingest(
unsigned int numberReadings);
58 void updateCounters();
61 std::string m_service;
62 int m_currentInterval;
64 unsigned long m_thisInterval;
67 unsigned long m_count;
~IngestRate()
Destructor for the ingest rate class.
Definition: ingestRate.cpp:30
IngestRate(ManagementClient *mgmtClient, const std::string &service)
Constructor for ingest rate class.
Definition: ingestRate.cpp:21
void periodic()
Called periodically by the stats update thread.
Definition: ingestRate.cpp:89
void ingest(unsigned int numberReadings)
Called each time we ingest any readings.
Definition: ingestRate.cpp:78
The management client class used by services and tasks to communicate with the management API of the ...
Definition: management_client.h:43
void updateConfig(int interval, int factor)
Update the configuration of the ingest rate mechanism.
Definition: ingestRate.cpp:40
void relearn()
The configuration has changed so we need to reset our state and go back into the mode of determining ...
Definition: ingestRate.cpp:63
A class used to track and report on the ingest rates of a data stream.
Definition: ingest_rate.h:49