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 @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 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 @Nullable 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