software.amazon.jdbc.hostlistprovider

Class AuroraMonitoringConnectionHandler

java.lang.Object

software.amazon.jdbc.hostlistprovider.AbstractMonitoringConnectionHandler<MonitoringConnectionPriority>

software.amazon.jdbc.hostlistprovider.AuroraMonitoringConnectionHandler

All Implemented Interfaces:

MonitoringConnectionHandler, StateSnapshotProvider

public class AuroraMonitoringConnectionHandler
extends AbstractMonitoringConnectionHandler<MonitoringConnectionPriority>

Aurora implementation of MonitoringConnectionHandler that uses MonitoringConnectionPriority to manage monitoring connection preferences.

Field Summary

Fields

Modifier and Type	Field and Description
static AwsWrapperProperty	MONITORING_CONNECTION_PRIORITY
protected int	readerPriorityIndex
protected int	writerPriorityIndex

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

currentPriorityIndex, monitoringConnection, monitoringProperties, pluginService, priorities, topologyUtils, upgradeConnectedHost, upgradeConnection, upgradeExecutor, upgradeFuture, upgradeReadyNotifier

Constructor Summary

Constructors

Constructor and Description
AuroraMonitoringConnectionHandler(AtomicConnection monitoringConnection, PluginService pluginService, TopologyUtils topologyUtils, java.util.Properties properties, java.util.Properties monitoringProperties)
AuroraMonitoringConnectionHandler(AtomicConnection monitoringConnection, PluginService pluginService, TopologyUtils topologyUtils, java.util.Properties properties, java.util.Properties monitoringProperties, @Nullable java.lang.Runnable upgradeReadyNotifier)

Method Summary

Modifier and Type	Method and Description
protected java.util.List<HostSpec>	findHostsForPriority(int priorityIndex, java.util.List<HostSpec> hosts) Returns all hosts in hosts that match the priority at priorityIndex of AbstractMonitoringConnectionHandler.priorities.
protected int	getPriorityIndex(HostSpec host, boolean isWriter) Returns the index into AbstractMonitoringConnectionHandler.priorities that the given host satisfies, or -1 if no priority matches.
protected java.lang.String	getUpgradeThreadName() Returns the thread-name prefix used for the async upgrade executor (e.g., "atmu" or "gatmu").

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

acceptConnection, acceptConnections, attemptConnectionUpgrade, close, effectiveIndex, findUpgradeCandidates, formatPriorityIndex, getAdditionalSnapshotState, getSnapshotState

Methods inherited from class java.lang.Object

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

Field Detail

MONITORING_CONNECTION_PRIORITY

public static final AwsWrapperProperty MONITORING_CONNECTION_PRIORITY

writerPriorityIndex

protected final int writerPriorityIndex

readerPriorityIndex

protected final int readerPriorityIndex

Constructor Detail

AuroraMonitoringConnectionHandler

public AuroraMonitoringConnectionHandler(AtomicConnection monitoringConnection,
                                         PluginService pluginService,
                                         TopologyUtils topologyUtils,
                                         java.util.Properties properties,
                                         java.util.Properties monitoringProperties)

AuroraMonitoringConnectionHandler

public AuroraMonitoringConnectionHandler(AtomicConnection monitoringConnection,
                                         PluginService pluginService,
                                         TopologyUtils topologyUtils,
                                         java.util.Properties properties,
                                         java.util.Properties monitoringProperties,
                                         @Nullable java.lang.Runnable upgradeReadyNotifier)

Method Detail

getPriorityIndex

protected int getPriorityIndex(HostSpec host,
                               boolean isWriter)

Description copied from class: AbstractMonitoringConnectionHandler

Returns the index into AbstractMonitoringConnectionHandler.priorities that the given host satisfies, or -1 if no priority matches. The lowest-index match wins.

Specified by:

getPriorityIndex in class AbstractMonitoringConnectionHandler<MonitoringConnectionPriority>

Parameters:

host - the host being considered

isWriter - whether the connection is to a writer

findHostsForPriority

protected java.util.List<HostSpec> findHostsForPriority(int priorityIndex,
                                                        java.util.List<HostSpec> hosts)

Description copied from class: AbstractMonitoringConnectionHandler

Returns all hosts in hosts that match the priority at priorityIndex of AbstractMonitoringConnectionHandler.priorities.

Specified by:

findHostsForPriority in class AbstractMonitoringConnectionHandler<MonitoringConnectionPriority>

getUpgradeThreadName

protected java.lang.String getUpgradeThreadName()

Description copied from class: AbstractMonitoringConnectionHandler

Returns the thread-name prefix used for the async upgrade executor (e.g., "atmu" or "gatmu").

Specified by:

getUpgradeThreadName in class AbstractMonitoringConnectionHandler<MonitoringConnectionPriority>