tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-29 08:34:20 +02:00
Code Issues Packages Projects Releases Wiki Activity

Introduce Endpoint#messages_received_per_type

Browse Source
This commit is contained in:
Alexander A. Klimov 2025-04-01 16:45:58 +02:00
parent dd9e211927
commit 712d39740f
3 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/remote/endpoint.cpp
View File

@ -149,3 +149,16 @@ double Endpoint::GetBytesReceivedPerSecond() const
{
return m_BytesReceived.CalculateRate(Utility::GetTime(), 60);
}
Dictionary::Ptr Endpoint::GetMessagesReceivedPerType() const
{
DictionaryData result;
for (auto& [afunc, cnt] : m_MessageCounters) {
if (auto v (cnt.load(std::memory_order_relaxed)); v) {
result.emplace_back(afunc->GetName(), v);
}
}
return new Dictionary(std::move(result));
}

2
lib/remote/endpoint.hpp
View File

@ -56,6 +56,8 @@ public:
double GetBytesSentPerSecond() const override;
double GetBytesReceivedPerSecond() const override;
Dictionary::Ptr GetMessagesReceivedPerType() const override;
protected:
void OnAllConfigLoaded() override;

4
lib/remote/endpoint.ti
View File

@ -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;
};
};
}