diff options
| author | hor911 <hor911@ydb.tech> | 2023-02-12 13:38:40 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2023-02-12 13:38:40 +0300 |
| commit | e36071919caa6b9ff580c06fd8f347f352b4dc6e (patch) | |
| tree | c33d8f8054a650403864b97a63e0c89ca8f9694f | |
| parent | fb07d31202e1f701940845b0a4899669ee8f0c28 (diff) | |
| download | ydb-e36071919caa6b9ff580c06fd8f347f352b4dc6e.tar.gz | |
Publish AnonRss sensors
| -rw-r--r-- | ydb/core/yq/libs/actors/nodes_manager.cpp | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/ydb/core/yq/libs/actors/nodes_manager.cpp b/ydb/core/yq/libs/actors/nodes_manager.cpp index daba067dc33..e524c4af6cd 100644 --- a/ydb/core/yq/libs/actors/nodes_manager.cpp +++ b/ydb/core/yq/libs/actors/nodes_manager.cpp @@ -1,9 +1,10 @@ #include "nodes_manager.h" #include <ydb/core/yq/libs/config/protos/fq_config.pb.h> +#include <library/cpp/actors/core/actor_bootstrapped.h> #include <library/cpp/actors/core/events.h> #include <library/cpp/actors/core/hfunc.h> -#include <library/cpp/actors/core/actor_bootstrapped.h> +#include <library/cpp/actors/core/process_stats.h> #include <library/cpp/actors/interconnect/events_local.h> #include <ydb/library/yql/providers/dq/worker_manager/interface/events.h> #include <ydb/library/yql/public/issue/yql_issue_message.h> @@ -64,6 +65,8 @@ public: { InstanceId = GetGuidAsString(RandomProvider->GenUuid4()); + AnonRssSize = ServiceCounters.Counters->GetCounter("AnonRssSize"); + AnonRssLimit = ServiceCounters.Counters->GetCounter("AnonRssLimit"); } static constexpr char ActorName[] = "YQ_NODES_MANAGER"; @@ -215,6 +218,11 @@ private: ServiceCounters.Counters->GetCounter("NodesHealthCheck", true)->Inc(); + NActors::TProcStat procStat; + procStat.Fill(getpid()); + AnonRssSize->Set(procStat.AnonRss); + AnonRssLimit->Set(procStat.CGroupMemLim); + Fq::Private::NodesHealthCheckRequest request; request.set_tenant(Tenant); auto& node = *request.mutable_node(); @@ -315,6 +323,8 @@ private: TString InstanceId; TActorId InternalServiceId; TString Address; + ::NMonitoring::TDynamicCounters::TCounterPtr AnonRssSize; + ::NMonitoring::TDynamicCounters::TCounterPtr AnonRssLimit; }; TActorId MakeNodesManagerId() { |