software.amazon.jdbc.plugin.efm.v1

Class HostMonitorServiceV1Impl

java.lang.Object

software.amazon.jdbc.plugin.efm.v1.HostMonitorServiceV1Impl

All Implemented Interfaces:

HostMonitorService, StateSnapshotProvider

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
HostMonitorServiceV1Impl(@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 HostMonitorV1Impl 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 TelemetryCounter abortedConnectionsCounter

failureDetectionTimeMillis

protected final int failureDetectionTimeMillis

failureDetectionIntervalMillis

protected final int failureDetectionIntervalMillis

failureDetectionCount

protected final int failureDetectionCount

Constructor Detail

HostMonitorServiceV1Impl

public HostMonitorServiceV1Impl(@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 HostMonitorV1Impl for a server.

Parameters:

hostSpec - Information such as hostname of the server.

properties - The user configuration for the current connection.

Returns:

A HostMonitorV1Impl 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