public interface Listener
Modifier and Type | Method and Description |
---|---|
void |
addToBlacklist(HostAddress hostAddress) |
boolean |
canRetryFailLoop() |
boolean |
checkMasterStatus(SearchFilter searchFilter) |
void |
foundActiveMaster(Protocol protocol) |
java.util.Set<HostAddress> |
getBlacklistKeys() |
Protocol |
getCurrentProtocol() |
SearchFilter |
getFilterForFailedHost() |
long |
getLastQueryNanos() |
FailoverProxy |
getProxy() |
int |
getRetriesAllDown() |
UrlParser |
getUrlParser() |
HandleErrorResult |
handleFailover(java.sql.SQLException qe,
java.lang.reflect.Method method,
java.lang.Object[] args,
Protocol protocol) |
boolean |
hasHostFail() |
void |
initializeConnection() |
java.lang.Object |
invoke(java.lang.reflect.Method method,
java.lang.Object[] args) |
java.lang.Object |
invoke(java.lang.reflect.Method method,
java.lang.Object[] args,
Protocol specificProtocol) |
boolean |
isAutoReconnect() |
boolean |
isClosed() |
boolean |
isExplicitClosed() |
boolean |
isMasterConnected() |
boolean |
isMasterHostFail() |
boolean |
isReadOnly() |
void |
preClose() |
void |
preExecute() |
HandleErrorResult |
primaryFail(java.lang.reflect.Method method,
java.lang.Object[] args) |
void |
reconnect() |
void |
reconnectFailedConnection(SearchFilter filter) |
void |
removeFromBlacklist(HostAddress hostAddress) |
void |
rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult,
boolean mustExecuteOnMaster) |
boolean |
setMasterHostFail() |
void |
setProxy(FailoverProxy proxy) |
void |
switchReadOnlyConnection(java.lang.Boolean readonly) |
void |
syncConnection(Protocol from,
Protocol to) |
void |
throwFailoverMessage(HostAddress failHostAddress,
boolean wasMaster,
java.sql.SQLException queryException,
boolean reconnected) |
FailoverProxy getProxy()
void setProxy(FailoverProxy proxy)
void initializeConnection() throws java.sql.SQLException
java.sql.SQLException
void preExecute() throws java.sql.SQLException
java.sql.SQLException
void preClose() throws java.sql.SQLException
java.sql.SQLException
void reconnectFailedConnection(SearchFilter filter) throws java.sql.SQLException
java.sql.SQLException
void switchReadOnlyConnection(java.lang.Boolean readonly) throws java.sql.SQLException
java.sql.SQLException
HandleErrorResult primaryFail(java.lang.reflect.Method method, java.lang.Object[] args) throws java.lang.Throwable
java.lang.Throwable
java.lang.Object invoke(java.lang.reflect.Method method, java.lang.Object[] args, Protocol specificProtocol) throws java.lang.Throwable
java.lang.Throwable
java.lang.Object invoke(java.lang.reflect.Method method, java.lang.Object[] args) throws java.lang.Throwable
java.lang.Throwable
HandleErrorResult handleFailover(java.sql.SQLException qe, java.lang.reflect.Method method, java.lang.Object[] args, Protocol protocol) throws java.lang.Throwable
java.lang.Throwable
void foundActiveMaster(Protocol protocol) throws java.sql.SQLException
java.sql.SQLException
java.util.Set<HostAddress> getBlacklistKeys()
void addToBlacklist(HostAddress hostAddress)
void removeFromBlacklist(HostAddress hostAddress)
void syncConnection(Protocol from, Protocol to) throws java.sql.SQLException
java.sql.SQLException
UrlParser getUrlParser()
void throwFailoverMessage(HostAddress failHostAddress, boolean wasMaster, java.sql.SQLException queryException, boolean reconnected) throws java.sql.SQLException
java.sql.SQLException
boolean isAutoReconnect()
int getRetriesAllDown()
boolean isExplicitClosed()
void reconnect() throws java.sql.SQLException
java.sql.SQLException
boolean isReadOnly()
boolean isClosed()
Protocol getCurrentProtocol()
boolean hasHostFail()
boolean canRetryFailLoop()
SearchFilter getFilterForFailedHost()
boolean isMasterConnected()
boolean setMasterHostFail()
boolean isMasterHostFail()
long getLastQueryNanos()
boolean checkMasterStatus(SearchFilter searchFilter)
void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustExecuteOnMaster) throws java.sql.SQLException
java.sql.SQLException