software.amazon.jdbc.plugin.bluegreen

Class BlueGreenStatusProvider

java.lang.Object

software.amazon.jdbc.plugin.bluegreen.BlueGreenStatusProvider

public class BlueGreenStatusProvider
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlueGreenStatusProvider.PhaseTimeInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicBoolean	allGreenNodesChangedName
static AwsWrapperProperty	BG_DROP_BLUE_CONNECTIONS
static AwsWrapperProperty	BG_INTERVAL_BASELINE_MS
static AwsWrapperProperty	BG_INTERVAL_HIGH_MS
static AwsWrapperProperty	BG_INTERVAL_INCREASED_MS
static AwsWrapperProperty	BG_SWITCHOVER_TIMEOUT_MS
protected java.lang.String	bgdId
protected boolean	blueConnectionsDropped
protected boolean	blueDnsUpdateCompleted
protected java.lang.String	clusterId
protected java.util.Map<java.lang.String,Pair<HostSpec,HostSpec>>	correspondingNodes
protected boolean	dropBlueConnectionsSetting
protected boolean	greenDnsRemoved
protected java.util.Map<java.lang.String,java.time.Instant>	greenNodeChangeNameTimes
protected boolean	greenTopologyChanged
protected java.util.concurrent.atomic.AtomicBoolean	greenTopologyRecognizedLogged
protected java.util.Map<java.lang.String,java.util.Optional<java.lang.String>>	hostIpAddresses
protected HostSpecBuilder	hostSpecBuilder
protected java.util.Map<java.lang.String,java.util.Set<java.lang.String>>	iamHostSuccessfulConnects
protected @Nullable BlueGreenInterimStatus[]	interimStatuses
protected int[]	interimStatusHashes
protected int	lastContextHash
protected BlueGreenPhase	latestStatusPhase
protected java.util.concurrent.atomic.AtomicBoolean	monitorResetOnInProgressCompleted
protected java.util.concurrent.atomic.AtomicBoolean	monitorResetOnTopologyCompleted
protected @Nullable BlueGreenStatusMonitor[]	monitors
protected java.util.Map<java.lang.String,BlueGreenStatusProvider.PhaseTimeInfo>	phaseTimeNano
protected PluginService	pluginService
protected long	postStatusEndTimeNano
protected ResourceLock	processStatusLock
protected java.util.Properties	props
protected RdsUtils	rdsUtils
protected java.util.Map<java.lang.String,BlueGreenRole>	roleByHost
protected boolean	rollback
protected FullServicesContainer	servicesContainer
protected java.util.Map<BlueGreenIntervalRate,java.lang.Long>	statusCheckIntervalMap
protected StorageService	storageService
protected @Nullable BlueGreenStatus	summaryStatus
protected long	switchoverTimeoutNano
protected @Nullable OpenedConnectionTracker	tracker

Constructor Summary

Constructors

Constructor and Description
BlueGreenStatusProvider(@NonNull FullServicesContainer servicesContainer, @NonNull java.util.Properties props, @NonNull java.lang.String bgdId, @NonNull java.lang.String clusterId)

Method Summary

Modifier and Type	Method and Description
protected java.util.List<ConnectRouting>	addSubstituteBlueWithIpAddressConnectRouting()
protected void	checkSwitchoverTimerExpiry() Checks if the switchover timer has expired while the plugin is still in an active switchover phase (IN_PROGRESS or POST).
protected void	createPostRouting(java.util.List<ConnectRouting> connectRouting)
protected void	dropBlueConnections()
protected static java.util.List<java.lang.String>	formatTwoColumnRows(java.util.List<java.lang.String[]> rows) Formats a list of two-element rows into aligned, indented columns.
protected int	getContextHash()
protected java.lang.String	getHostAndPort(java.lang.String host, int port)
protected java.util.Properties	getMonitoringProperties()
protected long	getNanoTime() For testing purposes.
protected @Nullable java.util.List<HostSpec>	getReaderHosts(BlueGreenRole role)
protected BlueGreenStatus	getStatusOfCompleted()
protected BlueGreenStatus	getStatusOfCreated()
protected BlueGreenStatus	getStatusOfInProgress() New connect requests to blue: suspend or route to corresponding IP address (depending on settings).
protected BlueGreenStatus	getStatusOfPost()
protected BlueGreenStatus	getStatusOfPreparation() New connect requests to blue: route to corresponding IP address.
protected int	getValueHash(int currentHash, java.lang.String val)
protected @Nullable HostSpec	getWriterHost(BlueGreenRole role)
protected void	initMonitoring()
protected boolean	isAlreadySuccessfullyConnected(java.lang.String connectHost, java.lang.String iamHost)
protected boolean	isSwitchoverTimerExpired()
protected void	logCurrentContext()
protected void	logGreenTopologyRecognized() Emits a concise, operationally useful readiness event once the plugin has recognized the target green topology for the configured bgdId.
protected void	logSwitchoverFinalSummary()
protected void	prepareStatus(@NonNull BlueGreenRole role, @NonNull BlueGreenInterimStatus interimStatus)
protected void	registerIamHost(java.lang.String connectHost, java.lang.String iamHost)
protected void	resetContextWhenCompleted()
protected void	resetMonitors(java.util.concurrent.atomic.AtomicBoolean monitorResetCompleted, java.lang.String eventName)
protected void	startSwitchoverTimer()
protected void	storeBlueDnsUpdateTime()
protected void	storeGreenDnsRemoveTime()
protected void	storeGreenNodeChangeNameTime()
protected void	storeGreenTopologyChangeTime()
protected void	storeMonitorResetTime(java.lang.String eventName)
protected void	storePhaseTime(BlueGreenPhase phase)
protected void	updateCorrespondingNodes() Update corresponding nodes Blue writer node is mapped to a green writer node.
protected void	updateDnsFlags(BlueGreenRole role, BlueGreenInterimStatus interimStatus)
protected void	updateMonitors()
protected void	updatePhase(BlueGreenRole role, BlueGreenInterimStatus interimStatus)
protected void	updateStatusCache()
protected void	updateSummaryStatus(BlueGreenRole role, BlueGreenInterimStatus interimStatus)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BG_INTERVAL_BASELINE_MS

