Conversation
af690c3 to
ecc5807
Compare
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
|
I think the csproj file is missing for BlueGreenConnection and BlueGreenConnection.Tests projects. |
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenConnectionPluginService.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenInterimStatus.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenPhase.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/SuspendConnectRouting.cs
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/BaseRouting.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/SuspendExecuteRouting.cs
Show resolved
Hide resolved
kenrickyap
left a comment
There was a problem hiding this comment.
NOICE WORK :):) added some comments
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/OnBlueGreenStatusChange.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatus.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
...aProvider.Plugin.BlueGreenConnection/BlueGreenConnection/Routing/SubstituteConnectRouting.cs
Outdated
Show resolved
Hide resolved
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
...r.Plugin.BlueGreenConnection/BlueGreenConnection/Dialect/BlueGreenConnectionDialectHelper.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
| this.pluginService = pluginService; | ||
| this.props = props; | ||
| this.providerSupplier = providerSupplier; | ||
| this.bgdId = PropertyDefinition.BgdId.GetString(this.props); |
There was a problem hiding this comment.
Should we normalize this like jdbc? Require it to be non null, trim, and also lowercase?
And curious, can users ever pass in null through the properties? This may blow up and we will get a NPE if we pass this in to routing.apply. Perhaps we should make bgId string instead of string? if possible
There was a problem hiding this comment.
I think it will use default value of property
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
...pperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenConnectionPlugin.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusMonitor.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusMonitor.cs
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusMonitor.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusMonitor.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusMonitor.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
...rapperDataProvider.Plugin.BlueGreenConnection/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
0473cd6 to
3df503d
Compare
d7c156a to
0035588
Compare
82f3958 to
74b80bd
Compare
9dcd290 to
0ff9f2e
Compare
docs/using-the-dotnet-driver/using-plugins/UsingTheBlueGreenPlugin.md
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/BaseExecuteRouting.cs
Show resolved
Hide resolved
AwsWrapperDataProvider.Plugin.SecretsManager/SecretsManager/SecretsManagerAuthPlugin.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/SubstituteConnectRouting.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/SuspendExecuteRouting.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/Routing/SuspendExecuteRouting.cs
Outdated
Show resolved
Hide resolved
...iver/Plugins/BlueGreenConnection/Routing/SuspendUntilCorrespondingNodeFoundConnectRouting.cs
Outdated
Show resolved
Hide resolved
...iver/Plugins/BlueGreenConnection/Routing/SuspendUntilCorrespondingNodeFoundConnectRouting.cs
Show resolved
Hide resolved
|
|
||
| while (bgStatus is { CurrentPhase: BlueGreenPhaseType.IN_PROGRESS }) | ||
| { | ||
| await this.Delay(this.sleepTimeMs, bgStatus, this.BgdId, cts.Token); |
There was a problem hiding this comment.
Looks like we are using cts.Token to interrupt this.Delay, curious if that will also interrupt this while loop while (bgStatus is { CurrentPhase: BlueGreenPhaseType.IN_PROGRESS }) or if you would still need stopwatch.ElapsedMilliseconds < timeoutMs
There was a problem hiding this comment.
It should interrupt the loop but I think putting in the time check would align better with the JDBC implementation.
AwsWrapperDataProvider/Driver/Plugins/ConnectionPluginChainBuilder.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/PhaseTimeInfo.cs
Outdated
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusProvider.cs
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusProvider.cs
Show resolved
Hide resolved
AwsWrapperDataProvider/Driver/Plugins/BlueGreenConnection/BlueGreenStatusProvider.cs
Outdated
Show resolved
Hide resolved
09d7ee2 to
6a74abd
Compare
|
|
||
| private static readonly string TopologyQuery = | ||
| $"SELECT id, endpoint, port FROM rds_tools.show_topology('aws_dotnet_driver-{DriverVersion}')"; | ||
| $"SELECT id, endpoint, port FROM rds_tools.show_topology('aws_advanced_dotnet_data_provider_wrapper-{DriverVersion}')"; |
There was a problem hiding this comment.
could we grab the version dynamically here too
There was a problem hiding this comment.
Going to change in future PR
Summary
Description
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.