software.amazon.jdbc.plugin.efm

Class MonitorConnectionContext

java.lang.Object

software.amazon.jdbc.plugin.efm.MonitorConnectionContext

public class MonitorConnectionContext
extends java.lang.Object

Monitoring context for each connection. This contains each connection's criteria for whether a server should be considered unhealthy.

Constructor Summary

Constructors

Constructor and Description
MonitorConnectionContext(java.sql.Connection connectionToAbort, java.util.Set<java.lang.String> hostAliases, long failureDetectionTimeMillis, long failureDetectionIntervalMillis, long failureDetectionCount) Constructor.

Method Summary

Modifier and Type	Method and Description
long	getFailureCount()
long	getFailureDetectionCount()
long	getFailureDetectionIntervalMillis()
long	getFailureDetectionTimeMillis()
long	getInvalidNodeStartTime()
void	invalidate()
boolean	isActiveContext()
boolean	isNodeUnhealthy()
void	updateConnectionStatus(long statusCheckStartTime, long currentTime, boolean isValid) Update whether the connection is still valid if the total elapsed time has passed the grace period.

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitorConnectionContext

public MonitorConnectionContext(java.sql.Connection connectionToAbort,
                                java.util.Set<java.lang.String> hostAliases,
                                long failureDetectionTimeMillis,
                                long failureDetectionIntervalMillis,
                                long failureDetectionCount)

Constructor.

Parameters:

connectionToAbort - A reference to the connection associated with this context that will be aborted in case of server failure.

hostAliases - All valid references to the server.

failureDetectionTimeMillis - Grace period after which node monitoring starts.

failureDetectionIntervalMillis - Interval between each failed connection check.

failureDetectionCount - Number of failed connection checks before considering database node as unhealthy.

Method Detail

getFailureDetectionTimeMillis

public long getFailureDetectionTimeMillis()

getFailureDetectionIntervalMillis

public long getFailureDetectionIntervalMillis()

getFailureDetectionCount

public long getFailureDetectionCount()

getFailureCount

public long getFailureCount()

getInvalidNodeStartTime

public long getInvalidNodeStartTime()

isNodeUnhealthy

public boolean isNodeUnhealthy()

isActiveContext

public boolean isActiveContext()

invalidate

public void invalidate()

updateConnectionStatus

public void updateConnectionStatus(long statusCheckStartTime,
                                   long currentTime,
                                   boolean isValid)

Update whether the connection is still valid if the total elapsed time has passed the grace period.

Parameters:

statusCheckStartTime - The time when connection status check started in nanos.

currentTime - The time when connection status check ended in nanos.

isValid - Whether the connection is valid.