software.amazon.jdbc.plugin.efm2

Class HostMonitorServiceImpl

java.lang.Object

software.amazon.jdbc.plugin.efm2.HostMonitorServiceImpl

All Implemented Interfaces:

HostMonitorService

public class HostMonitorServiceImpl
extends java.lang.Object
implements HostMonitorService

This class handles the creation and clean up of monitoring threads to servers with one or more active connections.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.concurrent.Executor	ABORT_EXECUTOR
protected TelemetryCounter	abortedConnectionsCounter
protected static long	CACHE_CLEANUP_NANO
static AwsWrapperProperty	MONITOR_DISPOSAL_TIME_MS
protected HostMonitorInitializer	monitorInitializer
protected static SlidingExpirationCacheWithCleanupThread<java.lang.String,HostMonitor>	monitors
protected PluginService	pluginService
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
HostMonitorServiceImpl(@NonNull PluginService pluginService)

Method Summary

Modifier and Type	Method and Description
static void	closeAllMonitors()
protected HostMonitor	getMonitor(HostSpec hostSpec, java.util.Properties properties, int failureDetectionTimeMillis, int failureDetectionIntervalMillis, int failureDetectionCount) Get or create a HostMonitorImpl for a server.
void	releaseResources()
HostMonitorConnectionContext	startMonitoring(java.sql.Connection connectionToAbort, HostSpec hostSpec, java.util.Properties properties, int failureDetectionTimeMillis, int failureDetectionIntervalMillis, int failureDetectionCount)
void	stopMonitoring(@NonNull HostMonitorConnectionContext context, @NonNull java.sql.Connection connectionToAbort) Stop monitoring for a connection represented by the given HostMonitorConnectionContext.

Methods inherited from class java.lang.Object

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

Field Detail

MONITOR_DISPOSAL_TIME_MS

public static final AwsWrapperProperty MONITOR_DISPOSAL_TIME_MS

CACHE_CLEANUP_NANO

protected static final long CACHE_CLEANUP_NANO

ABORT_EXECUTOR

protected static final java.util.concurrent.Executor ABORT_EXECUTOR

monitors

protected static final SlidingExpirationCacheWithCleanupThread<java.lang.String,HostMonitor> monitors

pluginService

protected final PluginService pluginService

monitorInitializer

protected final HostMonitorInitializer monitorInitializer

telemetryFactory

protected final TelemetryFactory telemetryFactory

abortedConnectionsCounter

protected final TelemetryCounter abortedConnectionsCounter

Constructor Detail

HostMonitorServiceImpl

public HostMonitorServiceImpl(@NonNull PluginService pluginService)

Method Detail

closeAllMonitors

public static void closeAllMonitors()

startMonitoring

public HostMonitorConnectionContext startMonitoring(java.sql.Connection connectionToAbort,
                                                    HostSpec hostSpec,
                                                    java.util.Properties properties,
                                                    int failureDetectionTimeMillis,
                                                    int failureDetectionIntervalMillis,
                                                    int failureDetectionCount)

Specified by:

startMonitoring in interface HostMonitorService

stopMonitoring

public void stopMonitoring(@NonNull HostMonitorConnectionContext context,
                           @NonNull java.sql.Connection connectionToAbort)

Description copied from interface: HostMonitorService

Stop monitoring for a connection represented by the given HostMonitorConnectionContext. Removes the context from the HostMonitorImpl.

Specified by:

stopMonitoring in interface HostMonitorService

Parameters:

context - The HostMonitorConnectionContext representing a connection.

connectionToAbort - A connection to abort.

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface HostMonitorService

getMonitor

protected HostMonitor getMonitor(HostSpec hostSpec,
                                 java.util.Properties properties,
                                 int failureDetectionTimeMillis,
                                 int failureDetectionIntervalMillis,
                                 int failureDetectionCount)

Get or create a HostMonitorImpl for a server.

Parameters:

hostSpec - Information such as hostname of the server.

properties - The user configuration for the current connection.

failureDetectionTimeMillis - A failure detection time in millis.

failureDetectionIntervalMillis - A failure detection interval in millis.

failureDetectionCount - A failure detection count.

Returns:

A HostMonitorImpl object associated with a specific server.