Provide collected cluster stats via /v1/status

Author: Al2Klimov

lib/remote/statsreporter.cpp

@@ -24,6 +24,7 @@
 #include "base/function.hpp"
 #include "base/objectlock.hpp"
 #include "base/scriptglobal.hpp"
+#include "base/statsfunction.hpp"
 #include "base/utility.hpp"
 #include "base/value.hpp"
 #include "remote/apifunction.hpp"
@@ -39,6 +40,8 @@ using namespace icinga;
 
 REGISTER_APIFUNCTION(ClusterStats, event, &StatsReporter::ClusterStatsAPIHandler);
 
+REGISTER_STATSFUNCTION(ClusterStats, &StatsReporter::StatsFunc);
+
 StatsReporter StatsReporter::m_Instance;
 
 StatsReporter::StatsReporter()
@@ -182,3 +185,8 @@ void StatsReporter::ClusterStatsHandler(const String& endpoint, const Dictionary
 	boost::mutex::scoped_lock lock (m_Mutex);
 	m_SecondaryStats[endpoint] = stats;
 }
+
+void StatsReporter::StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata)
+{
+	status->Set("cluster", m_Instance.GenerateStats());
+}

lib/remote/statsreporter.hpp

@@ -20,6 +20,7 @@
 #ifndef STATSREPORTER_H
 #define STATSREPORTER_H
 
+#include "base/array.hpp"
 #include "base/dictionary.hpp"
 #include "base/string.hpp"
 #include "base/timer.hpp"
@@ -40,6 +41,7 @@ class StatsReporter
 {
 public:
 	static Value ClusterStatsAPIHandler(const MessageOrigin::Ptr& origin, const Dictionary::Ptr& params);
+	static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
 
 private:
 	StatsReporter();