software.amazon.jdbc.plugin.limitless

Class LimitlessRouterServiceImpl

java.lang.Object

software.amazon.jdbc.plugin.limitless.LimitlessRouterServiceImpl

All Implemented Interfaces:

LimitlessRouterService

public class LimitlessRouterServiceImpl
extends java.lang.Object
implements LimitlessRouterService

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	CACHE_CLEANUP_NANO
protected static java.util.Map<java.lang.String,java.util.concurrent.locks.ReentrantLock>	forceGetLimitlessRoutersLockMap
protected static SlidingExpirationCacheWithCleanupThread<java.lang.String,java.util.List<HostSpec>>	limitlessRouterCache
protected LimitlessRouterMonitorInitializer	limitlessRouterMonitorInitializer
protected static SlidingExpirationCacheWithCleanupThread<java.lang.String,LimitlessRouterMonitor>	limitlessRouterMonitors
static AwsWrapperProperty	MONITOR_DISPOSAL_TIME_MS
protected PluginService	pluginService
protected LimitlessQueryHelper	queryHelper

Constructor Summary

Constructors

Constructor and Description
LimitlessRouterServiceImpl(@NonNull PluginService pluginService)
LimitlessRouterServiceImpl(@NonNull PluginService pluginService, LimitlessRouterMonitorInitializer limitlessRouterMonitorInitializer, LimitlessQueryHelper queryHelper)

Method Summary

Modifier and Type	Method and Description
void	establishConnection(LimitlessConnectionContext context)
protected java.util.List<HostSpec>	getLimitlessRouters(java.lang.String clusterId, java.util.Properties props)
void	startMonitoring(@NonNull HostSpec hostSpec, @NonNull java.util.Properties props, int intervalMs)
protected void	synchronouslyGetLimitlessRouters(LimitlessConnectionContext context)
protected void	synchronouslyGetLimitlessRoutersWithRetry(LimitlessConnectionContext context)

Methods inherited from class java.lang.Object

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

Field Detail

MONITOR_DISPOSAL_TIME_MS

public static final AwsWrapperProperty MONITOR_DISPOSAL_TIME_MS

CACHE_CLEANUP_NANO

protected static final long CACHE_CLEANUP_NANO

forceGetLimitlessRoutersLockMap

protected static final java.util.Map<java.lang.String,java.util.concurrent.locks.ReentrantLock> forceGetLimitlessRoutersLockMap

pluginService

protected final PluginService pluginService

queryHelper

protected final LimitlessQueryHelper queryHelper

limitlessRouterMonitorInitializer

protected final LimitlessRouterMonitorInitializer limitlessRouterMonitorInitializer

limitlessRouterMonitors

protected static final SlidingExpirationCacheWithCleanupThread<java.lang.String,LimitlessRouterMonitor> limitlessRouterMonitors

limitlessRouterCache

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

Constructor Detail

LimitlessRouterServiceImpl

public LimitlessRouterServiceImpl(@NonNull PluginService pluginService)

LimitlessRouterServiceImpl

public LimitlessRouterServiceImpl(@NonNull PluginService pluginService,
                                  LimitlessRouterMonitorInitializer limitlessRouterMonitorInitializer,
                                  LimitlessQueryHelper queryHelper)

Method Detail

establishConnection

public void establishConnection(LimitlessConnectionContext context)
                         throws java.sql.SQLException

Specified by:

establishConnection in interface LimitlessRouterService

Throws:

java.sql.SQLException

getLimitlessRouters

protected java.util.List<HostSpec> getLimitlessRouters(java.lang.String clusterId,
                                                       java.util.Properties props)

synchronouslyGetLimitlessRoutersWithRetry

protected void synchronouslyGetLimitlessRoutersWithRetry(LimitlessConnectionContext context)
                                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

synchronouslyGetLimitlessRouters

protected void synchronouslyGetLimitlessRouters(LimitlessConnectionContext context)
                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

startMonitoring

public void startMonitoring(@NonNull HostSpec hostSpec,
                            @NonNull java.util.Properties props,
                            int intervalMs)

Specified by:

startMonitoring in interface LimitlessRouterService