Package | Description |
---|---|
com.xjeffrose.xio.client | |
com.xjeffrose.xio.client.loadbalancer | |
com.xjeffrose.xio.client.loadbalancer.strategies |
Modifier and Type | Method and Description |
---|---|
Node |
SingleUnpooledNodeClient.buildNode(InetSocketAddress address,
io.netty.bootstrap.Bootstrap bootstrap) |
Node |
SingleNodeClient.buildNode(InetSocketAddress address,
io.netty.bootstrap.Bootstrap bootstrap) |
abstract Node |
XioClient.getNode() |
Node |
SingleNodeClient.getNode() |
Node |
MultiNodeClient.getNode() |
Modifier and Type | Class and Description |
---|---|
class |
UnpooledNode |
Modifier and Type | Method and Description |
---|---|
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
Distributor.getNodeById(UUID id)
The node returned by UUID.
|
Node |
Distributor.pick()
Pick the next node.
|
Modifier and Type | Method and Description |
---|---|
Map<UUID,Node> |
Distributor.getOkNodes() |
com.google.common.collect.ImmutableList<Node> |
Distributor.getPool() |
Modifier and Type | Method and Description |
---|---|
void |
NodeHealthCheck.connect(Node node,
Protocol proto,
boolean ssl,
ECV ecv) |
boolean |
Strategy.okToPick(Node node) |
Modifier and Type | Method and Description |
---|---|
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
Strategy.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Distributor |
Distributor.rebuild(com.google.common.collect.ImmutableList<Node> list)
Rebuild this distributor with a new vector.
|
Constructor and Description |
---|
Node(Node n) |
NodeECV(Node node,
Protocol proto,
ECV ecv) |
NodeStat(Node node) |
Constructor and Description |
---|
Distributor(com.google.common.collect.ImmutableList<Node> pool,
Strategy strategy,
NodeHealthCheck nodeHealthCheck,
XioTimer xioTimer) |
Modifier and Type | Method and Description |
---|---|
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Modifier and Type | Method and Description |
---|---|
boolean |
RoundRobinLoadBalancer.okToPick(Node node) |
boolean |
FilteredRoundRobinLoadBalancer.okToPick(Node node) |
boolean |
ConsistantHashLoadBalancer.okToPick(Node node) |
Modifier and Type | Method and Description |
---|---|
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes) |
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
RoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
FilteredRoundRobinLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Node |
ConsistantHashLoadBalancer.getNextNode(com.google.common.collect.ImmutableList<Node> pool,
Map<UUID,Node> okNodes,
String sessionID) |
Copyright © 2016. All Rights Reserved.