public class GlobalAuroraTopologyUtils extends AuroraTopologyUtils
| Modifier and Type | Field and Description |
|---|---|
protected GlobalAuroraTopologyDialect |
dialect |
DEFAULT_QUERY_TIMEOUT_MS, hostSpecBuilder, networkTimeoutExecutor| Constructor and Description |
|---|
GlobalAuroraTopologyUtils(GlobalAuroraTopologyDialect dialect,
HostSpecBuilder hostSpecBuilder) |
| Modifier and Type | Method and Description |
|---|---|
protected HostSpec |
createHost(java.sql.ResultSet rs,
HostSpec initialHostSpec,
java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) |
protected @Nullable java.util.List<HostSpec> |
getHosts(java.sql.ResultSet rs,
HostSpec initialHostSpec,
java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) |
@Nullable java.lang.String |
getRegion(@Nullable java.lang.String instanceId,
java.sql.Connection conn) |
java.util.Map<java.lang.String,HostSpec> |
parseInstanceTemplates(@Nullable java.lang.String instanceTemplatesString,
java.util.function.Consumer<java.lang.String> hostValidator) |
@Nullable java.util.List<HostSpec> |
queryForTopology(java.sql.Connection conn,
HostSpec initialHostSpec,
HostSpec instanceTemplate)
Query the database for information for each instance in the database topology.
|
@Nullable java.util.List<HostSpec> |
queryForTopology(java.sql.Connection conn,
HostSpec initialHostSpec,
java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) |
createHost, getHosts, isWriterInstancecreateHost, createHost, setNetworkTimeout, verifyWriterprotected final GlobalAuroraTopologyDialect dialect
public GlobalAuroraTopologyUtils(GlobalAuroraTopologyDialect dialect, HostSpecBuilder hostSpecBuilder)
public @Nullable java.util.List<HostSpec> queryForTopology(java.sql.Connection conn, HostSpec initialHostSpec, HostSpec instanceTemplate)
TopologyUtilsqueryForTopology in class TopologyUtilsconn - the connection to use to query the database.initialHostSpec - the HostSpec that was used to initially connect.instanceTemplate - the template HostSpec to use when constructing new HostSpec objects from
the data returned by the topology query.HostSpec objects representing the results of the topology query.public @Nullable java.util.List<HostSpec> queryForTopology(java.sql.Connection conn, HostSpec initialHostSpec, java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) throws java.sql.SQLException
java.sql.SQLExceptionprotected @Nullable java.util.List<HostSpec> getHosts(java.sql.ResultSet rs, HostSpec initialHostSpec, java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) throws java.sql.SQLException
java.sql.SQLExceptionprotected HostSpec createHost(java.sql.ResultSet rs, HostSpec initialHostSpec, java.util.Map<java.lang.String,HostSpec> instanceTemplatesByRegion) throws java.sql.SQLException
java.sql.SQLExceptionpublic @Nullable java.lang.String getRegion(@Nullable java.lang.String instanceId,
java.sql.Connection conn)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.Map<java.lang.String,HostSpec> parseInstanceTemplates(@Nullable java.lang.String instanceTemplatesString, java.util.function.Consumer<java.lang.String> hostValidator) throws java.sql.SQLException
java.sql.SQLException