public static final AwsWrapperProperty BG_INTERVAL_BASELINE_MS

BG_INTERVAL_INCREASED_MS

public static final AwsWrapperProperty BG_INTERVAL_INCREASED_MS

BG_INTERVAL_HIGH_MS

public static final AwsWrapperProperty BG_INTERVAL_HIGH_MS

BG_SWITCHOVER_TIMEOUT_MS

public static final AwsWrapperProperty BG_SWITCHOVER_TIMEOUT_MS

BG_DROP_BLUE_CONNECTIONS

public static final AwsWrapperProperty BG_DROP_BLUE_CONNECTIONS

hostSpecBuilder

protected final HostSpecBuilder hostSpecBuilder

monitors

protected final @Nullable BlueGreenStatusMonitor[] monitors

interimStatusHashes

protected int[] interimStatusHashes

lastContextHash

protected int lastContextHash

interimStatuses

protected @Nullable BlueGreenInterimStatus[] interimStatuses

hostIpAddresses

protected final java.util.Map<java.lang.String,java.util.Optional<java.lang.String>> hostIpAddresses

correspondingNodes

protected final java.util.Map<java.lang.String,Pair<HostSpec,HostSpec>> correspondingNodes

roleByHost

protected final java.util.Map<java.lang.String,BlueGreenRole> roleByHost

iamHostSuccessfulConnects

protected final java.util.Map<java.lang.String,java.util.Set<java.lang.String>> iamHostSuccessfulConnects

greenNodeChangeNameTimes

protected final java.util.Map<java.lang.String,java.time.Instant> greenNodeChangeNameTimes

summaryStatus

protected @Nullable BlueGreenStatus summaryStatus

latestStatusPhase

protected BlueGreenPhase latestStatusPhase

rollback

protected boolean rollback

blueDnsUpdateCompleted

protected boolean blueDnsUpdateCompleted

greenDnsRemoved

protected boolean greenDnsRemoved

greenTopologyChanged

protected boolean greenTopologyChanged

monitorResetOnInProgressCompleted

protected java.util.concurrent.atomic.AtomicBoolean monitorResetOnInProgressCompleted

monitorResetOnTopologyCompleted

protected java.util.concurrent.atomic.AtomicBoolean monitorResetOnTopologyCompleted

allGreenNodesChangedName

protected final java.util.concurrent.atomic.AtomicBoolean allGreenNodesChangedName

greenTopologyRecognizedLogged

protected final java.util.concurrent.atomic.AtomicBoolean greenTopologyRecognizedLogged

postStatusEndTimeNano

protected long postStatusEndTimeNano

processStatusLock

protected final ResourceLock processStatusLock

statusCheckIntervalMap

protected final java.util.Map<BlueGreenIntervalRate,java.lang.Long> statusCheckIntervalMap

switchoverTimeoutNano

protected final long switchoverTimeoutNano

servicesContainer

protected final FullServicesContainer servicesContainer

storageService

protected final StorageService storageService

pluginService

protected final PluginService pluginService

props

protected final java.util.Properties props

bgdId

protected final java.lang.String bgdId

clusterId

protected final java.lang.String clusterId

phaseTimeNano

protected java.util.Map<java.lang.String,BlueGreenStatusProvider.PhaseTimeInfo> phaseTimeNano

rdsUtils

protected final RdsUtils rdsUtils

tracker

protected @Nullable OpenedConnectionTracker tracker

dropBlueConnectionsSetting

protected final boolean dropBlueConnectionsSetting

blueConnectionsDropped

protected boolean blueConnectionsDropped

Constructor Detail

BlueGreenStatusProvider

public BlueGreenStatusProvider(@NonNull FullServicesContainer servicesContainer,
                               @NonNull java.util.Properties props,
                               @NonNull java.lang.String bgdId,
                               @NonNull java.lang.String clusterId)

Method Detail

initMonitoring

protected void initMonitoring()

getMonitoringProperties

protected java.util.Properties getMonitoringProperties()

