| Package | Description |
|---|---|
| com.taosdata.jdbc.common | |
| com.taosdata.jdbc.rs | |
| com.taosdata.jdbc.utils | |
| com.taosdata.jdbc.ws | |
| com.taosdata.jdbc.ws.loadbalance |
| Modifier and Type | Method and Description |
|---|---|
Set<Endpoint> |
Cluster.getEndpoints()
Gets all nodes in the cluster (unmodifiable).
|
| Constructor and Description |
|---|
Cluster(Endpoint... endpoints)
Constructs a Cluster with variable endpoints.
|
| Constructor and Description |
|---|
Cluster(Set<Endpoint> endpoints)
Constructs a Cluster with a set of endpoints.
|
| Modifier and Type | Method and Description |
|---|---|
List<Endpoint> |
ConnectionParam.getEndpoints() |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectionParam.setEndpoints(List<Endpoint> endpoints) |
| Constructor and Description |
|---|
Builder(List<Endpoint> endpoints) |
| Modifier and Type | Method and Description |
|---|---|
static List<Endpoint> |
Utils.getEndpoints(String host,
String port) |
static List<Endpoint> |
StringUtils.parseEndpoints(String endpointsFullStr) |
| Modifier and Type | Method and Description |
|---|---|
Endpoint |
Transport.getCurrentEndpoint()
Gets the current active endpoint.
|
Endpoint |
WSConnectionManager.getCurrentEndpoint()
Gets the current active endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
Endpoint |
BgHealthCheck.getEndpoint() |
| Modifier and Type | Method and Description |
|---|---|
void |
RebalanceManager.decrementConnectionCount(Endpoint endpoint)
Decrement the connection count of the specified endpoint
Called when a connection is closed to the endpoint
|
void |
RebalanceManager.endpointUp(ConnectionParam param,
Endpoint endpoint)
Mark endpoint as online and trigger rebalancing if conditions are met
|
EndpointInfo |
RebalanceManager.getEndpointInfo(Endpoint endpoint)
Get the metadata (connection count + health status) of the specified endpoint
|
boolean |
RebalanceManager.handleRebalancing(ConnectionParam param,
Endpoint currentEndpoint)
Handle rebalancing logic for the current connection
1.
|
void |
RebalanceManager.incrementConnectionCount(Endpoint endpoint)
Increment the connection count of the specified endpoint
Called when a new connection is established to the endpoint
|
boolean |
RebalanceManager.isRebalancing(Endpoint endpoint)
Check if the cluster of the specified endpoint is in rebalancing state
|
| Modifier and Type | Method and Description |
|---|---|
void |
RebalanceManager.connected(List<Endpoint> endpoints,
int index)
Mark the specified endpoint as online when connection is successful
|
int[] |
RebalanceManager.getConnectCountsAsc(List<Endpoint> endpoints)
Get endpoint indexes sorted by connection count in ascending order
Used for load balancing to select the least loaded endpoint
|
void |
RebalanceManager.newCluster(List<Endpoint> endpoints)
Register a new cluster and initialize endpoint metadata
Idempotent operation: no effect if the cluster is already registered
|
Copyright © 2025. All rights reserved.