software.amazon.jdbc.plugin.efm2

Class MonitorImpl

java.lang.Object

software.amazon.jdbc.plugin.efm2.MonitorImpl

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, Monitor

public class MonitorImpl
extends java.lang.Object
implements Monitor

This class uses a background thread to monitor a particular server with one or more active Connection.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.concurrent.Executor	ABORT_EXECUTOR

Constructor Summary

Constructors

Constructor and Description
MonitorImpl(@NonNull PluginService pluginService, @NonNull HostSpec hostSpec, @NonNull java.util.Properties properties, int failureDetectionTimeMillis, int failureDetectionIntervalMillis, int failureDetectionCount, TelemetryCounter abortedConnectionsCounter) Store the monitoring configuration for a connection.

Method Summary

Modifier and Type	Method and Description
boolean	canDispose()
void	clearContexts()
void	close()
protected long	getActiveContextSize()
void	newContextRun()
void	run()
void	startMonitoring(MonitorConnectionContext context)

Methods inherited from class java.lang.Object

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

Field Detail

ABORT_EXECUTOR

protected static final java.util.concurrent.Executor ABORT_EXECUTOR

Constructor Detail

MonitorImpl

public MonitorImpl(@NonNull PluginService pluginService,
                   @NonNull HostSpec hostSpec,
                   @NonNull java.util.Properties properties,
                   int failureDetectionTimeMillis,
                   int failureDetectionIntervalMillis,
                   int failureDetectionCount,
                   TelemetryCounter abortedConnectionsCounter)

Store the monitoring configuration for a connection.

Parameters:

pluginService - A service for creating new connections.

hostSpec - The HostSpec of the server this MonitorImpl instance is monitoring.

properties - The Properties containing additional monitoring configuration.

Method Detail

canDispose

public boolean canDispose()

Specified by:

canDispose in interface Monitor

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

getActiveContextSize

protected long getActiveContextSize()

startMonitoring

public void startMonitoring(MonitorConnectionContext context)

Specified by:

startMonitoring in interface Monitor

clearContexts

public void clearContexts()

newContextRun

public void newContextRun()

run

public void run()

Specified by:

run in interface java.lang.Runnable