/******************************************************************************
* Icinga 2 *
- * Copyright (C) 2012-2015 Icinga Development Team (http://www.icinga.org) *
+ * Copyright (C) 2012-2018 Icinga Development Team (https://www.icinga.com/) *
* *
* This program is free software; you can redistribute it and/or *
* modify it under the terms of the GNU General Public License *
#include "livestatus/column.hpp"
#include "base/object.hpp"
#include "base/dictionary.hpp"
+#include "base/array.hpp"
#include <vector>
namespace icinga
{
-typedef boost::function<void (const Value&)> AddRowFunction;
+struct LivestatusRowValue {
+ Value Row;
+ LivestatusGroupByType GroupByType;
+ Value GroupByObject;
+};
+
+typedef std::function<bool (const Value&, LivestatusGroupByType, const Object::Ptr&)> AddRowFunction;
class Filter;
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(void) const = 0;
- virtual String GetPrefix(void) const = 0;
+ virtual String GetName() const = 0;
+ virtual String GetPrefix() const = 0;
- std::vector<Value> FilterRows(const intrusive_ptr<Filter>& filter);
+ 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(void) const;
+ std::vector<String> GetColumnNames() const;
+
+ LivestatusGroupByType GetGroupByType() const;
protected:
- Table(void);
+ Table(LivestatusGroupByType type = LivestatusGroupByNone);
virtual void FetchRows(const AddRowFunction& addRowFn) = 0;
static Value EmptyArrayAccessor(const Value&);
static Value EmptyDictionaryAccessor(const Value&);
+ LivestatusGroupByType m_GroupByType;
+ Value m_GroupByObject;
+
private:
std::map<String, Column> m_Columns;
- void FilteredAddRow(std::vector<Value>& rs, const intrusive_ptr<Filter>& filter, const Value& row);
+ bool FilteredAddRow(std::vector<LivestatusRowValue>& rs, const intrusive_ptr<Filter>& filter, int limit, const Value& row, LivestatusGroupByType groupByType, const Object::Ptr& groupByObject);
};
}