software.amazon.jdbc.hostlistprovider

Class GlobalAuroraTopologyMonitor

java.lang.Object

software.amazon.jdbc.util.monitoring.AbstractMonitor

software.amazon.jdbc.hostlistprovider.ClusterTopologyMonitorImpl

software.amazon.jdbc.hostlistprovider.GlobalAuroraTopologyMonitor

All Implemented Interfaces:

java.lang.Runnable, ClusterTopologyMonitor, EventSubscriber, Monitor, StateSnapshotProvider

public class GlobalAuroraTopologyMonitor
extends ClusterTopologyMonitorImpl

Field Summary

Fields

Modifier and Type	Field and Description
protected @Nullable java.util.Set<java.lang.String>	accessibleRegions
protected java.util.Map<java.lang.String,HostSpec>	instanceTemplatesByRegion
protected RdsUtils	rdsUtils
protected GlobalAuroraTopologyUtils	topologyUtils

Fields inherited from class software.amazon.jdbc.hostlistprovider.ClusterTopologyMonitorImpl

closeConnectionNetworkTimeoutMs, clusterId, completedOneCycle, connectionHandler, defaultConnectionTimeoutMs, defaultSocketTimeoutMs, fatalError, highRefreshPeriodAfterPanicNano, highRefreshRateEndTimeNano, highRefreshRateNano, hostSpecExtractor, initialHostSpec, instanceTemplate, lastKnownWriterHostSpec, logUnclosedConnections, MONITORING_PROPERTY_PREFIX, monitoringConnection, monitoringProperties, monitorTerminationTimeoutSec, networkTimeoutExecutor, nodeExecutorLock, nodeExecutorService, nodeThreadsConnections, nodeThreadsLatestTopology, nodeThreadsStop, nodeThreadsWriterHostSpec, properties, rdsHelper, readerTopologiesById, refreshRateNano, requestToUpdateTopology, servicesContainer, stableTopologiesStartNano, submittedNodes, topologyUpdated, writerHostSpec

Fields inherited from class software.amazon.jdbc.util.monitoring.AbstractMonitor

lastActivityTimestampNanos, monitorExecutor, state, stop, terminationTimeoutSec

Constructor Summary

Constructors

Constructor and Description
GlobalAuroraTopologyMonitor(FullServicesContainer servicesContainer, GlobalAuroraTopologyUtils topologyUtils, java.lang.String clusterId, HostSpec initialHostSpec, java.util.Properties properties, HostSpec instanceTemplate, long refreshRateNano, long highRefreshRateNano, java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion)

Method Summary

Modifier and Type	Method and Description
protected MonitoringConnectionHandler	createConnectionHandler()
protected java.util.List<HostSpec>	filterHostsForNodeMonitoring(java.util.List<HostSpec> hosts) Filters the list of hosts that should be used for node monitoring during panic mode.
protected HostSpec	getInstanceTemplate(@Nullable java.lang.String instanceId, java.sql.Connection connection)
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
protected long	getStableTopologiesDurationNano()
protected @Nullable java.util.List<HostSpec>	openAnyConnectionAndUpdateTopology()
protected @Nullable java.util.List<HostSpec>	queryForTopology(java.sql.Connection connection)

Methods inherited from class software.amazon.jdbc.hostlistprovider.ClusterTopologyMonitorImpl

canDispose, checkForStableReaderTopologies, clearTopologyCache, close, closeConnection, closeNodeMonitors, createNodeExecutorService, delay, fetchTopologyAndUpdateCache, forceRefresh, getConnectionHandler, getNodeMonitoringWorker, getStoredHosts, isInPanicMode, isUnresolvableDueToMisconfiguration, monitor, nodeThreadConnectionCleanUp, processEvent, recordFatalError, reset, stop, submitNodeMonitorIfAbsent, throwIfFatalError, updateHostsAvailability, updateTopologyCache, waitForTopologyUpdate, wakeUpMonitoringLoop

Methods inherited from class software.amazon.jdbc.util.monitoring.AbstractMonitor

getLastActivityTimestampNanos, getState, run, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.jdbc.util.monitoring.Monitor

getLastActivityTimestampNanos, getState, start

Field Detail

instanceTemplatesByRegion

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

topologyUtils

protected final GlobalAuroraTopologyUtils topologyUtils

accessibleRegions

protected final @Nullable java.util.Set<java.lang.String> accessibleRegions

rdsUtils

protected final RdsUtils rdsUtils

Constructor Detail

GlobalAuroraTopologyMonitor

public GlobalAuroraTopologyMonitor(FullServicesContainer servicesContainer,
                                   GlobalAuroraTopologyUtils topologyUtils,
                                   java.lang.String clusterId,
                                   HostSpec initialHostSpec,
                                   java.util.Properties properties,
                                   HostSpec instanceTemplate,
                                   long refreshRateNano,
                                   long highRefreshRateNano,
                                   java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion)

Method Detail

getInstanceTemplate

protected HostSpec getInstanceTemplate(@Nullable java.lang.String instanceId,
                                       java.sql.Connection connection)
                                throws java.sql.SQLException

Overrides:

getInstanceTemplate in class ClusterTopologyMonitorImpl

Throws:

java.sql.SQLException

queryForTopology

protected @Nullable java.util.List<HostSpec> queryForTopology(java.sql.Connection connection)
                                                       throws java.sql.SQLException

Overrides:

queryForTopology in class ClusterTopologyMonitorImpl

Throws:

java.sql.SQLException

openAnyConnectionAndUpdateTopology

protected @Nullable java.util.List<HostSpec> openAnyConnectionAndUpdateTopology()

Overrides:

openAnyConnectionAndUpdateTopology in class ClusterTopologyMonitorImpl

filterHostsForNodeMonitoring

protected java.util.List<HostSpec> filterHostsForNodeMonitoring(java.util.List<HostSpec> hosts)

Description copied from class: ClusterTopologyMonitorImpl

Filters the list of hosts that should be used for node monitoring during panic mode. Subclasses can override this to restrict which hosts are eligible for connection attempts.

Overrides:

filterHostsForNodeMonitoring in class ClusterTopologyMonitorImpl

Parameters:

hosts - the full list of hosts from the topology

Returns:

the filtered list of hosts to use for node monitoring

createConnectionHandler

protected MonitoringConnectionHandler createConnectionHandler()

Overrides:

createConnectionHandler in class ClusterTopologyMonitorImpl

getStableTopologiesDurationNano

protected long getStableTopologiesDurationNano()

Overrides:

getStableTopologiesDurationNano in class ClusterTopologyMonitorImpl

getSnapshotState

public java.util.List<Pair<java.lang.String,java.lang.Object>> getSnapshotState()

Specified by:

getSnapshotState in interface StateSnapshotProvider

Overrides:

getSnapshotState in class ClusterTopologyMonitorImpl