software.amazon.jdbc.plugin.strategy.fastestresponse

Class NodeResponseTimeMonitor

java.lang.Object

software.amazon.jdbc.util.monitoring.AbstractMonitor

software.amazon.jdbc.plugin.strategy.fastestresponse.NodeResponseTimeMonitor

All Implemented Interfaces:

java.lang.Runnable, EventSubscriber, Monitor, StateSnapshotProvider

public class NodeResponseTimeMonitor
extends AbstractMonitor
implements EventSubscriber, StateSnapshotProvider

Field Summary

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

lastActivityTimestampNanos, monitorExecutor, state, stop, terminationTimeoutSec

Constructor Summary

Constructors

Constructor and Description
NodeResponseTimeMonitor(@NonNull FullServicesContainer servicesContainer, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props, int intervalMs)

Method Summary

Modifier and Type	Method and Description
void	close() Closes all resources used by this monitor.
protected long	getCurrentTime()
@NonNull HostSpec	getHostSpec()
int	getResponseTime()
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()

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

canDispose, getLastActivityTimestampNanos, getState, run, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeResponseTimeMonitor

public NodeResponseTimeMonitor(@NonNull FullServicesContainer servicesContainer,
                               @NonNull HostSpec hostSpec,
                               @NonNull java.util.Properties props,
                               int intervalMs)

Method Detail

getResponseTime

public int getResponseTime()

getHostSpec

public @NonNull HostSpec getHostSpec()

getCurrentTime

protected long getCurrentTime()

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

close

public void close()

Description copied from interface: Monitor

Closes all resources used by this monitor. This method will be called as part of Monitor.stop().

Specified by:

close in interface Monitor

Overrides:

close in class AbstractMonitor

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