| Modifier and Type | Method and Description |
|---|---|
protected Connection |
AbstractDriver.getWSConnection(String url,
ConnectionParam param,
Properties props) |
| Modifier and Type | Method and Description |
|---|---|
ConnectionParam |
ConnectionParam.Builder.build() |
static ConnectionParam |
ConnectionParam.getParam(Properties properties) |
static ConnectionParam |
ConnectionParam.getParamWs(Properties perperties) |
| Modifier and Type | Method and Description |
|---|---|
static ConnectionParam.Builder |
ConnectionParam.copyToBuilder(ConnectionParam original) |
| Modifier and Type | Field and Description |
|---|---|
protected ConnectionParam |
WSRowPreparedStatement.param |
protected ConnectionParam |
WSRetryableStmt.param |
| Modifier and Type | Method and Description |
|---|---|
ConnectionParam |
Transport.getConnectionParam()
Gets the connection parameters.
|
ConnectionParam |
WSConnectionManager.getConnectionParam()
Gets the connection parameters.
|
ConnectionParam |
WSConnection.getParam() |
| Modifier and Type | Method and Description |
|---|---|
static WSClient |
WSClient.getInstance(ConnectionParam params,
int endpointIndex,
WSFunction function) |
static WSClient |
WSClient.getSlaveInstance(ConnectionParam params,
WSFunction function) |
| Constructor and Description |
|---|
AbsWSPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId) |
AbsWSPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId,
Stmt2PrepareResp prepareResp) |
Transport(WSFunction function,
ConnectionParam param,
InFlightRequest inFlightRequest)
Constructs a new Transport instance.
|
TSWSPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId) |
TSWSPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId,
Stmt2PrepareResp prepareResp) |
WebSocketChannelInitializer(ConnectionParam connectionParam,
String host,
int port,
URI serverUri) |
WSClient(URI serverUri,
ConnectionParam connectionParam)
create websocket connection client
|
WSConnection(String url,
Properties properties,
Transport transport,
ConnectionParam param,
String serverVersion) |
WSConnectionManager(WSFunction function,
ConnectionParam param,
InFlightRequest inFlightRequest)
Constructs a new WSConnectionManager with the specified parameters.
|
WSEWPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId,
Stmt2PrepareResp prepareResp) |
WSRetryableStmt(AbstractConnection connection,
ConnectionParam param,
String database,
Transport transport,
Long instanceId,
StmtInfo stmtInfo,
AtomicInteger batchInsertedRows) |
WSRowPreparedStatement(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
String sql,
Long instanceId,
Stmt2PrepareResp prepareResp) |
| Constructor and Description |
|---|
ConnectReq(ConnectionParam param) |
| Modifier and Type | Method and Description |
|---|---|
ConnectionParam |
BgHealthCheck.getParam() |
| Modifier and Type | Method and Description |
|---|---|
void |
RebalanceManager.disconnected(ConnectionParam original,
int index,
InFlightRequest inFlightRequest)
Handle endpoint disconnection event
1.
|
void |
RebalanceManager.disconnectedBySelf(ConnectionParam original,
int index)
Handle self-initiated disconnection (only decrement connection count)
|
void |
RebalanceManager.endpointUp(ConnectionParam param,
Endpoint endpoint)
Mark endpoint as online and trigger rebalancing if conditions are met
|
int |
RebalanceManager.getMinConnectionEndpointIndex(ConnectionParam param)
Get the index of the endpoint with the minimum connection count
Used to select the least loaded endpoint for rebalancing
|
boolean |
RebalanceManager.handleRebalancing(ConnectionParam param,
Endpoint currentEndpoint)
Handle rebalancing logic for the current connection
1.
|
void |
RebalanceManager.startBackgroundHealthCheck(ConnectionParam original,
int index,
InFlightRequest inFlightRequest)
Start background health check for offline endpoints
Monitors endpoint recovery status and updates state when online
|
| Constructor and Description |
|---|
BgHealthCheck(WSFunction wsFunction,
ConnectionParam param,
int index,
InFlightRequest inFlightRequest) |
| Modifier and Type | Method and Description |
|---|---|
ConnectionParam |
PstmtConInfo.getParam() |
| Constructor and Description |
|---|
PstmtConInfo(Transport transport,
ConnectionParam param,
String database,
AbstractConnection connection,
Long instanceId) |
| Modifier and Type | Method and Description |
|---|---|
ConnectionParam |
ConsumerParam.getConnectionParam() |
| Modifier and Type | Method and Description |
|---|---|
void |
ConsumerParam.setConnectionParam(ConnectionParam connectionParam) |
Copyright © 2025. All rights reserved.