Move blobstorageproxies actor services to different monitoring shard (#8815)

Author: serbel324

ydb/core/base/counters.cpp

@@ -10,6 +10,7 @@ static const THashSet<TString> DATABASE_SERVICES
     = {{ TString("compile"),
          TString("coordinator"),
          TString("dsproxy"),
+         TString("dsproxy_mon"),
          TString("dsproxynode"),
          TString("dsproxy_overview"),
          TString("dsproxy_percentile"),

ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp

@@ -402,8 +402,15 @@ class TBlobStorageGroupProxyMonActor : public TActorBootstrapped<TBlobStorageGro
 
             TString path = Sprintf("blobstorageproxy%09" PRIu32, (ui32)GroupId);
             TString name = Sprintf("BlobStorageProxy%09" PRIu32, (ui32)GroupId);
-            mon->RegisterActorPage(proxiesMonPage, path, name, false, TlsActivationContext->ExecutorThread.ActorSystem,
-                SelfId());
+            mon->RegisterActorPage(TMon::TRegisterActorPageFields{
+                .Title = name,
+                .RelPath = path,
+                .ActorSystem = TlsActivationContext->ExecutorThread.ActorSystem,
+                .Index = proxiesMonPage, 
+                .PreTag = false, 
+                .ActorId = SelfId(),
+                .MonServiceName = "dsproxy_mon"
+            });
         }
 
         Become(&TThis::StateOnline);

ydb/core/mon/async_http_mon.cpp

@@ -219,7 +219,8 @@ class THttpMonLegacyActorRequest : public TActorBootstrapped<THttpMonLegacyActor
     void ReplyWith(NHttp::THttpOutgoingResponsePtr response) {
         TString url(Event->Get()->Request->URL.Before('?'));
         TString status(response->Status);
-        NMonitoring::THistogramPtr ResponseTimeHgram = NKikimr::GetServiceCounters(NKikimr::AppData()->Counters, "utils")
+        NMonitoring::THistogramPtr ResponseTimeHgram = NKikimr::GetServiceCounters(NKikimr::AppData()->Counters,
+                ActorMonPage->MonServiceName)
             ->GetSubgroup("subsystem", "mon")
             ->GetSubgroup("url", url)
             ->GetSubgroup("status", status)
@@ -870,7 +871,8 @@ NMonitoring::IMonPage* TAsyncHttpMon::RegisterActorPage(TRegisterActorPageFields
         fields.ActorSystem,
         fields.ActorId,
         fields.AllowedSIDs ? fields.AllowedSIDs : Config.AllowedSIDs,
-        fields.UseAuth ? Config.Authorizer : TRequestAuthorizer());
+        fields.UseAuth ? Config.Authorizer : TRequestAuthorizer(),
+        fields.MonServiceName);
     if (fields.Index) {
         fields.Index->Register(page);
         if (fields.SortPages) {

ydb/core/mon/mon.h

@@ -60,6 +60,7 @@ class TMon {
         bool UseAuth = true;
         TVector<TString> AllowedSIDs;
         bool SortPages = true;
+        TString MonServiceName = "utils";
     };
 
     virtual NMonitoring::IMonPage* RegisterActorPage(TRegisterActorPageFields fields) = 0;

ydb/core/mon/mon_impl.h

@@ -360,14 +360,15 @@ class TActorMonPage: public IMonPage {
 public:
     TActorMonPage(const TString &path, const TString &title, const TString &host, bool preTag,
                     TActorSystem *actorSystem, const TActorId &actorId, const TVector<TString> &sids,
-                    TMon::TRequestAuthorizer authorizer)
+                    TMon::TRequestAuthorizer authorizer, TString monServiceName = "utils")
         : IMonPage(path, title)
         , Host(host)
         , PreTag(preTag)
         , ActorSystem(actorSystem)
         , TargetActorId(actorId)
         , AllowedSIDs(sids)
         , Authorizer(std::move(authorizer))
+        , MonServiceName(monServiceName)
     {
     }
 
@@ -405,6 +406,7 @@ class TActorMonPage: public IMonPage {
     TActorId TargetActorId;
     const TVector<TString> AllowedSIDs;
     TMon::TRequestAuthorizer Authorizer;
+    TString MonServiceName;
 };
 
 inline TString GetPageFullPath(const NMonitoring::IMonPage* page) {

ydb/core/mon/sync_http_mon.cpp

@@ -81,7 +81,8 @@ namespace NActors {
             fields.ActorSystem,
             fields.ActorId,
             fields.AllowedSIDs ? fields.AllowedSIDs : Config.AllowedSIDs,
-            fields.UseAuth ? Config.Authorizer : TRequestAuthorizer());
+            fields.UseAuth ? Config.Authorizer : TRequestAuthorizer(),
+            fields.MonServiceName);
         if (fields.Index) {
             fields.Index->Register(page);
             if (fields.SortPages) {

ydb/deploy/helm/ydb-prometheus/values.yaml

@@ -102,6 +102,7 @@ ydb:
         format: prometheus
         tenant: "{{ .target.path }}"
       skipNameRelabeling: true
+    - counter: dsproxy_mon
 
   # Cluster which will be monitored
   clusters: []