software.amazon.jdbc.plugin.strategy.fastestresponse

Class HostResponseTimeServiceImpl

java.lang.Object

software.amazon.jdbc.plugin.strategy.fastestresponse.HostResponseTimeServiceImpl

All Implemented Interfaces:

HostResponseTimeService

public class HostResponseTimeServiceImpl
extends java.lang.Object
implements HostResponseTimeService

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	CACHE_CLEANUP_NANO
protected static long	CACHE_EXPIRATION_NANO
protected static java.util.concurrent.locks.ReentrantLock	cacheLock
protected java.util.List<HostSpec>	hosts
protected int	intervalMs
protected static SlidingExpirationCacheWithCleanupThread<java.lang.String,NodeResponseTimeMonitor>	monitoringNodes
protected @NonNull PluginService	pluginService
protected @NonNull java.util.Properties	props
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
HostResponseTimeServiceImpl(@NonNull PluginService pluginService, @NonNull java.util.Properties props, int intervalMs)

Method Summary

Modifier and Type	Method and Description
int	getResponseTime(HostSpec hostSpec) Return a response time in milliseconds to the host.
void	setHosts(@NonNull java.util.List<HostSpec> hosts) Provides an updated host list to a service.

Methods inherited from class java.lang.Object

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

Field Detail

CACHE_EXPIRATION_NANO

protected static final long CACHE_EXPIRATION_NANO

CACHE_CLEANUP_NANO

protected static final long CACHE_CLEANUP_NANO

monitoringNodes

protected static final SlidingExpirationCacheWithCleanupThread<java.lang.String,NodeResponseTimeMonitor> monitoringNodes

cacheLock

protected static final java.util.concurrent.locks.ReentrantLock cacheLock

intervalMs

protected int intervalMs

hosts

protected java.util.List<HostSpec> hosts

pluginService

protected final @NonNull PluginService pluginService

props

protected final @NonNull java.util.Properties props

telemetryFactory

protected final TelemetryFactory telemetryFactory

Constructor Detail

HostResponseTimeServiceImpl

public HostResponseTimeServiceImpl(@NonNull PluginService pluginService,
                                   @NonNull java.util.Properties props,
                                   int intervalMs)

Method Detail

getResponseTime

public int getResponseTime(HostSpec hostSpec)

Description copied from interface: HostResponseTimeService

Return a response time in milliseconds to the host. Return Integer.MAX_VALUE if response time is not available.

Specified by:

getResponseTime in interface HostResponseTimeService

Parameters:

hostSpec - the host details

Returns:

response time in milliseconds for a desired host. It should return Integer.MAX_VALUE if response time couldn't be measured.

setHosts

public void setHosts(@NonNull java.util.List<HostSpec> hosts)

Description copied from interface: HostResponseTimeService

Provides an updated host list to a service.

Specified by:

setHosts in interface HostResponseTimeService