public class GlobalAuroraHostListProvider extends RdsHostListProvider
RdsHostListProvider.FetchTopologyResult| Modifier and Type | Field and Description |
|---|---|
static AwsWrapperProperty |
GLOBAL_CLUSTER_INSTANCE_HOST_PATTERNS |
protected java.util.Map<java.lang.String,HostSpec> |
instanceTemplatesByRegion |
protected RdsUtils |
rdsUtils |
protected GlobalAuroraTopologyUtils |
topologyUtils |
CLUSTER_ID, CLUSTER_INSTANCE_HOST_PATTERN, CLUSTER_TOPOLOGY_HIGH_REFRESH_RATE_MS, CLUSTER_TOPOLOGY_REFRESH_RATE_MS, clusterId, connectionUrlParser, DEFAULT_TOPOLOGY_QUERY_TIMEOUT_MS, highRefreshRateNano, hostListProviderService, initialHostList, initialHostSpec, instanceTemplate, isInitialized, lock, originalUrl, pluginService, properties, rdsHelper, rdsUrlType, refreshRateNano, servicesContainer| Constructor and Description |
|---|
GlobalAuroraHostListProvider(GlobalAuroraTopologyUtils topologyUtils,
java.util.Properties properties,
java.lang.String originalUrl,
FullServicesContainer servicesContainer) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable java.util.List<HostSpec> |
getCurrentTopology(java.sql.Connection conn,
HostSpec initialHostSpec)
Get current topology information for the connected database.
|
protected ClusterTopologyMonitor |
getOrCreateMonitor() |
protected void |
initSettings() |
clear, forceRefresh, forceRefresh, forceRefreshMonitor, getClusterId, getRdsUrlType, getStoredTopology, getTopology, init, refresh, releaseResources, stopMonitor, validateHostPatternSettingpublic static final AwsWrapperProperty GLOBAL_CLUSTER_INSTANCE_HOST_PATTERNS
protected final RdsUtils rdsUtils
protected final GlobalAuroraTopologyUtils topologyUtils
protected java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion
public GlobalAuroraHostListProvider(GlobalAuroraTopologyUtils topologyUtils, java.util.Properties properties, java.lang.String originalUrl, FullServicesContainer servicesContainer)
protected void initSettings()
throws java.sql.SQLException
initSettings in class RdsHostListProviderjava.sql.SQLExceptionprotected ClusterTopologyMonitor getOrCreateMonitor() throws java.sql.SQLException
getOrCreateMonitor in class RdsHostListProviderjava.sql.SQLExceptionpublic @Nullable java.util.List<HostSpec> getCurrentTopology(java.sql.Connection conn, HostSpec initialHostSpec) throws java.sql.SQLException
HostListProviderStaticHostListProvider. The returned topology should be fresh info returned from a topology
query if `this` is a DynamicHostListProvider,getCurrentTopology in interface HostListProvidergetCurrentTopology in class RdsHostListProviderconn - the connection to use to query the database for topology information, if needed.initialHostSpec - the host details of the initial connection.java.sql.SQLException - if an error occurs while attempting to acquire the database topology information.