Skip to content

Commit

Permalink
Use ControlPlaneConnection instead of ExecutionConnection
Browse files Browse the repository at this point in the history
  • Loading branch information
Hor911 committed Feb 25, 2024
1 parent a34d029 commit 88a8f32
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -370,7 +370,7 @@ class TComputeDatabaseControlPlaneServiceActor : public NActors::TActorBootstrap
auto monitoringEndpoint = loadConfig.GetMonitoringEndpoint();
auto credentialsProvider = CredentialsProviderFactory(GetYdbCredentialSettings(config.GetControlPlaneConnection()))->CreateProvider();
if (monitoringEndpoint) {
clientActor = Register(CreateMonitoringRestClientActor(monitoringEndpoint, config.GetExecutionConnection().GetDatabase(), credentialsProvider).release());
clientActor = Register(CreateMonitoringRestClientActor(monitoringEndpoint, config.GetControlPlaneConnection().GetDatabase(), credentialsProvider).release());
} else {
clientActor = Register(CreateMonitoringGrpcClientActor(CreateGrpcClientSettings(config), credentialsProvider).release());
}
Expand All @@ -393,7 +393,7 @@ class TComputeDatabaseControlPlaneServiceActor : public NActors::TActorBootstrap
auto monitoringEndpoint = loadConfig.GetMonitoringEndpoint();
auto credentialsProvider = CredentialsProviderFactory(GetYdbCredentialSettings(config.GetControlPlaneConnection()))->CreateProvider();
if (monitoringEndpoint) {
clientActor = Register(CreateMonitoringRestClientActor(monitoringEndpoint, config.GetExecutionConnection().GetDatabase(), credentialsProvider).release());
clientActor = Register(CreateMonitoringRestClientActor(monitoringEndpoint, config.GetControlPlaneConnection().GetDatabase(), credentialsProvider).release());
} else {
clientActor = Register(CreateMonitoringGrpcClientActor(CreateGrpcClientSettings(config), credentialsProvider).release());
}
Expand Down

0 comments on commit 88a8f32

Please sign in to comment.