Introduce Endpoint#messages_received_per_type

Author: Al2Klimov

lib/remote/endpoint.cpp

@@ -1,5 +1,6 @@
 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
 
+#include "remote/apifunction.hpp"
 #include "remote/endpoint.hpp"
 #include "remote/endpoint-ti.cpp"
 #include "remote/apilistener.hpp"
@@ -136,3 +137,17 @@ double Endpoint::GetBytesReceivedPerSecond() const
 {
 	return m_BytesReceived.CalculateRate(Utility::GetTime(), 60);
 }
+
+Dictionary::Ptr Endpoint::GetMessagesReceivedPerType() const
+{
+	DictionaryData result;
+
+	{
+		std::shared_lock sLock (m_MessageCountersMutex);
+
+		for (auto& [afunc, cnt] : m_MessageCounters)
+			result.emplace_back(afunc->GetName(), cnt.load(std::memory_order_relaxed));
+	}
+
+	return new Dictionary(std::move(result));
+}

lib/remote/endpoint.hpp

@@ -56,6 +56,8 @@ class Endpoint final : public ObjectImpl<Endpoint>
 	double GetBytesSentPerSecond() const override;
 	double GetBytesReceivedPerSecond() const override;
 
+	Dictionary::Ptr GetMessagesReceivedPerType() const override;
+
 protected:
 	void OnAllConfigLoaded() override;
 

lib/remote/endpoint.ti

@@ -54,6 +54,10 @@ class Endpoint : ConfigObject
 	[no_user_modify, no_storage] double bytes_received_per_second {
 		get;
 	};
+
+	[no_user_modify, no_storage] Dictionary::Ptr messages_received_per_type {
+		get;
+	};
 };
 
 }