1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
#ifndef TABLE_H
#define TABLE_H
#include "livestatus/column.hpp"
#include "base/object.hpp"
#include "base/dictionary.hpp"
#include "base/array.hpp"
#include <vector>
namespace icinga
{
// Well, don't ask.
#define LIVESTATUS_INTERVAL_LENGTH 60.0
struct LivestatusRowValue {
Value Row;
LivestatusGroupByType GroupByType;
Value GroupByObject;
};
typedef std::function<bool (const Value&, LivestatusGroupByType, const Object::Ptr&)> AddRowFunction;
class Filter;
/**
* @ingroup livestatus
*/
class Table : public Object
{
public:
DECLARE_PTR_TYPEDEFS(Table);
static Table::Ptr GetByName(const String& name, const String& compat_log_path = "", const unsigned long& from = 0, const unsigned long& until = 0);
virtual String GetName() const = 0;
virtual String GetPrefix() const = 0;
std::vector<LivestatusRowValue> FilterRows(const intrusive_ptr<Filter>& filter, int limit = -1);
void AddColumn(const String& name, const Column& column);
Column GetColumn(const String& name) const;
std::vector<String> GetColumnNames() const;
LivestatusGroupByType GetGroupByType() const;
protected:
Table(LivestatusGroupByType type = LivestatusGroupByNone);
virtual void FetchRows(const AddRowFunction& addRowFn) = 0;
static Value ZeroAccessor(const Value&);
static Value OneAccessor(const Value&);
static Value EmptyStringAccessor(const Value&);
static Value EmptyArrayAccessor(const Value&);
static Value EmptyDictionaryAccessor(const Value&);
LivestatusGroupByType m_GroupByType;
Value m_GroupByObject;
private:
std::map<String, Column> m_Columns;
bool FilteredAddRow(std::vector<LivestatusRowValue>& rs, const intrusive_ptr<Filter>& filter, int limit, const Value& row, LivestatusGroupByType groupByType, const Object::Ptr& groupByObject);
};
}
#endif /* TABLE_H */
#include "livestatus/filter.hpp"
|
