diff options
| author | tesseract <tesseract@yandex-team.com> | 2023-03-01 18:56:14 +0300 |
|---|---|---|
| committer | tesseract <tesseract@yandex-team.com> | 2023-03-01 18:56:14 +0300 |
| commit | fe73913f0bad7f7bce94ed81638f9b0ed442b1a3 (patch) | |
| tree | 6e4b8c90a586b6749a602c94bd615eeac06ad3e7 | |
| parent | 73d7c9861df84ecfff5cb0b23ec96e41866fc4c4 (diff) | |
| download | ydb-fe73913f0bad7f7bce94ed81638f9b0ed442b1a3.tar.gz | |
В schemeshard-е поддерживать статистику об используемом месте топиками пользователя (исправления замечаний)
| -rw-r--r-- | ydb/core/tx/schemeshard/schemeshard__pq_stats.cpp | 6 | ||||
| -rw-r--r-- | ydb/core/tx/schemeshard/schemeshard_path_describer.h | 2 |
2 files changed, 6 insertions, 2 deletions
diff --git a/ydb/core/tx/schemeshard/schemeshard__pq_stats.cpp b/ydb/core/tx/schemeshard/schemeshard__pq_stats.cpp index 34f0f86dae..8193d85f03 100644 --- a/ydb/core/tx/schemeshard/schemeshard__pq_stats.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__pq_stats.cpp @@ -19,7 +19,7 @@ public: virtual ~TTxStoreTopicStats() = default; - void Complete(const TActorContext& ) override {}; + void Complete(const TActorContext& ) override; // returns true to continue batching bool PersistSingleStats(const TPathId& pathId, const TStatsQueue<TEvPersQueue::TEvPeriodicTopicStats>::TItem& item, TTransactionContext& txc, const TActorContext& ctx) override; @@ -62,6 +62,10 @@ bool TTxStoreTopicStats::PersistSingleStats(const TPathId& pathId, const TStatsQ return true; } +void TTxStoreTopicStats::Complete(const TActorContext&) { + Queue.WriteQueueSizeMetric(); +} + void TSchemeShard::Handle(TEvPersQueue::TEvPeriodicTopicStats::TPtr& ev, const TActorContext& ctx) { const auto& rec = ev->Get()->Record; diff --git a/ydb/core/tx/schemeshard/schemeshard_path_describer.h b/ydb/core/tx/schemeshard/schemeshard_path_describer.h index 4fe210d5ae..2e40315cfc 100644 --- a/ydb/core/tx/schemeshard/schemeshard_path_describer.h +++ b/ydb/core/tx/schemeshard/schemeshard_path_describer.h @@ -32,7 +32,7 @@ class TPathDescriber { void DescribeSolomonVolume(TPathId pathId, TPathElement::TPtr pathEl, bool returnChannelsBinding); void DescribeUserAttributes(TPathElement::TPtr pathEl); void DescribePathVersion(const TPath& path); - void DescribeDomain(TPathElement::TPtr pathEl) ; + void DescribeDomain(TPathElement::TPtr pathEl); void DescribeDomainRoot(TPathElement::TPtr pathEl); void DescribeDomainExtra(TPathElement::TPtr pathEl); void DescribeRevertedMigrations(TPathElement::TPtr pathEl); |