prepareStatus

protected void prepareStatus(@NonNull BlueGreenRole role,
                             @NonNull BlueGreenInterimStatus interimStatus)

updatePhase

protected void updatePhase(BlueGreenRole role,
                           BlueGreenInterimStatus interimStatus)

updateStatusCache

protected void updateStatusCache()

updateCorrespondingNodes

protected void updateCorrespondingNodes()

Update corresponding nodes Blue writer node is mapped to a green writer node. Blue reader nodes are mapped to green reader nodes.

getWriterHost

protected @Nullable HostSpec getWriterHost(BlueGreenRole role)

getReaderHosts

protected @Nullable java.util.List<HostSpec> getReaderHosts(BlueGreenRole role)

updateSummaryStatus

protected void updateSummaryStatus(BlueGreenRole role,
                                   BlueGreenInterimStatus interimStatus)

updateMonitors

protected void updateMonitors()

updateDnsFlags

protected void updateDnsFlags(BlueGreenRole role,
                              BlueGreenInterimStatus interimStatus)

resetMonitors

protected void resetMonitors(java.util.concurrent.atomic.AtomicBoolean monitorResetCompleted,
                             java.lang.String eventName)

dropBlueConnections

protected void dropBlueConnections()

getContextHash

protected int getContextHash()

getValueHash

protected int getValueHash(int currentHash,
                           java.lang.String val)

getHostAndPort

protected java.lang.String getHostAndPort(java.lang.String host,
                                          int port)

getStatusOfCreated

protected BlueGreenStatus getStatusOfCreated()

getStatusOfPreparation

protected BlueGreenStatus getStatusOfPreparation()

New connect requests to blue: route to corresponding IP address. New connect requests to green: route to corresponding IP address New connect requests with IP address: default behaviour; no routing Existing connections: default behaviour; no action Execute JDBC calls: default behaviour; no action

Returns:

Blue/Green status

addSubstituteBlueWithIpAddressConnectRouting

protected java.util.List<ConnectRouting> addSubstituteBlueWithIpAddressConnectRouting()

getStatusOfInProgress

protected BlueGreenStatus getStatusOfInProgress()

New connect requests to blue: suspend or route to corresponding IP address (depending on settings). New connect requests to green: suspend New connect requests with IP address: suspend Existing connections: default behaviour; no action Execute JDBC calls: suspend

Returns:

Blue/Green status

getStatusOfPost

protected BlueGreenStatus getStatusOfPost()

createPostRouting

protected void createPostRouting(java.util.List<ConnectRouting> connectRouting)

getStatusOfCompleted

protected BlueGreenStatus getStatusOfCompleted()

registerIamHost

protected void registerIamHost(java.lang.String connectHost,
                               java.lang.String iamHost)

isAlreadySuccessfullyConnected

protected boolean isAlreadySuccessfullyConnected(java.lang.String connectHost,
                                                 java.lang.String iamHost)

getNanoTime

protected long getNanoTime()

For testing purposes.

Returns:

current time in nanoseconds

storePhaseTime

protected void storePhaseTime(BlueGreenPhase phase)

storeBlueDnsUpdateTime

protected void storeBlueDnsUpdateTime()

storeGreenDnsRemoveTime

protected void storeGreenDnsRemoveTime()

storeGreenNodeChangeNameTime

protected void storeGreenNodeChangeNameTime()

storeGreenTopologyChangeTime

protected void storeGreenTopologyChangeTime()

storeMonitorResetTime

protected void storeMonitorResetTime(java.lang.String eventName)

logSwitchoverFinalSummary

protected void logSwitchoverFinalSummary()

resetContextWhenCompleted

protected void resetContextWhenCompleted()

startSwitchoverTimer

protected void startSwitchoverTimer()

isSwitchoverTimerExpired

protected boolean isSwitchoverTimerExpired()

checkSwitchoverTimerExpiry

protected void checkSwitchoverTimerExpiry()

Checks if the switchover timer has expired while the plugin is still in an active switchover phase (IN_PROGRESS or POST). If expired, forces a transition to COMPLETED (or CREATED on rollback) and updates the status cache. This ensures the plugin does not remain stuck indefinitely when the monitor cannot detect the phase change from RDS.

logCurrentContext

protected void logCurrentContext()

logGreenTopologyRecognized

protected void logGreenTopologyRecognized()

Emits a concise, operationally useful readiness event once the plugin has recognized the target green topology for the configured bgdId. Readiness means both the source and target interim statuses are available and the blue-to-green corresponding node map has been populated. The event is logged at most once per deployment cycle (reset by resetContextWhenCompleted()) so operators can confirm per-instance readiness before initiating a manual switchover, without producing hot-path log spam.

formatTwoColumnRows

protected static java.util.List<java.lang.String> formatTwoColumnRows(java.util.List<java.lang.String[]> rows)

Formats a list of two-element rows into aligned, indented columns. The left column is padded to the width of its widest value so the right column starts at the same offset on every row.

Parameters:

rows - the rows to format, each as a [left, right] pair.

Returns:

the formatted, indented row strings.