Package | Description |
---|---|
org.mariadb.jdbc | |
org.mariadb.jdbc.internal.com.send | |
org.mariadb.jdbc.internal.failover | |
org.mariadb.jdbc.internal.failover.impl | |
org.mariadb.jdbc.internal.protocol |
Modifier and Type | Field and Description |
---|---|
private java.util.List<HostAddress> |
UrlParser.addresses |
Modifier and Type | Method and Description |
---|---|
private static HostAddress |
HostAddress.parseParameterHostAddress(java.lang.String str) |
private static HostAddress |
HostAddress.parseSimpleHostAddress(java.lang.String str) |
Modifier and Type | Method and Description |
---|---|
java.util.List<HostAddress> |
UrlParser.getHostAddresses() |
static java.util.List<HostAddress> |
HostAddress.parse(java.lang.String spec,
HaMode haMode)
parse - parse server addresses from the URL fragment.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
HostAddress.toString(HostAddress[] addrs)
ToString implementation of addresses.
|
Modifier and Type | Method and Description |
---|---|
void |
UrlParser.setHostAddresses(java.util.List<HostAddress> addresses) |
static java.lang.String |
HostAddress.toString(java.util.List<HostAddress> addrs)
ToString implementation of addresses.
|
Constructor and Description |
---|
UrlParser(java.lang.String database,
java.util.List<HostAddress> addresses,
Options options,
HaMode haMode) |
Modifier and Type | Method and Description |
---|---|
static void |
SendHandshakeResponsePacket.send(PacketOutputStream pos,
java.lang.String username,
java.lang.String password,
HostAddress currentHost,
java.lang.String database,
long clientCapabilities,
long serverCapabilities,
byte serverLanguage,
byte packetSeq,
Options options,
ReadInitialHandShakePacket greetingPacket)
Send handshake response packet.
|
private static void |
SendHandshakeResponsePacket.writeConnectAttributes(PacketOutputStream pos,
java.lang.String connectionAttributes,
HostAddress currentHost) |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.ConcurrentMap<HostAddress,java.lang.Long> |
AbstractMastersListener.blacklist
List the recent failedConnection.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<HostAddress> |
AbstractMastersListener.getBlacklistKeys() |
java.util.Set<HostAddress> |
Listener.getBlacklistKeys() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMastersListener.addToBlacklist(HostAddress hostAddress)
After a failover, put the hostAddress in a static list so the other connection will not take
this host in account for a time.
|
void |
Listener.addToBlacklist(HostAddress hostAddress) |
void |
AbstractMastersListener.removeFromBlacklist(HostAddress hostAddress)
After a successfull connection, permit to remove a hostAddress from blacklist.
|
void |
Listener.removeFromBlacklist(HostAddress hostAddress) |
void |
AbstractMastersListener.throwFailoverMessage(HostAddress failHostAddress,
boolean wasMaster,
java.sql.SQLException queryException,
boolean reconnected)
Throw a human readable message after a failoverException.
|
void |
Listener.throwFailoverMessage(HostAddress failHostAddress,
boolean wasMaster,
java.sql.SQLException queryException,
boolean reconnected) |
Modifier and Type | Field and Description |
---|---|
private HostAddress |
AuroraListener.clusterHostAddress |
Modifier and Type | Method and Description |
---|---|
private HostAddress |
AuroraListener.findClusterHostAddress(UrlParser urlParser)
Retrieves the cluster host address from the UrlParser instance.
|
HostAddress |
AuroraListener.getClusterHostAddress() |
HostAddress |
AuroraListener.searchByStartName(Protocol secondaryProtocol,
java.util.List<HostAddress> loopAddress)
Looks for the current master/writer instance via the secondary protocol if it is found within 3
attempts.
|
private HostAddress |
AuroraListener.searchForMasterHostAddress(Protocol protocol,
java.util.List<HostAddress> loopAddress)
Aurora replica doesn't have the master endpoint but the master instance name.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<HostAddress> |
MastersSlavesListener.connectedHosts()
List current connected HostAddress.
|
Modifier and Type | Method and Description |
---|---|
HostAddress |
AuroraListener.searchByStartName(Protocol secondaryProtocol,
java.util.List<HostAddress> loopAddress)
Looks for the current master/writer instance via the secondary protocol if it is found within 3
attempts.
|
private HostAddress |
AuroraListener.searchForMasterHostAddress(Protocol protocol,
java.util.List<HostAddress> loopAddress)
Aurora replica doesn't have the master endpoint but the master instance name.
|
Modifier and Type | Field and Description |
---|---|
private HostAddress |
AbstractConnectProtocol.currentHost |
Modifier and Type | Method and Description |
---|---|
HostAddress |
Protocol.getHostAddress() |
HostAddress |
AbstractConnectProtocol.getHostAddress() |
Modifier and Type | Method and Description |
---|---|
private static void |
AuroraProtocol.searchProbableMaster(AuroraListener listener,
GlobalStateInfo globalInfo,
HostAddress probableMaster)
Connect aurora probable master.
|
void |
Protocol.setHostAddress(HostAddress hostAddress) |
void |
AbstractConnectProtocol.setHostAddress(HostAddress host) |
Modifier and Type | Method and Description |
---|---|
static void |
AuroraProtocol.loop(AuroraListener listener,
GlobalStateInfo globalInfo,
java.util.List<HostAddress> addresses,
SearchFilter initialSearchFilter)
loop until found the failed connection.
|
static void |
MasterProtocol.loop(Listener listener,
GlobalStateInfo globalInfo,
java.util.List<HostAddress> addresses,
SearchFilter searchFilter)
loop until found the failed connection.
|
static void |
MastersSlavesProtocol.loop(MastersSlavesListener listener,
GlobalStateInfo globalInfo,
java.util.List<HostAddress> addresses,
SearchFilter searchFilter)
loop until found the failed connection.
|
private static void |
AuroraProtocol.resetHostList(AuroraListener listener,
java.util.Deque<HostAddress> loopAddresses)
Reinitialize loopAddresses with all hosts : all servers in randomize order with cluster
address.
|
private static void |
MasterProtocol.resetHostList(Listener listener,
java.util.Deque<HostAddress> loopAddresses)
Reinitialize loopAddresses with all hosts : all servers in randomize order without connected
host.
|
private static void |
MastersSlavesProtocol.resetHostList(MastersSlavesListener listener,
java.util.Deque<HostAddress> loopAddresses)
Reinitialize loopAddresses with all servers in randomize order.
|