software.amazon.jdbc.hostlistprovider

Class GdbMonitoringConnectionHandler

java.lang.Object

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

software.amazon.jdbc.hostlistprovider.GdbMonitoringConnectionHandler

All Implemented Interfaces:

MonitoringConnectionHandler, StateSnapshotProvider

public class GdbMonitoringConnectionHandler
extends AbstractMonitoringConnectionHandler<GdbMonitoringConnectionPriority>

GDB-specific implementation of MonitoringConnectionHandler that uses GdbMonitoringConnectionPriority with region and primary/secondary awareness.

Field Summary

Fields

Modifier and Type	Field and Description
static AwsWrapperProperty	GDB_MONITORING_CONNECTION_PRIORITY
protected RdsUtils	rdsUtils
protected java.util.concurrent.atomic.AtomicReference<HostSpec>	writerHostSpec

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
GdbMonitoringConnectionHandler(AtomicConnection monitoringConnection, PluginService pluginService, TopologyUtils topologyUtils, java.util.Properties properties, java.util.Properties monitoringProperties, java.util.concurrent.atomic.AtomicReference<HostSpec> writerHostSpec)
GdbMonitoringConnectionHandler(AtomicConnection monitoringConnection, PluginService pluginService, TopologyUtils topologyUtils, java.util.Properties properties, java.util.Properties monitoringProperties, java.util.concurrent.atomic.AtomicReference<HostSpec> writerHostSpec, @Nullable java.lang.Runnable upgradeReadyNotifier)

Method Summary

Modifier and Type	Method and Description
@Nullable HostSpec	acceptConnections(java.util.Map<HostSpec,AtomicConnection> connections, @Nullable HostSpec writerHostSpecOverride, @Nullable java.util.List<HostSpec> topology) GDB needs to evaluate priorities relative to the cluster's primary region.
protected int	determinePriorityIndex(@NonNull HostSpec hostSpec, boolean isWriter, @Nullable java.lang.String primaryRegion)
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 @Nullable java.util.List<Pair<java.lang.String,java.lang.Object>>	getAdditionalSnapshotState() Hook for subclasses to publish additional snapshot state (e.g., GDB primary region).
protected @Nullable java.lang.String	getPrimaryRegion()
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, attemptConnectionUpgrade, close, effectiveIndex, findUpgradeCandidates, formatPriorityIndex, getSnapshotState

Methods inherited from class java.lang.Object

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

Field Detail

GDB_MONITORING_CONNECTION_PRIORITY

public static final AwsWrapperProperty GDB_MONITORING_CONNECTION_PRIORITY

rdsUtils

protected final RdsUtils rdsUtils

writerHostSpec

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

Constructor Detail

GdbMonitoringConnectionHandler

public GdbMonitoringConnectionHandler(AtomicConnection monitoringConnection,
                                      PluginService pluginService,
                                      TopologyUtils topologyUtils,
                                      java.util.Properties properties,
                                      java.util.Properties monitoringProperties,
                                      java.util.concurrent.atomic.AtomicReference<HostSpec> writerHostSpec)

GdbMonitoringConnectionHandler

public GdbMonitoringConnectionHandler(AtomicConnection monitoringConnection,
                                      PluginService pluginService,
                                      TopologyUtils topologyUtils,
                                      java.util.Properties properties,
                                      java.util.Properties monitoringProperties,
                                      java.util.concurrent.atomic.AtomicReference<HostSpec> writerHostSpec,
                                      @Nullable java.lang.Runnable upgradeReadyNotifier)

Method Detail

acceptConnections

public @Nullable HostSpec acceptConnections(java.util.Map<HostSpec,AtomicConnection> connections,
                                            @Nullable HostSpec writerHostSpecOverride,
                                            @Nullable java.util.List<HostSpec> topology)

GDB needs to evaluate priorities relative to the cluster's primary region. The base implementation calls AbstractMonitoringConnectionHandler.getPriorityIndex(HostSpec, boolean) which doesn't carry region context, so acceptConnections is overridden to allow the caller's writer host to seed the primary region (used during panic-mode resolution where the newly detected writer may differ from the cached one).

Specified by:

acceptConnections in interface MonitoringConnectionHandler

Overrides:

acceptConnections in class AbstractMonitoringConnectionHandler<GdbMonitoringConnectionPriority>

Parameters:

connections - a map of host -> connection harvested from node threads

writerHostSpecOverride - the host spec of the writer (if known)

topology - the current topology, used for region/role context

Returns:

the host of the connection that was selected and set as the monitoring connection, or null if no connection was selected

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

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

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

getAdditionalSnapshotState

protected @Nullable java.util.List<Pair<java.lang.String,java.lang.Object>> getAdditionalSnapshotState()

Description copied from class: AbstractMonitoringConnectionHandler

Hook for subclasses to publish additional snapshot state (e.g., GDB primary region). Returns null when none.

Overrides:

getAdditionalSnapshotState in class AbstractMonitoringConnectionHandler<GdbMonitoringConnectionPriority>

getPrimaryRegion

protected @Nullable java.lang.String getPrimaryRegion()

determinePriorityIndex

protected int determinePriorityIndex(@NonNull HostSpec hostSpec,
                                     boolean isWriter,
                                     @Nullable java.lang.String primaryRegion)