software.amazon.jdbc.plugin.efm.v1

Class HostMonitorV1Impl

java.lang.Object

software.amazon.jdbc.util.monitoring.AbstractMonitor

software.amazon.jdbc.plugin.efm.v1.HostMonitorV1Impl

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, HostMonitor, EventSubscriber, Monitor, StateSnapshotProvider

public class HostMonitorV1Impl
extends AbstractMonitor
implements HostMonitor, StateSnapshotProvider

Field Summary

Fields

Modifier and Type	Field and Description
protected HostSpec	hostSpec
protected AtomicConnection	monitoringConn
protected java.util.Properties	monitoringProperties
protected java.util.Properties	properties
protected FullServicesContainer	servicesContainer
protected TelemetryFactory	telemetryFactory

Fields inherited from class software.amazon.jdbc.util.monitoring.AbstractMonitor

lastActivityTimestampNanos, monitorExecutor, state, stop, terminationTimeoutSec

Constructor Summary

Constructors

Constructor and Description
HostMonitorV1Impl(@NonNull FullServicesContainer servicesContainer, @NonNull HostSpec hostSpec, @NonNull java.util.Properties properties) Store the monitoring configuration for a connection.

Method Summary

Modifier and Type	Method and Description
protected long	getCurrentTimeNano()
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
void	monitor() Executes the monitoring loop for this monitor.
void	processEvent(Event event) Processes an event.
protected void	reset()
void	start() Submits this monitor in a separate thread to begin its monitoring tasks.
void	startMonitoring(ConnectionContext context)

Methods inherited from class software.amazon.jdbc.util.monitoring.AbstractMonitor

canDispose, close, getLastActivityTimestampNanos, getState, run, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Methods inherited from interface software.amazon.jdbc.util.monitoring.Monitor

canDispose, close, getLastActivityTimestampNanos, getState, stop

Methods inherited from interface java.lang.Runnable

run

Field Detail

servicesContainer

protected final FullServicesContainer servicesContainer

telemetryFactory

protected final TelemetryFactory telemetryFactory

properties

protected final java.util.Properties properties

monitoringProperties

protected final java.util.Properties monitoringProperties

hostSpec

protected final HostSpec hostSpec

monitoringConn

protected AtomicConnection monitoringConn

Constructor Detail

HostMonitorV1Impl

public HostMonitorV1Impl(@NonNull FullServicesContainer servicesContainer,
                         @NonNull HostSpec hostSpec,
                         @NonNull java.util.Properties properties)

Store the monitoring configuration for a connection.

Parameters:

servicesContainer - The telemetry factory to use to create telemetry data.

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

properties - The Properties containing additional monitoring configuration.

Method Detail

start

public void start()

Description copied from interface: Monitor

Submits this monitor in a separate thread to begin its monitoring tasks.

Specified by:

start in interface Monitor

Overrides:

start in class AbstractMonitor

startMonitoring

public void startMonitoring(ConnectionContext context)

Specified by:

startMonitoring in interface HostMonitor

monitor

public void monitor()

Description copied from interface: Monitor

Executes the monitoring loop for this monitor. This method should be called in the run() method of the thread submitted during the call to Monitor.start(). Additionally, the monitoring loop should regularly update the last activity timestamp so that the MonitorService can detect whether the monitor is stuck or not.

Specified by:

monitor in interface Monitor

getCurrentTimeNano

protected long getCurrentTimeNano()

reset

protected void reset()

processEvent

public void processEvent(Event event)

Description copied from interface: EventSubscriber

Processes an event. This method will only be called on this subscriber if it has subscribed to the event class via EventPublisher.subscribe(software.amazon.jdbc.util.events.EventSubscriber, java.util.Set<java.lang.Class<? extends software.amazon.jdbc.util.events.Event>>).

Specified by:

processEvent in interface EventSubscriber

Parameters:

event - the event to process.

getSnapshotState

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

Specified by:

getSnapshotState in interface StateSnapshotProvider