software.amazon.jdbc.plugin.efm2

Class MonitorServiceImpl

java.lang.Object

software.amazon.jdbc.plugin.efm2.MonitorServiceImpl

All Implemented Interfaces:

MonitorService

public class MonitorServiceImpl
extends java.lang.Object
implements MonitorService

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 MonitorInitializer	monitorInitializer
protected static SlidingExpirationCacheWithCleanupThread<java.lang.String,Monitor>	monitors
protected PluginService	pluginService
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
MonitorServiceImpl(@NonNull PluginService pluginService)

Method Summary

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

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,Monitor> monitors

pluginService

protected final PluginService pluginService

monitorInitializer

protected final MonitorInitializer monitorInitializer

telemetryFactory

protected final TelemetryFactory telemetryFactory

abortedConnectionsCounter

protected final TelemetryCounter abortedConnectionsCounter

Constructor Detail

MonitorServiceImpl

public MonitorServiceImpl(@NonNull PluginService pluginService)

Method Detail

clearCache

public static void clearCache()

startMonitoring

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

Specified by:

startMonitoring in interface MonitorService

stopMonitoring

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

Description copied from interface: MonitorService

Stop monitoring for a connection represented by the given MonitorConnectionContext. Removes the context from the MonitorImpl.

Specified by:

stopMonitoring in interface MonitorService

Parameters:

context - The MonitorConnectionContext representing a connection.

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface MonitorService

getMonitor

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

Get or create a MonitorImpl for a server.

Parameters:

hostSpec - Information such as hostname of the server.

properties - The user configuration for the current connection.

Returns:

A MonitorImpl object associated with a specific server.