software.amazon.jdbc.hostlistprovider.monitoring

Class ClusterTopologyMonitorImpl

java.lang.Object

software.amazon.jdbc.hostlistprovider.monitoring.ClusterTopologyMonitorImpl

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, ClusterTopologyMonitor

Direct Known Subclasses:

MultiAzClusterTopologyMonitorImpl

public class ClusterTopologyMonitorImpl
extends java.lang.Object
implements ClusterTopologyMonitor

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	closeConnectionNetworkTimeoutMs
protected java.lang.String	clusterId
protected HostSpec	clusterInstanceTemplate
protected static int	defaultConnectionTimeoutMs
protected static int	defaultSocketTimeoutMs
protected static int	defaultTopologyQueryTimeoutMs
protected static long	highRefreshPeriodAfterPanicNano
protected long	highRefreshRateEndTimeNano
protected long	highRefreshRateNano
protected HostListProviderService	hostListProviderService
protected java.util.concurrent.atomic.AtomicLong	ignoreNewTopologyRequestsEndTimeNano
protected static long	ignoreTopologyRequestNano
protected HostSpec	initialHostSpec
protected boolean	isVerifiedWriterConnection
protected java.util.concurrent.ExecutorService	monitorExecutor
protected static java.lang.String	MONITORING_PROPERTY_PREFIX
protected java.util.concurrent.atomic.AtomicReference<java.sql.Connection>	monitoringConnection
protected java.util.Properties	monitoringProperties
protected static java.util.concurrent.Executor	networkTimeoutExecutor
protected java.lang.String	nodeIdQuery
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Thread>	nodeThreads
protected java.util.concurrent.atomic.AtomicReference<java.util.List<HostSpec>>	nodeThreadsLatestTopology
protected java.util.concurrent.atomic.AtomicReference<java.sql.Connection>	nodeThreadsReaderConnection
protected java.util.concurrent.atomic.AtomicBoolean	nodeThreadsStop
protected java.util.concurrent.atomic.AtomicReference<java.sql.Connection>	nodeThreadsWriterConnection
protected java.util.concurrent.atomic.AtomicReference<HostSpec>	nodeThreadsWriterHostSpec
protected PluginService	pluginService
protected java.util.Properties	properties
protected static RdsUtils	rdsHelper
protected long	refreshRateNano
protected java.util.concurrent.atomic.AtomicBoolean	requestToUpdateTopology
protected java.util.concurrent.atomic.AtomicBoolean	stop
protected long	topologyCacheExpirationNano
protected CacheMap<java.lang.String,java.util.List<HostSpec>>	topologyMap
protected java.lang.String	topologyQuery
protected java.lang.Object	topologyUpdated
protected java.util.concurrent.atomic.AtomicReference<HostSpec>	writerHostSpec
protected java.lang.String	writerTopologyQuery

Constructor Summary

Constructors

Constructor and Description

ClusterTopologyMonitorImpl(java.lang.String clusterId, CacheMap<java.lang.String,java.util.List<HostSpec>> topologyMap, HostSpec initialHostSpec, java.util.Properties properties, PluginService pluginService, HostListProviderService hostListProviderService, HostSpec clusterInstanceTemplate, long refreshRateNano, long highRefreshRateNano, long topologyCacheExpirationNano, java.lang.String topologyQuery, java.lang.String writerTopologyQuery, java.lang.String nodeIdQuery)

Method Summary

