diff options
| author | Dan Engelbrecht <[email protected]> | 2023-11-01 11:27:19 +0100 |
|---|---|---|
| committer | Dan Engelbrecht <[email protected]> | 2023-11-01 11:27:19 +0100 |
| commit | a037e739d8ea1aa3f6e250158597ad8fcee3358d (patch) | |
| tree | 55e58bc1ce48a4a73b15115ab404079d8064b13f | |
| parent | override fix (diff) | |
| download | zen-de/statds-for-gc.tar.xz zen-de/statds-for-gc.zip | |
add gcmanager as a statsd providerde/statds-for-gc
| -rw-r--r-- | src/zenserver/zenserver.cpp | 1 | ||||
| -rw-r--r-- | src/zenstore/gc.cpp | 6 | ||||
| -rw-r--r-- | src/zenstore/include/zenstore/gc.h | 5 |
3 files changed, 11 insertions, 1 deletions
diff --git a/src/zenserver/zenserver.cpp b/src/zenserver/zenserver.cpp index 282dc73cf..0fa8d2521 100644 --- a/src/zenserver/zenserver.cpp +++ b/src/zenserver/zenserver.cpp @@ -526,6 +526,7 @@ ZenServer::InitializeStructuredCache(const ZenServerOptions& ServerOptions) m_StatsReporter.AddProvider(m_CacheStore.Get()); m_StatsReporter.AddProvider(m_CidStore.get()); + m_StatsReporter.AddProvider(&m_GcManager); } void diff --git a/src/zenstore/gc.cpp b/src/zenstore/gc.cpp index 4d146c16c..77f625d89 100644 --- a/src/zenstore/gc.cpp +++ b/src/zenstore/gc.cpp @@ -769,6 +769,12 @@ GcManager::TotalStorageSize() const return TotalSize; } +void +GcManager::ReportMetrics(StatsMetrics&) +{ + // TODO +} + ////////////////////////////////////////////////////////////////////////// void diff --git a/src/zenstore/include/zenstore/gc.h b/src/zenstore/include/zenstore/gc.h index e2e99d5a4..b10ab9d5c 100644 --- a/src/zenstore/include/zenstore/gc.h +++ b/src/zenstore/include/zenstore/gc.h @@ -6,6 +6,7 @@ #include <zencore/thread.h> #include <zenstore/caslog.h> #include <zenstore/scrubcontext.h> +#include <zenutil/statsreporter.h> ZEN_THIRD_PARTY_INCLUDES_START #include <fmt/format.h> @@ -326,7 +327,7 @@ public: /** GC orchestrator */ -class GcManager +class GcManager : public StatsProvider { public: GcManager(); @@ -358,6 +359,8 @@ public: const DiskWriteBlocker* GetDiskWriteBlocker() { return m_DiskWriteBlocker; } void SetDiskWriteBlocker(const DiskWriteBlocker* Monitor) { m_DiskWriteBlocker = Monitor; } + virtual void ReportMetrics(StatsMetrics& Statsd) override; + private: spdlog::logger& Log() { return m_Log; } spdlog::logger& m_Log; |