| 限定符和类型 | 方法和说明 |
|---|---|
static OceanBaseConnection |
OceanBaseConnection.newConnection(UrlParser urlParser,
GlobalStateInfo globalInfo)
Create new connection Object.
|
| 构造器和说明 |
|---|
OceanBaseConnection(UrlParser urlParser,
GlobalStateInfo globalInfo,
boolean flag) |
| 限定符和类型 | 字段和说明 |
|---|---|
protected GlobalStateInfo |
AbstractMastersListener.globalInfo |
| 构造器和说明 |
|---|
AbstractMastersListener(UrlParser urlParser,
GlobalStateInfo globalInfo) |
AbstractMastersSlavesListener(UrlParser urlParser,
GlobalStateInfo globalInfo) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
LoadBalanceDriver.loop(UrlParser urlParser,
Listener listener,
GlobalStateInfo globalInfo,
SearchFilter searchFilter,
ConcurrentMap<HostAddress,HostStateInfo> blacklist,
Set<HostAddress> pickedList) |
| 构造器和说明 |
|---|
AuroraListener(UrlParser urlParser,
GlobalStateInfo globalInfo)
Constructor for Aurora.
|
MastersFailoverListener(UrlParser urlParser,
GlobalStateInfo globalInfo)
Initialisation.
|
MastersSlavesListener(UrlParser urlParser,
GlobalStateInfo globalInfo)
Initialisation.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static AuroraProtocol |
AuroraProtocol.getNewProtocol(FailoverProxy proxy,
GlobalStateInfo globalInfo,
UrlParser urlParser)
Initialize new protocol instance.
|
static void |
AuroraProtocol.loop(AuroraListener listener,
GlobalStateInfo globalInfo,
List<HostAddress> addresses,
SearchFilter initialSearchFilter)
loop until found the failed connection.
|
static void |
MasterProtocol.loop(Listener listener,
GlobalStateInfo globalInfo,
List<HostAddress> addresses) |
static void |
MasterProtocol.loop(Listener listener,
GlobalStateInfo globalInfo,
List<HostAddress> addresses,
boolean fallThrough)
loop until found the failed connection.
|
static void |
MastersSlavesProtocol.loop(MastersSlavesListener listener,
GlobalStateInfo globalInfo,
List<HostAddress> addresses,
SearchFilter searchFilter)
loop until found the failed connection.
|
| 构造器和说明 |
|---|
AbstractConnectProtocol(UrlParser urlParser,
GlobalStateInfo globalInfo,
ReentrantLock lock,
LruTraceCache traceCache)
Get a protocol instance.
|
AuroraProtocol(UrlParser url,
GlobalStateInfo globalInfo,
ReentrantLock lock,
LruTraceCache traceCache) |
MasterProtocol(UrlParser urlParser,
GlobalStateInfo globalInfo,
ReentrantLock lock,
LruTraceCache traceCache)
Get a protocol instance.
|
MastersSlavesProtocol(UrlParser url,
GlobalStateInfo globalInfo,
ReentrantLock lock,
LruTraceCache traceCache) |
| 限定符和类型 | 方法和说明 |
|---|---|
static Protocol |
Utils.retrieveProxy(UrlParser urlParser,
GlobalStateInfo globalInfo)
Retrieve protocol corresponding to the failover options. if no failover option, protocol will
not be proxied. if a failover option is precised, protocol will be proxied so that any
connection error will be handle directly.
|
| 限定符和类型 | 方法和说明 |
|---|---|
GlobalStateInfo |
Pool.getGlobalInfo() |
Copyright © 2024 oceanbase.com. All rights reserved.