public class RetryUtil
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
RetryUtil.Results |
| Constructor and Description |
|---|
RetryUtil() |
| Modifier and Type | Method and Description |
|---|---|
RetryUtil.Results |
getAllowedConnection(@NonNull PluginService pluginService,
@NonNull java.util.Properties properties,
@Nullable ConnectionPlugin plugin,
@NonNull java.util.function.Supplier<java.util.Set<HostSpec>> allowedHosts,
@Nullable java.lang.String strategy,
@Nullable HostRole verifyRole,
long retryEndNano) |
RetryUtil.Results |
getWriterConnection(@NonNull PluginService pluginService,
@NonNull java.util.Properties properties,
@Nullable ConnectionPlugin plugin,
boolean verifyRole,
long timeoutEndNano) |
protected void |
shortDelay() |
public RetryUtil.Results getWriterConnection(@NonNull PluginService pluginService, @NonNull java.util.Properties properties, @Nullable ConnectionPlugin plugin, boolean verifyRole, long timeoutEndNano) throws java.util.concurrent.TimeoutException, java.sql.SQLException
java.util.concurrent.TimeoutExceptionjava.sql.SQLExceptionpublic RetryUtil.Results getAllowedConnection(@NonNull PluginService pluginService, @NonNull java.util.Properties properties, @Nullable ConnectionPlugin plugin, @NonNull java.util.function.Supplier<java.util.Set<HostSpec>> allowedHosts, @Nullable java.lang.String strategy, @Nullable HostRole verifyRole, long retryEndNano) throws java.util.concurrent.TimeoutException, java.sql.SQLException
java.util.concurrent.TimeoutExceptionjava.sql.SQLExceptionprotected void shortDelay()