software.amazon.jdbc.plugin.readwritesplitting.cache

Class DefaultCachePolicy

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.cache.DefaultCachePolicy

All Implemented Interfaces:

ConnectionCachePolicy

public class DefaultCachePolicy
extends java.lang.Object
implements ConnectionCachePolicy

Default ConnectionCachePolicy, reproducing the legacy AbstractReadWriteSplittingPlugin.getKeepAliveTimeout behavior: pooled connections defer their lifetime to the pool (deadline 0); non-pooled connections use cachedReaderKeepAliveTimeoutMs (default 0 = keep reusing indefinitely).

The clock is injectable via NanoTimeSource so deadline computation is unit-testable without real waits.

Constructor Summary

Constructors

Constructor and Description
DefaultCachePolicy(long keepAliveMs, NanoTimeSource timeSource)
DefaultCachePolicy(java.util.Properties properties)

Method Summary

Modifier and Type	Method and Description
long	keepAliveDeadlineNanos(boolean fromPool) Returns the System.nanoTime()-based deadline after which a cached connection may be released, or 0 to keep it (pool-managed, or reuse indefinitely).

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCachePolicy

public DefaultCachePolicy(java.util.Properties properties)

DefaultCachePolicy

public DefaultCachePolicy(long keepAliveMs,
                          NanoTimeSource timeSource)

Method Detail

keepAliveDeadlineNanos

public long keepAliveDeadlineNanos(boolean fromPool)

Description copied from interface: ConnectionCachePolicy

Returns the System.nanoTime()-based deadline after which a cached connection may be released, or 0 to keep it (pool-managed, or reuse indefinitely).

Specified by:

keepAliveDeadlineNanos in interface ConnectionCachePolicy

Parameters:

fromPool - whether the connection came from an internal connection pool

Returns:

the deadline in nanoTime units, or 0