Package | Description |
---|---|
com.predic8.membrane.core.interceptor.balancer |
Modifier and Type | Method and Description |
---|---|
Node |
RoundRobinStrategy.dispatch(LoadBalancingInterceptor interceptor) |
Node |
DispatchingStrategy.dispatch(LoadBalancingInterceptor interceptor) |
Node |
ByThreadStrategy.dispatch(LoadBalancingInterceptor interceptor) |
Node |
Session.getNode() |
Node |
Cluster.getNode(Node ep) |
static Node |
BalancerUtil.getNode(Router router,
String balancerName,
String cluster,
String host,
int port) |
Node |
Balancer.getNode(String cluster,
String host,
int port) |
Modifier and Type | Method and Description |
---|---|
List<Node> |
Cluster.getAllNodes(long timeout) |
static List<Node> |
BalancerUtil.getAllNodesByCluster(Router router,
String balancerName,
String cName) |
List<Node> |
Balancer.getAllNodesByCluster(String cName) |
List<Node> |
Cluster.getAvailableNodes(long timeout) |
static List<Node> |
BalancerUtil.getAvailableNodesByCluster(Router router,
String balancerName,
String cName) |
List<Node> |
Balancer.getAvailableNodesByCluster(String cName) |
List<Node> |
LoadBalancingInterceptor.getEndpoints() |
Modifier and Type | Method and Description |
---|---|
void |
Cluster.addSession(String sessionId,
Node n) |
static void |
BalancerUtil.addSession2Cluster(Router router,
String balancerName,
String sessionId,
String cName,
Node n) |
void |
Balancer.addSession2Cluster(String sessionId,
String cName,
Node n) |
Node |
Cluster.getNode(Node ep) |
List<Session> |
Cluster.getSessionsByNode(Node node) |
static List<Session> |
BalancerUtil.getSessionsByNode(Router router,
String balancerName,
String cName,
Node node) |
List<Session> |
Balancer.getSessionsByNode(String cName,
Node node) |
void |
Cluster.nodeDown(Node n) |
void |
Cluster.nodeTakeOut(Node n) |
void |
Cluster.nodeUp(Node n) |
boolean |
Cluster.removeNode(Node node) |
Copyright © 2012. All Rights Reserved.