Modifier and Type	Method and Description
boolean	canDispose()
void	close()
protected void	closeConnection(@Nullable java.sql.Connection connection)
protected void	closeConnection(@Nullable java.sql.Connection connection, boolean unstableConnection)
protected HostSpec	createHost(java.sql.ResultSet resultSet, java.lang.String suggestedWriterNodeId)
protected HostSpec	createHost(java.lang.String nodeName, boolean isWriter, long weight, java.sql.Timestamp lastUpdateTime)
protected void	delay(boolean useHighRefreshRate)
protected @Nullable java.util.List<HostSpec>	fetchTopologyAndUpdateCache(java.sql.Connection connection)
java.util.List<HostSpec>	forceRefresh(boolean shouldVerifyWriter, long timeoutMs)
java.util.List<HostSpec>	forceRefresh(@Nullable java.sql.Connection connection, long timeoutMs)
protected java.lang.String	getHostEndpoint(java.lang.String nodeName)
protected java.lang.String	getNodeId(java.sql.Connection connection)
protected java.lang.Thread	getNodeMonitoringThread(HostSpec hostSpec, @Nullable HostSpec writerHostSpec)
protected java.lang.String	getSuggestedWriterNodeId(java.sql.Connection connection)
protected java.lang.String	getWriterNodeId(java.sql.Connection connection)
protected boolean	isInPanicMode()
protected java.util.List<HostSpec>	openAnyConnectionAndUpdateTopology()
protected java.util.List<HostSpec>	processQueryResults(java.sql.ResultSet resultSet, java.lang.String suggestedWriterNodeId)
protected java.util.List<HostSpec>	queryForTopology(java.sql.Connection conn)
void	run()
void	setClusterId(java.lang.String clusterId)
protected void	updateTopologyCache(@NonNull java.util.List<HostSpec> hosts)
protected java.util.List<HostSpec>	waitTillTopologyGetsUpdated(long timeoutMs)

Methods inherited from class java.lang.Object

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

Field Detail

MONITORING_PROPERTY_PREFIX

protected static final java.lang.String MONITORING_PROPERTY_PREFIX

See Also:

Constant Field Values

networkTimeoutExecutor

protected static final java.util.concurrent.Executor networkTimeoutExecutor

rdsHelper

protected static final RdsUtils rdsHelper

defaultTopologyQueryTimeoutMs

protected static final int defaultTopologyQueryTimeoutMs

See Also:

Constant Field Values

closeConnectionNetworkTimeoutMs

protected static final int closeConnectionNetworkTimeoutMs

See Also:

Constant Field Values

defaultConnectionTimeoutMs

protected static final int defaultConnectionTimeoutMs

See Also:

Constant Field Values

defaultSocketTimeoutMs

protected static final int defaultSocketTimeoutMs

See Also:

Constant Field Values

highRefreshPeriodAfterPanicNano

protected static final long highRefreshPeriodAfterPanicNano

ignoreTopologyRequestNano

protected static final long ignoreTopologyRequestNano

refreshRateNano

protected final long refreshRateNano

highRefreshRateNano

protected final long highRefreshRateNano

topologyCacheExpirationNano

protected final long topologyCacheExpirationNano

properties

protected final java.util.Properties properties

monitoringProperties

protected final java.util.Properties monitoringProperties

pluginService

protected final PluginService pluginService

initialHostSpec

protected final HostSpec initialHostSpec

topologyMap

protected final CacheMap<java.lang.String,java.util.List<HostSpec>> topologyMap

topologyQuery

protected final java.lang.String topologyQuery

nodeIdQuery

protected final java.lang.String nodeIdQuery

writerTopologyQuery

protected final java.lang.String writerTopologyQuery

hostListProviderService

protected final HostListProviderService hostListProviderService

clusterInstanceTemplate

protected final HostSpec clusterInstanceTemplate

clusterId

protected java.lang.String clusterId

writerHostSpec

protected final java.util.concurrent.atomic.AtomicReference<HostSpec> writerHostSpec

monitoringConnection

protected final java.util.concurrent.atomic.AtomicReference<java.sql.Connection> monitoringConnection

isVerifiedWriterConnection

protected boolean isVerifiedWriterConnection

stop

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

highRefreshRateEndTimeNano

protected long highRefreshRateEndTimeNano

topologyUpdated

protected final java.lang.Object topologyUpdated

requestToUpdateTopology

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

ignoreNewTopologyRequestsEndTimeNano

protected final java.util.concurrent.atomic.AtomicLong ignoreNewTopologyRequestsEndTimeNano

nodeThreads

protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Thread> nodeThreads

nodeThreadsStop

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

nodeThreadsWriterConnection

protected final java.util.concurrent.atomic.AtomicReference<java.sql.Connection> nodeThreadsWriterConnection

nodeThreadsWriterHostSpec

protected final java.util.concurrent.atomic.AtomicReference<HostSpec> nodeThreadsWriterHostSpec

