tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-31 01:24:19 +02:00
Code Issues Packages Projects Releases Wiki Activity

Provide collected cluster stats via /v1/status

Browse Source
This commit is contained in:
Alexander A. Klimov 2018-08-02 14:31:06 +02:00
parent 186b0bdff5
commit 78c26f055a
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/remote/statsreporter.cpp
View File

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

2
lib/remote/statsreporter.hpp
View File

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