software.amazon.jdbc.plugin.limitless

Class LimitlessRouterMonitor

java.lang.Object

software.amazon.jdbc.plugin.limitless.LimitlessRouterMonitor

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable

public class LimitlessRouterMonitor
extends java.lang.Object
implements java.lang.AutoCloseable, java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected @NonNull HostSpec	hostSpec
protected int	intervalMs
protected SlidingExpirationCacheWithCleanupThread<java.lang.String,java.util.List<HostSpec>>	limitlessRouterCache
protected java.lang.String	limitlessRouterCacheKey
protected static java.lang.String	MONITORING_PROPERTY_PREFIX
protected java.sql.Connection	monitoringConn
protected @NonNull PluginService	pluginService
protected @NonNull java.util.Properties	props
protected LimitlessQueryHelper	queryHelper
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
LimitlessRouterMonitor(@NonNull PluginService pluginService, @NonNull HostSpec hostSpec, @NonNull SlidingExpirationCacheWithCleanupThread<java.lang.String,java.util.List<HostSpec>> limitlessRouterCache, @NonNull java.lang.String limitlessRouterCacheKey, @NonNull java.util.Properties props, int intervalMs)

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.List<HostSpec>	getLimitlessRouters()
java.util.concurrent.atomic.AtomicBoolean	isStopped()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

MONITORING_PROPERTY_PREFIX

protected static final java.lang.String MONITORING_PROPERTY_PREFIX

See Also:

Constant Field Values

intervalMs

protected final int intervalMs

hostSpec

protected final @NonNull HostSpec hostSpec

limitlessRouterCache

protected final SlidingExpirationCacheWithCleanupThread<java.lang.String,java.util.List<HostSpec>> limitlessRouterCache

limitlessRouterCacheKey

protected final java.lang.String limitlessRouterCacheKey

props

protected final @NonNull java.util.Properties props

pluginService

protected final @NonNull PluginService pluginService

queryHelper

protected final LimitlessQueryHelper queryHelper

telemetryFactory

protected final TelemetryFactory telemetryFactory

monitoringConn

protected java.sql.Connection monitoringConn

Constructor Detail

LimitlessRouterMonitor

public LimitlessRouterMonitor(@NonNull PluginService pluginService,
                              @NonNull HostSpec hostSpec,
                              @NonNull SlidingExpirationCacheWithCleanupThread<java.lang.String,java.util.List<HostSpec>> limitlessRouterCache,
                              @NonNull java.lang.String limitlessRouterCacheKey,
                              @NonNull java.util.Properties props,
                              int intervalMs)

Method Detail

getLimitlessRouters

public java.util.List<HostSpec> getLimitlessRouters()

isStopped

public java.util.concurrent.atomic.AtomicBoolean isStopped()

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable