Introduce Endpoint#seconds_{reading,processing}_messages for the API

Icinga · Dec 10, 2024 · 3ebbfc6 · 3ebbfc6
1 parent ecea525
commit 3ebbfc6
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 1 deletion.
diff --git a/lib/base/benchmark.hpp b/lib/base/benchmark.hpp
@@ -25,7 +25,7 @@ class Benchmark
 	 * @return The total accumulated time in seconds
 	 */
 	template<class T>
-	explicit operator T() const noexcept
+	operator T() const noexcept
 	{
 		return std::chrono::duration<T>(Clock::duration(m_Sum.load(std::memory_order_relaxed))).count();
 	}

diff --git a/lib/remote/endpoint.cpp b/lib/remote/endpoint.cpp
@@ -136,3 +136,13 @@ double Endpoint::GetBytesReceivedPerSecond() const
 {
 	return m_BytesReceived.CalculateRate(Utility::GetTime(), 60);
 }
+
+double Endpoint::GetSecondsReadingMessages() const
+{
+	return m_InputReadTime;
+}
+
+double Endpoint::GetSecondsProcessingMessages() const
+{
+	return m_InputProcessTime;
+}
diff --git a/lib/remote/endpoint.hpp b/lib/remote/endpoint.hpp
@@ -57,6 +57,9 @@ class Endpoint final : public ObjectImpl<Endpoint>
 	double GetBytesSentPerSecond() const override;
 	double GetBytesReceivedPerSecond() const override;
 
+	double GetSecondsReadingMessages() const override;
+	double GetSecondsProcessingMessages() const override;
+
 protected:
 	void OnAllConfigLoaded() override;
 

diff --git a/lib/remote/endpoint.ti b/lib/remote/endpoint.ti
@@ -54,6 +54,14 @@ class Endpoint : ConfigObject
 	[no_user_modify, no_storage] double bytes_received_per_second {
 		get;
 	};
+
+	[no_user_modify, no_storage] double seconds_reading_messages {
+		get;
+	};
+
+	[no_user_modify, no_storage] double seconds_processing_messages {
+		get;
+	};
 };
 
 }