diff options
| author | capone212 <capone212@yandex-team.com> | 2023-12-07 04:06:40 +0300 |
|---|---|---|
| committer | capone212 <capone212@yandex-team.com> | 2023-12-07 04:27:46 +0300 |
| commit | 5c1b88932efdcffb8a5500204cf7a579bae5ffcd (patch) | |
| tree | d87aca1854d25ef5d971fa02198e0d019cf16bd8 | |
| parent | 6c084f56f0fc117bdf761a3d5f0b9234cf818aee (diff) | |
| download | ydb-5c1b88932efdcffb8a5500204cf7a579bae5ffcd.tar.gz | |
YT-18346: Enhancing journals io rate monitoring
| -rw-r--r-- | yt/yt/client/api/journal_client.cpp | 4 | ||||
| -rw-r--r-- | yt/yt/client/api/journal_client.h | 4 |
2 files changed, 8 insertions, 0 deletions
diff --git a/yt/yt/client/api/journal_client.cpp b/yt/yt/client/api/journal_client.cpp index b377ed9bbf..96854d1174 100644 --- a/yt/yt/client/api/journal_client.cpp +++ b/yt/yt/client/api/journal_client.cpp @@ -26,6 +26,10 @@ TJournalWriterPerformanceCounters::TJournalWriterPerformanceCounters(const NProf WriteQuorumLag = profiler.Timer("/write_quorum_lag"); MaxReplicaLag = profiler.Timer("/max_replica_lag"); + + MediumWrittenBytes = profiler.Counter("/medium_written_bytes"); + JournalWrittenBytes = profiler.Counter("/journal_written_bytes"); + IORequestCount = profiler.Counter("/io_request_count"); } //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/client/api/journal_client.h b/yt/yt/client/api/journal_client.h index 086e7634c6..0feb298e1d 100644 --- a/yt/yt/client/api/journal_client.h +++ b/yt/yt/client/api/journal_client.h @@ -36,6 +36,10 @@ struct TJournalWriterPerformanceCounters NProfiling::TEventTimer SealChunkTimer; NProfiling::TEventTimer WriteQuorumLag; NProfiling::TEventTimer MaxReplicaLag; + + NProfiling::TCounter MediumWrittenBytes; + NProfiling::TCounter IORequestCount; + NProfiling::TCounter JournalWrittenBytes; }; struct TJournalWriterOptions |