software.amazon.jdbc.plugin.efm.v2

Class HostMonitorServiceV2Impl

java.lang.Object

software.amazon.jdbc.plugin.efm.v2.HostMonitorServiceV2Impl

All Implemented Interfaces:

HostMonitorService, StateSnapshotProvider

public class HostMonitorServiceV2Impl
extends java.lang.Object
implements HostMonitorService, StateSnapshotProvider

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	HostMonitorServiceV2Impl.HostMonitorKey

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.concurrent.Executor	ABORT_EXECUTOR
protected @Nullable TelemetryCounter	abortedConnectionsCounter
protected ConnectionContextService	connectionContextService
protected MonitorService	coreMonitorService
protected int	failureDetectionCount
protected int	failureDetectionIntervalMillis
protected int	failureDetectionTimeMillis
static AwsWrapperProperty	MONITOR_DISPOSAL_TIME_MS
protected HostMonitorServiceV2Impl.HostMonitorKey	monitorKey
protected PluginService	pluginService
protected FullServicesContainer	serviceContainer
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
HostMonitorServiceV2Impl(@NonNull FullServicesContainer serviceContainer, java.util.Properties props)

Method Summary

Modifier and Type	Method and Description
static void	closeAllMonitors()
protected HostMonitor	getMonitor(HostSpec hostSpec, java.util.Properties properties) Get or create a HostMonitorV2Impl for a server.
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
ConnectionContext	startMonitoring(java.sql.Connection connectionToAbort, HostSpec hostSpec, java.util.Properties properties)
void	stopMonitoring(@NonNull ConnectionContext context) 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

ABORT_EXECUTOR

protected static final java.util.concurrent.Executor ABORT_EXECUTOR

serviceContainer

protected final FullServicesContainer serviceContainer

pluginService

protected final PluginService pluginService

connectionContextService

protected final ConnectionContextService connectionContextService

coreMonitorService

protected final MonitorService coreMonitorService

telemetryFactory

protected final TelemetryFactory telemetryFactory

abortedConnectionsCounter

protected final @Nullable TelemetryCounter abortedConnectionsCounter

failureDetectionTimeMillis

protected final int failureDetectionTimeMillis

failureDetectionIntervalMillis

protected final int failureDetectionIntervalMillis

failureDetectionCount

protected final int failureDetectionCount

monitorKey

protected HostMonitorServiceV2Impl.HostMonitorKey monitorKey

Constructor Detail

HostMonitorServiceV2Impl

public HostMonitorServiceV2Impl(@NonNull FullServicesContainer serviceContainer,
                                java.util.Properties props)

Method Detail

closeAllMonitors

public static void closeAllMonitors()

startMonitoring

public ConnectionContext startMonitoring(java.sql.Connection connectionToAbort,
                                         HostSpec hostSpec,
                                         java.util.Properties properties)
                                  throws java.sql.SQLException

Specified by:

startMonitoring in interface HostMonitorService

Throws:

java.sql.SQLException

stopMonitoring

public void stopMonitoring(@NonNull ConnectionContext context)

Description copied from interface: HostMonitorService

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

Specified by:

stopMonitoring in interface HostMonitorService

Parameters:

context - The HostMonitorConnectionContext representing a connection.

getMonitor

protected HostMonitor getMonitor(HostSpec hostSpec,
                                 java.util.Properties properties)
                          throws java.sql.SQLException

Get or create a HostMonitorV2Impl for a server.

Parameters:

hostSpec - Information such as hostname of the server.

properties - The user configuration for the current connection.

Returns:

A HostMonitorV2Impl object associated with a specific server.

Throws:

java.sql.SQLException - if there's errors getting or creating a monitor

getSnapshotState

public java.util.List<Pair<java.lang.String,java.lang.Object>> getSnapshotState()

Specified by:

getSnapshotState in interface StateSnapshotProvider