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_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	blueDnsUpdateCompleted
protected java.lang.String	clusterId
protected java.util.Map<java.lang.String,Pair<HostSpec,HostSpec>>	correspondingNodes
protected boolean	greenDnsRemoved
protected java.util.Map<java.lang.String,java.time.Instant>	greenNodeChangeNameTimes
protected boolean	greenTopologyChanged
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 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 BlueGreenStatusMonitor[]	monitors
protected java.util.Map<java.lang.String,BlueGreenStatusProvider.PhaseTimeInfo>	phaseTimeNano
protected PluginService	pluginService
protected long	postStatusEndTimeNano
protected java.util.concurrent.locks.ReentrantLock	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 BlueGreenStatus	summaryStatus
protected long	switchoverTimeoutNano

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	createPostRouting(java.util.List<ConnectRouting> connectRouting)
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	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

hostSpecBuilder

protected final HostSpecBuilder hostSpecBuilder

monitors

protected final BlueGreenStatusMonitor[] monitors

interimStatusHashes

protected int[] interimStatusHashes

lastContextHash

protected int lastContextHash

interimStatuses

protected 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 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

postStatusEndTimeNano

protected long postStatusEndTimeNano

processStatusLock

protected final java.util.concurrent.locks.ReentrantLock 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

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)

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()

logCurrentContext

protected void logCurrentContext()