nodeThreadsReaderConnection

protected final java.util.concurrent.atomic.AtomicReference<java.sql.Connection> nodeThreadsReaderConnection

nodeThreadsLatestTopology

protected final java.util.concurrent.atomic.AtomicReference<java.util.List<HostSpec>> nodeThreadsLatestTopology

monitorExecutor

protected final java.util.concurrent.ExecutorService monitorExecutor

Constructor Detail

ClusterTopologyMonitorImpl

public ClusterTopologyMonitorImpl(java.lang.String clusterId,
                                  CacheMap<java.lang.String,java.util.List<HostSpec>> topologyMap,
                                  HostSpec initialHostSpec,
                                  java.util.Properties properties,
                                  PluginService pluginService,
                                  HostListProviderService hostListProviderService,
                                  HostSpec clusterInstanceTemplate,
                                  long refreshRateNano,
                                  long highRefreshRateNano,
                                  long topologyCacheExpirationNano,
                                  java.lang.String topologyQuery,
                                  java.lang.String writerTopologyQuery,
                                  java.lang.String nodeIdQuery)

Method Detail

canDispose

public boolean canDispose()

Specified by:

canDispose in interface ClusterTopologyMonitor

setClusterId

public void setClusterId(java.lang.String clusterId)

Specified by:

setClusterId in interface ClusterTopologyMonitor

forceRefresh

public java.util.List<HostSpec> forceRefresh(boolean shouldVerifyWriter,
                                             long timeoutMs)
                                      throws java.sql.SQLException,
                                             java.util.concurrent.TimeoutException

Specified by:

forceRefresh in interface ClusterTopologyMonitor

Throws:

java.sql.SQLException

java.util.concurrent.TimeoutException

forceRefresh

public java.util.List<HostSpec> forceRefresh(@Nullable java.sql.Connection connection,
                                             long timeoutMs)
                                      throws java.sql.SQLException,
                                             java.util.concurrent.TimeoutException

Specified by:

forceRefresh in interface ClusterTopologyMonitor

Throws:

java.sql.SQLException

java.util.concurrent.TimeoutException

waitTillTopologyGetsUpdated

protected java.util.List<HostSpec> waitTillTopologyGetsUpdated(long timeoutMs)
                                                        throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable

isInPanicMode

protected boolean isInPanicMode()

getNodeMonitoringThread

protected java.lang.Thread getNodeMonitoringThread(HostSpec hostSpec,
                                                   @Nullable HostSpec writerHostSpec)

openAnyConnectionAndUpdateTopology

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

getNodeId

protected java.lang.String getNodeId(java.sql.Connection connection)

closeConnection

protected void closeConnection(@Nullable java.sql.Connection connection)

closeConnection

protected void closeConnection(@Nullable java.sql.Connection connection,
                               boolean unstableConnection)

delay

protected void delay(boolean useHighRefreshRate)
              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

fetchTopologyAndUpdateCache

protected @Nullable java.util.List<HostSpec> fetchTopologyAndUpdateCache(java.sql.Connection connection)

updateTopologyCache

protected void updateTopologyCache(@NonNull java.util.List<HostSpec> hosts)

getWriterNodeId

protected java.lang.String getWriterNodeId(java.sql.Connection connection)
                                    throws java.sql.SQLException

Throws:

java.sql.SQLException

queryForTopology

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

Throws:

java.sql.SQLException

getSuggestedWriterNodeId

protected java.lang.String getSuggestedWriterNodeId(java.sql.Connection connection)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

processQueryResults

protected java.util.List<HostSpec> processQueryResults(java.sql.ResultSet resultSet,
                                                       java.lang.String suggestedWriterNodeId)
                                                throws java.sql.SQLException

Throws:

java.sql.SQLException

createHost

protected HostSpec createHost(java.sql.ResultSet resultSet,
                              java.lang.String suggestedWriterNodeId)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

createHost

protected HostSpec createHost(java.lang.String nodeName,
                              boolean isWriter,
                              long weight,
                              java.sql.Timestamp lastUpdateTime)

getHostEndpoint

protected java.lang.String getHostEndpoint(java.lang.String nodeName)