2019-02-25 14:48:22 +01:00
|
|
|
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
|
2013-07-12 12:07:32 +02:00
|
|
|
|
|
|
|
#ifndef MAXAGGREGATOR_H
|
|
|
|
#define MAXAGGREGATOR_H
|
|
|
|
|
2014-05-25 16:23:35 +02:00
|
|
|
#include "livestatus/table.hpp"
|
|
|
|
#include "livestatus/aggregator.hpp"
|
2013-07-12 12:07:32 +02:00
|
|
|
|
2013-11-11 11:57:25 +01:00
|
|
|
namespace icinga
|
2013-07-12 12:07:32 +02:00
|
|
|
{
|
|
|
|
|
2017-08-14 15:30:06 +02:00
|
|
|
/**
|
|
|
|
* @ingroup livestatus
|
|
|
|
*/
|
2018-01-04 06:11:04 +01:00
|
|
|
struct MaxAggregatorState final : public AggregatorState
|
2017-08-14 15:30:06 +02:00
|
|
|
{
|
2018-01-04 09:43:49 +01:00
|
|
|
double Max{0};
|
2017-08-14 15:30:06 +02:00
|
|
|
};
|
|
|
|
|
2013-07-12 12:07:32 +02:00
|
|
|
/**
|
|
|
|
* @ingroup livestatus
|
|
|
|
*/
|
2018-01-04 06:11:04 +01:00
|
|
|
class MaxAggregator final : public Aggregator
|
2013-07-12 12:07:32 +02:00
|
|
|
{
|
|
|
|
public:
|
2014-11-07 18:37:07 +01:00
|
|
|
DECLARE_PTR_TYPEDEFS(MaxAggregator);
|
2013-07-12 12:07:32 +02:00
|
|
|
|
2018-01-04 08:54:18 +01:00
|
|
|
MaxAggregator(String attr);
|
2013-07-12 12:07:32 +02:00
|
|
|
|
2018-01-04 05:12:56 +01:00
|
|
|
void Apply(const Table::Ptr& table, const Value& row, AggregatorState **state) override;
|
|
|
|
double GetResultAndFreeState(AggregatorState *state) const override;
|
2013-07-12 12:07:32 +02:00
|
|
|
|
|
|
|
private:
|
|
|
|
String m_MaxAttr;
|
2017-08-14 15:30:06 +02:00
|
|
|
|
|
|
|
static MaxAggregatorState *EnsureState(AggregatorState **state);
|
2013-07-12 12:07:32 +02:00
|
|
|
};
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif /* MAXAGGREGATOR_H */
|