@@ -239,14 +239,14 @@ namespace Tests {
239
239
appData.PQConfig .MergeFrom (Settings->PQConfig );
240
240
appData.PQClusterDiscoveryConfig .MergeFrom (Settings->PQClusterDiscoveryConfig );
241
241
appData.NetClassifierConfig .MergeFrom (Settings->NetClassifierConfig );
242
- appData.StreamingConfig .MergeFrom (Settings->AppConfig . GetGRpcConfig ().GetStreamingConfig ());
243
- appData.EnforceUserTokenRequirement = Settings->AppConfig . GetDomainsConfig ().GetSecurityConfig ().GetEnforceUserTokenRequirement ();
244
- appData.DomainsConfig .MergeFrom (Settings->AppConfig . GetDomainsConfig ());
245
- appData.ColumnShardConfig .MergeFrom (Settings->AppConfig . GetColumnShardConfig ());
242
+ appData.StreamingConfig .MergeFrom (Settings->AppConfig -> GetGRpcConfig ().GetStreamingConfig ());
243
+ appData.EnforceUserTokenRequirement = Settings->AppConfig -> GetDomainsConfig ().GetSecurityConfig ().GetEnforceUserTokenRequirement ();
244
+ appData.DomainsConfig .MergeFrom (Settings->AppConfig -> GetDomainsConfig ());
245
+ appData.ColumnShardConfig .MergeFrom (Settings->AppConfig -> GetColumnShardConfig ());
246
246
appData.PersQueueGetReadSessionsInfoWorkerFactory = Settings->PersQueueGetReadSessionsInfoWorkerFactory .get ();
247
247
appData.DataStreamsAuthFactory = Settings->DataStreamsAuthFactory .get ();
248
248
appData.PersQueueMirrorReaderFactory = Settings->PersQueueMirrorReaderFactory .get ();
249
- appData.HiveConfig .MergeFrom (Settings->AppConfig . GetHiveConfig ());
249
+ appData.HiveConfig .MergeFrom (Settings->AppConfig -> GetHiveConfig ());
250
250
251
251
appData.DynamicNameserviceConfig = new TDynamicNameserviceConfig;
252
252
auto dnConfig = appData.DynamicNameserviceConfig ;
@@ -315,11 +315,11 @@ namespace Tests {
315
315
316
316
Cerr << " TServer::EnableGrpc on GrpcPort " << options.Port << " , node " << system ->NodeId << Endl;
317
317
318
- const size_t proxyCount = Max (ui32{1 }, Settings->AppConfig . GetGRpcConfig ().GetGRpcProxyCount ());
318
+ const size_t proxyCount = Max (ui32{1 }, Settings->AppConfig -> GetGRpcConfig ().GetGRpcProxyCount ());
319
319
TVector<TActorId> grpcRequestProxies;
320
320
grpcRequestProxies.reserve (proxyCount);
321
321
for (size_t i = 0 ; i < proxyCount; ++i) {
322
- auto grpcRequestProxy = NGRpcService::CreateGRpcRequestProxy (Settings->AppConfig );
322
+ auto grpcRequestProxy = NGRpcService::CreateGRpcRequestProxy (* Settings->AppConfig );
323
323
auto grpcRequestProxyId = system ->Register (grpcRequestProxy, TMailboxType::ReadAsFilled);
324
324
system ->RegisterLocalService (NGRpcService::CreateGRpcRequestProxyId (), grpcRequestProxyId);
325
325
grpcRequestProxies.push_back (grpcRequestProxyId);
@@ -353,7 +353,7 @@ namespace Tests {
353
353
}
354
354
355
355
if (!options.SslData .Empty ()) {
356
- grpcService->SetDynamicNodeAuthParams (NKikimr::GetDynamicNodeAuthorizationParams (Settings->AppConfig . GetClientCertificateAuthorization ()));
356
+ grpcService->SetDynamicNodeAuthParams (NKikimr::GetDynamicNodeAuthorizationParams (Settings->AppConfig -> GetClientCertificateAuthorization ()));
357
357
}
358
358
359
359
auto future = grpcService->Prepare (
@@ -390,7 +390,7 @@ namespace Tests {
390
390
GRpcServer->AddService (new NGRpcService::TGRpcCmsService (system , counters, grpcRequestProxies[0 ], true ));
391
391
auto discoveryService = new NGRpcService::TGRpcDiscoveryService (system , counters, grpcRequestProxies[0 ], true );
392
392
if (!options.SslData .Empty ()) {
393
- discoveryService->SetDynamicNodeAuthParams (NKikimr::GetDynamicNodeAuthorizationParams (Settings->AppConfig . GetClientCertificateAuthorization ()));
393
+ discoveryService->SetDynamicNodeAuthParams (NKikimr::GetDynamicNodeAuthorizationParams (Settings->AppConfig -> GetClientCertificateAuthorization ()));
394
394
}
395
395
GRpcServer->AddService (discoveryService);
396
396
GRpcServer->AddService (new NGRpcService::TGRpcYdbClickhouseInternalService (system , counters, appData.InFlightLimiterRegistry , grpcRequestProxies[0 ], true ));
@@ -746,7 +746,7 @@ namespace Tests {
746
746
Runtime->RegisterService (MakeTenantPoolRootID (), poolId, nodeIdx);
747
747
if (Settings->EnableConfigsDispatcher ) {
748
748
// We overwrite icb settings here to save behavior when configs dispatcher are enabled
749
- NKikimrConfig::TAppConfig initial = Settings->AppConfig ;
749
+ NKikimrConfig::TAppConfig initial = * Settings->AppConfig ;
750
750
if (!initial.HasImmediateControlsConfig ()) {
751
751
initial.MutableImmediateControlsConfig ()->CopyFrom (Settings->Controls );
752
752
}
@@ -839,7 +839,7 @@ namespace Tests {
839
839
auto kqpProxySharedResources = std::make_shared<NKqp::TKqpProxySharedResources>();
840
840
841
841
IActor* kqpRmService = NKqp::CreateKqpResourceManagerActor (
842
- Settings->AppConfig . GetTableServiceConfig ().GetResourceManager (), nullptr , {}, kqpProxySharedResources);
842
+ Settings->AppConfig -> GetTableServiceConfig ().GetResourceManager (), nullptr , {}, kqpProxySharedResources);
843
843
TActorId kqpRmServiceId = Runtime->Register (kqpRmService, nodeIdx);
844
844
Runtime->RegisterService (NKqp::MakeKqpRmServiceID (Runtime->GetNodeId (nodeIdx)), kqpRmServiceId, nodeIdx);
845
845
@@ -851,7 +851,7 @@ namespace Tests {
851
851
852
852
std::shared_ptr<NKikimr::NKqp::IKqpFederatedQuerySetupFactory> federatedQuerySetupFactory = Settings->FederatedQuerySetupFactory ;
853
853
if (Settings->InitializeFederatedQuerySetupFactory ) {
854
- const auto & queryServiceConfig = Settings->AppConfig . GetQueryServiceConfig ();
854
+ const auto & queryServiceConfig = Settings->AppConfig -> GetQueryServiceConfig ();
855
855
856
856
auto httpProxyActorId = NFq::MakeYqlAnalyticsHttpProxyId ();
857
857
Runtime->RegisterService (
@@ -888,17 +888,17 @@ namespace Tests {
888
888
);
889
889
}
890
890
891
- IActor* kqpProxyService = NKqp::CreateKqpProxyService (Settings->AppConfig . GetLogConfig (),
892
- Settings->AppConfig . GetTableServiceConfig (),
893
- Settings->AppConfig . GetQueryServiceConfig (),
894
- Settings->AppConfig . GetMetadataProviderConfig (),
891
+ IActor* kqpProxyService = NKqp::CreateKqpProxyService (Settings->AppConfig -> GetLogConfig (),
892
+ Settings->AppConfig -> GetTableServiceConfig (),
893
+ Settings->AppConfig -> GetQueryServiceConfig (),
894
+ Settings->AppConfig -> GetMetadataProviderConfig (),
895
895
TVector<NKikimrKqp::TKqpSetting>(Settings->KqpSettings ),
896
896
nullptr , std::move (kqpProxySharedResources),
897
897
federatedQuerySetupFactory);
898
898
TActorId kqpProxyServiceId = Runtime->Register (kqpProxyService, nodeIdx);
899
899
Runtime->RegisterService (NKqp::MakeKqpProxyID (Runtime->GetNodeId (nodeIdx)), kqpProxyServiceId, nodeIdx);
900
900
901
- IActor* scriptFinalizeService = NKqp::CreateKqpFinalizeScriptService (Settings->AppConfig . GetQueryServiceConfig ().GetFinalizeScriptServiceConfig (), Settings->AppConfig . GetMetadataProviderConfig (), federatedQuerySetupFactory);
901
+ IActor* scriptFinalizeService = NKqp::CreateKqpFinalizeScriptService (Settings->AppConfig -> GetQueryServiceConfig ().GetFinalizeScriptServiceConfig (), Settings->AppConfig -> GetMetadataProviderConfig (), federatedQuerySetupFactory);
902
902
TActorId scriptFinalizeServiceId = Runtime->Register (scriptFinalizeService, nodeIdx);
903
903
Runtime->RegisterService (NKqp::MakeKqpFinalizeScriptServiceId (Runtime->GetNodeId (nodeIdx)), scriptFinalizeServiceId, nodeIdx);
904
904
}
@@ -1013,14 +1013,14 @@ namespace Tests {
1013
1013
Runtime->RegisterService (MakePollerActorId (), actorId, nodeIdx);
1014
1014
}
1015
1015
1016
- if (Settings->AppConfig . GetKafkaProxyConfig ().GetEnableKafkaProxy ()) {
1016
+ if (Settings->AppConfig -> GetKafkaProxyConfig ().GetEnableKafkaProxy ()) {
1017
1017
NKafka::TListenerSettings settings;
1018
- settings.Port = Settings->AppConfig . GetKafkaProxyConfig ().GetListeningPort ();
1019
- if (Settings->AppConfig . GetKafkaProxyConfig ().HasSslCertificate ()) {
1020
- settings.SslCertificatePem = Settings->AppConfig . GetKafkaProxyConfig ().GetSslCertificate ();
1018
+ settings.Port = Settings->AppConfig -> GetKafkaProxyConfig ().GetListeningPort ();
1019
+ if (Settings->AppConfig -> GetKafkaProxyConfig ().HasSslCertificate ()) {
1020
+ settings.SslCertificatePem = Settings->AppConfig -> GetKafkaProxyConfig ().GetSslCertificate ();
1021
1021
}
1022
1022
1023
- IActor* actor = NKafka::CreateKafkaListener (MakePollerActorId (), settings, Settings->AppConfig . GetKafkaProxyConfig ());
1023
+ IActor* actor = NKafka::CreateKafkaListener (MakePollerActorId (), settings, Settings->AppConfig -> GetKafkaProxyConfig ());
1024
1024
TActorId actorId = Runtime->Register (actor, nodeIdx);
1025
1025
Runtime->RegisterService (TActorId{}, actorId, nodeIdx);
1026
1026
@@ -1061,7 +1061,7 @@ namespace Tests {
1061
1061
{
1062
1062
auto & controlPlaneStorageConfig = *protoConfig.MutableControlPlaneStorage ();
1063
1063
controlPlaneStorageConfig.SetEnabled (true );
1064
- controlPlaneStorageConfig.SetUseInMemory (Settings->AppConfig . GetFederatedQueryConfig ().GetControlPlaneStorage ().GetUseInMemory ());
1064
+ controlPlaneStorageConfig.SetUseInMemory (Settings->AppConfig -> GetFederatedQueryConfig ().GetControlPlaneStorage ().GetUseInMemory ());
1065
1065
auto & storage = *controlPlaneStorageConfig.MutableStorage ();
1066
1066
storage.SetEndpoint (endpoint);
1067
1067
storage.SetTablePrefix (prefix);
0 commit comments