Browse Source

Refactoring: NYq::NCommon::TServiceCounters -> NYql::NCommon::TServiceCounters

::NYq::NCommon::TServiceCounters -> ::NYql::NCommon::TServiceCounters

ref:a0834e5ccd4139183520676615bdbf45b30f0bc0
dinmukhammed 3 years ago
parent
commit
471e9b902d

+ 3 - 3
ydb/core/yq/libs/actors/nodes_manager.cpp

@@ -57,7 +57,7 @@ public:
         const NDqs::TWorkerManagerCounters& workerManagerCounters,
         TIntrusivePtr<ITimeProvider> timeProvider,
         TIntrusivePtr<IRandomProvider> randomProvider,
-        const ::NYq::NCommon::TServiceCounters& serviceCounters,
+        const ::NYql::NCommon::TServiceCounters& serviceCounters,
         const NConfig::TPrivateApiConfig& privateApiConfig,
         const ui32& icPort,
         const TString& tenant,
@@ -255,7 +255,7 @@ private:
     NDqs::TWorkerManagerCounters WorkerManagerCounters;
     TIntrusivePtr<ITimeProvider> TimeProvider;
     TIntrusivePtr<IRandomProvider> RandomProvider;
-    ::NYq::NCommon::TServiceCounters ServiceCounters;
+    ::NYql::NCommon::TServiceCounters ServiceCounters;
     NConfig::TPrivateApiConfig PrivateApiConfig;
     TString Tenant;
     ui64 MkqlInitialMemoryLimit;
