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 java.util.Map<java.lang.String,HostSpec>	instanceTemplatesByRegion
protected GlobalAuroraTopologyUtils	topologyUtils

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

closeConnectionNetworkTimeoutMs, clusterId, completedOneCycle, defaultConnectionTimeoutMs, defaultSocketTimeoutMs, highRefreshPeriodAfterPanicNano, highRefreshRateEndTimeNano, highRefreshRateNano, hostSpecExtractor, initialHostSpec, instanceTemplate, isVerifiedWriterConnection, logUnclosedConnections, MONITORING_PROPERTY_PREFIX, monitoringConnection, monitoringProperties, monitorTerminationTimeoutSec, networkTimeoutExecutor, nodeExecutorLock, nodeExecutorService, nodeThreadsLatestTopology, nodeThreadsReaderConnection, nodeThreadsStop, nodeThreadsWriterConnection, nodeThreadsWriterHostSpec, properties, rdsHelper, readerTopologiesById, refreshRateNano, requestToUpdateTopology, servicesContainer, stableTopologiesDurationNano, 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 HostSpec	getInstanceTemplate(java.lang.String instanceId, java.sql.Connection connection)
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
protected 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, getNodeMonitoringWorker, isInPanicMode, monitor, nodeThreadConnectionCleanUp, openAnyConnectionAndUpdateTopology, processEvent, reset, stop, updateHostsAvailability, updateTopologyCache, waitForTopologyUpdate

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

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(java.lang.String instanceId,
                                       java.sql.Connection connection)
                                throws java.sql.SQLException

Overrides:

getInstanceTemplate in class ClusterTopologyMonitorImpl

Throws:

java.sql.SQLException

queryForTopology

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

Overrides:

queryForTopology in class ClusterTopologyMonitorImpl

Throws:

java.sql.SQLException

getSnapshotState

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

Specified by:

getSnapshotState in interface StateSnapshotProvider

Overrides:

getSnapshotState in class ClusterTopologyMonitorImpl