software.amazon.jdbc.plugin.efm.base

Class HostMonitorConnectionContext

java.lang.Object

software.amazon.jdbc.plugin.efm.base.HostMonitorConnectionContext

All Implemented Interfaces:

ConnectionContext

Direct Known Subclasses:

HostMonitorConnectionContextV1, HostMonitorConnectionContextV2

public abstract class HostMonitorConnectionContext
extends java.lang.Object
implements ConnectionContext

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReference<java.lang.ref.WeakReference<java.sql.Connection>>	connectionToAbortRef
protected java.util.concurrent.atomic.AtomicBoolean	nodeUnhealthy

Constructor Summary

Constructors

Constructor and Description
HostMonitorConnectionContext()

Method Summary

Modifier and Type	Method and Description
@Nullable java.sql.Connection	getConnection() Get the connection associated with this context.
boolean	isActive() Check if this context is currently active.
boolean	isNodeUnhealthy() Check if the database node is unhealthy.
void	setInactive() Mark this context as inactive and release any connection references.
void	setNodeUnhealthy(boolean nodeUnhealthy) Set the health status of the database node.
boolean	shouldAbort() Check if the connection should be aborted due to node failure.

Methods inherited from class java.lang.Object

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

Field Detail

connectionToAbortRef

protected final java.util.concurrent.atomic.AtomicReference<java.lang.ref.WeakReference<java.sql.Connection>> connectionToAbortRef

nodeUnhealthy

protected final java.util.concurrent.atomic.AtomicBoolean nodeUnhealthy

Constructor Detail

HostMonitorConnectionContext

public HostMonitorConnectionContext()

Method Detail

isNodeUnhealthy

public boolean isNodeUnhealthy()

Description copied from interface: ConnectionContext

Check if the database node is unhealthy.

Specified by:

isNodeUnhealthy in interface ConnectionContext

Returns:

true if the node is unhealthy, false otherwise

setNodeUnhealthy

public void setNodeUnhealthy(boolean nodeUnhealthy)

Description copied from interface: ConnectionContext

Set the health status of the database node.

Specified by:

setNodeUnhealthy in interface ConnectionContext

Parameters:

nodeUnhealthy - true if the node is unhealthy, false otherwise

setInactive

public void setInactive()

Description copied from interface: ConnectionContext

Mark this context as inactive and release any connection references.

Specified by:

setInactive in interface ConnectionContext

getConnection

public @Nullable java.sql.Connection getConnection()

Description copied from interface: ConnectionContext

Get the connection associated with this context.

Specified by:

getConnection in interface ConnectionContext

Returns:

the connection, or null if not available

isActive

public boolean isActive()

Description copied from interface: ConnectionContext

Check if this context is currently active.

Specified by:

isActive in interface ConnectionContext

Returns:

true if active, false otherwise

shouldAbort

public boolean shouldAbort()

Description copied from interface: ConnectionContext

Check if the connection should be aborted due to node failure.

Specified by:

shouldAbort in interface ConnectionContext

Returns:

true if the connection should be aborted, false otherwise