@@ -293,7 +293,7 @@ IActor* CreateYqlNodesManager(
     const NDqs::TWorkerManagerCounters& workerManagerCounters,
     TIntrusivePtr<ITimeProvider> timeProvider,
     TIntrusivePtr<IRandomProvider> randomProvider,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     const NConfig::TPrivateApiConfig& privateApiConfig,
     const NYq::TYqSharedResources::TPtr& yqSharedResources,
     const ui32& icPort,

+ 1 - 1
ydb/core/yq/libs/actors/nodes_manager.h

@@ -25,7 +25,7 @@ IActor* CreateYqlNodesManager(
     const NYql::NDqs::TWorkerManagerCounters& workerManagerCounters,
     TIntrusivePtr<ITimeProvider> timeProvider,
     TIntrusivePtr<IRandomProvider> randomProvider,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     const NConfig::TPrivateApiConfig& privateApiConfig,
     const NYq::TYqSharedResources::TPtr& yqSharedResources,
     const ui32& icPort,

+ 4 - 4
ydb/core/yq/libs/actors/pending_fetcher.cpp

@@ -136,7 +136,7 @@ public:
         TIntrusivePtr<ITimeProvider> timeProvider,
         TIntrusivePtr<IRandomProvider> randomProvider,
         NKikimr::NMiniKQL::TComputationNodeFactory dqCompFactory,
-        const ::NYq::NCommon::TServiceCounters& serviceCounters,
+        const ::NYql::NCommon::TServiceCounters& serviceCounters,
         ISecuredServiceAccountCredentialsFactory::TPtr credentialsFactory,
         IHTTPGateway::TPtr s3Gateway,
         ::NPq::NConfigurationManager::IConnections::TPtr pqCmConnections,
@@ -318,7 +318,7 @@ private:
         const TString cloudId = task.sensor_labels().at("cloud_id");
         const TString queryId = task.query_id().value();
 
-        ::NYq::NCommon::TServiceCounters queryCounters(ServiceCounters);
+        ::NYql::NCommon::TServiceCounters queryCounters(ServiceCounters);
         auto publicCountersParent = ServiceCounters.PublicCounters;
 
         if (cloudId && folderId) {
@@ -395,7 +395,7 @@ private:
     TIntrusivePtr<IRandomProvider> RandomProvider;
     NKikimr::NMiniKQL::TComputationNodeFactory DqCompFactory;
     TIntrusivePtr<IDqGateway> DqGateway;
-    ::NYq::NCommon::TServiceCounters ServiceCounters;
+    ::NYql::NCommon::TServiceCounters ServiceCounters;
 
     IModuleResolver::TPtr ModuleResolver;
 
@@ -437,7 +437,7 @@ NActors::IActor* CreatePendingFetcher(
     TIntrusivePtr<ITimeProvider> timeProvider,
     TIntrusivePtr<IRandomProvider> randomProvider,
     NKikimr::NMiniKQL::TComputationNodeFactory dqCompFactory,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     ISecuredServiceAccountCredentialsFactory::TPtr credentialsFactory,
     IHTTPGateway::TPtr s3Gateway,
     ::NPq::NConfigurationManager::IConnections::TPtr pqCmConnections,

+ 3 - 3
ydb/core/yq/libs/actors/pinger.cpp

@@ -151,7 +151,7 @@ public:
         const TActorId parent,
         const NConfig::TPingerConfig& config,
         TInstant deadline,
-        const ::NYq::NCommon::TServiceCounters& queryCounters,
+        const ::NYql::NCommon::TServiceCounters& queryCounters,
         TInstant createdAt)
         : Config(config)
         , TenantName(tenantName)
@@ -435,7 +435,7 @@ private:
     const TActorId Parent;
     const TInstant Deadline;
 
-    const ::NYq::NCommon::TServiceCounters QueryCounters;
+    const ::NYql::NCommon::TServiceCounters QueryCounters;
     const TInstant CreatedAt;
 
     std::deque<TForwardPingReqInfo> ForwardRequests;
@@ -455,7 +455,7 @@ IActor* CreatePingerActor(
     const TActorId parent,
     const NConfig::TPingerConfig& config,
     TInstant deadline,
-    const ::NYq::NCommon::TServiceCounters& queryCounters,
+    const ::NYql::NCommon::TServiceCounters& queryCounters,
     TInstant createdAt)
 {
     return new TPingerActor(

+ 3 - 3
ydb/core/yq/libs/actors/proxy.h

@@ -44,7 +44,7 @@ NActors::IActor* CreatePendingFetcher(
     TIntrusivePtr<ITimeProvider> timeProvider,
     TIntrusivePtr<IRandomProvider> randomProvider,
     NKikimr::NMiniKQL::TComputationNodeFactory dqCompFactory,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     NYql::ISecuredServiceAccountCredentialsFactory::TPtr credentialsFactory,
     NYql::IHTTPGateway::TPtr s3Gateway,
     ::NPq::NConfigurationManager::IConnections::TPtr pqCmConnections,
@@ -54,7 +54,7 @@ NActors::IActor* CreatePendingFetcher(
 
 NActors::IActor* CreateRunActor(
     const NActors::TActorId& fetcherId,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     TRunActorParams&& params);
 
 struct TResultId {
@@ -87,7 +87,7 @@ NActors::IActor* CreatePingerActor(
     const NActors::TActorId parent,
     const NConfig::TPingerConfig& config,
     TInstant deadline,
-    const ::NYq::NCommon::TServiceCounters& queryCounters,
+    const ::NYql::NCommon::TServiceCounters& queryCounters,
     TInstant createdAt);
 
 TString MakeInternalError(const TString& text);

+ 3 - 3
ydb/core/yq/libs/actors/run_actor.cpp

@@ -87,7 +87,7 @@ class TRunActor : public NActors::TActorBootstrapped<TRunActor> {
 public:
     explicit TRunActor(
         const NActors::TActorId& fetcherId
-        , const ::NYq::NCommon::TServiceCounters& queryCounters
+        , const ::NYql::NCommon::TServiceCounters& queryCounters
         , TRunActorParams&& params)
         : FetcherId(fetcherId)
         , Params(std::move(params))
@@ -1292,7 +1292,7 @@ private:
     NActors::TActorId ControlId;
     NActors::TActorId CheckpointCoordinatorId;
     TString SessionId;
-    ::NYq::NCommon::TServiceCounters QueryCounters;
+    ::NYql::NCommon::TServiceCounters QueryCounters;
     const NMonitoring::TDynamicCounters::TCounterPtr QueryUptime;
     bool EnableCheckpointCoordinator = false;
     bool RetryNeeded = false;
@@ -1326,7 +1326,7 @@ private:
 
 IActor* CreateRunActor(
     const NActors::TActorId& fetcherId,
-    const ::NYq::NCommon::TServiceCounters& serviceCounters,
+    const ::NYql::NCommon::TServiceCounters& serviceCounters,
     TRunActorParams&& params
 ) {
     return new TRunActor(fetcherId, serviceCounters, std::move(params));

+ 1 - 1
ydb/core/yq/libs/init/init.cpp

@@ -168,7 +168,7 @@ void Init(
         actorRegistrator(NYql::NDqs::MakeWorkerManagerActorID(nodeId), resman);
     }
 
-    ::NYq::NCommon::TServiceCounters serviceCounters(appData->Counters);
+    ::NYql::NCommon::TServiceCounters serviceCounters(appData->Counters);
 
     if (protoConfig.GetNodesManager().GetEnabled()) {
         auto nodesManager = CreateYqlNodesManager(

+ 1 - 1
ydb/library/yql/providers/common/metrics/service_counters.cpp

@@ -1,6 +1,6 @@
 #include "service_counters.h"
 
-namespace NYq {
+namespace NYql {
 namespace NCommon {
 
 TServiceCounters::TServiceCounters(

+ 1 - 1
ydb/library/yql/providers/common/metrics/service_counters.h

@@ -3,7 +3,7 @@
 #include <util/generic/string.h>
 #include <library/cpp/monlib/dynamic_counters/counters.h>
 
-namespace NYq {
+namespace NYql {
 namespace NCommon {
 
 struct TServiceCounters {

+ 3 - 3
ydb/library/yql/providers/dq/actors/task_controller.cpp

@@ -50,7 +50,7 @@ public:
         const NActors::TActorId& executerId,
         const NActors::TActorId& resultId,
         const TDqConfiguration::TPtr& settings,
-        const NYq::NCommon::TServiceCounters& serviceCounters,
+        const NYql::NCommon::TServiceCounters& serviceCounters,
         const TDuration& pingPeriod,
         const TDuration& aggrPeriod
     )
@@ -548,7 +548,7 @@ private:
     TDqConfiguration::TPtr Settings;
     bool Finished = false;
     TCounters TaskStat;
-    NYq::NCommon::TServiceCounters ServiceCounters;
+    NYql::NCommon::TServiceCounters ServiceCounters;
     TDuration PingPeriod = TDuration::Zero();
     TDuration AggrPeriod = TDuration::Zero();
     TIssues Issues;
@@ -562,7 +562,7 @@ THolder<NActors::IActor> MakeTaskController(
     const NActors::TActorId& executerId,
     const NActors::TActorId& resultId,
     const TDqConfiguration::TPtr& settings,
-    const NYq::NCommon::TServiceCounters& serviceCounters,
+    const NYql::NCommon::TServiceCounters& serviceCounters,
     const TDuration& pingPeriod,
     const TDuration& aggrPeriod
 ) {

Some files were not shown because too many files changed in this diff