public class WeightedRRLCAlgorithm extends Object implements LoadbalanceAlgorithm, ManagedLifecycle
This algorithm is similar to WeightedRoundRobin algorithm
except it takes the active connections made by the endpoints in to account. Weights assinged
to each endpoint and these are static weights. But depending on the active connections these
weights are changed dynamically during the execution.
Algorithm assumes that the endpoint connections to total connection ratio should be eqault to endpoint weight to total weights ratio. If the ratios are different it tries to align them by changing the weights dynamically.
| Modifier and Type | Field and Description |
|---|---|
static String |
LB_WEIGHTED_RRLC_ROUNDS_PER_RECAL |
static String |
LB_WEIGHTED_RRLC_WEIGHT |
static String |
LB_WEIGHTED_RRLC_WEIGHT_MAX |
static String |
LB_WEIGHTED_RRLC_WEIGHT_MIN |
static int |
LB_WEIGHTED_RRLC_WEIGHT_SKEW |
| Constructor and Description |
|---|
WeightedRRLCAlgorithm() |
| Modifier and Type | Method and Description |
|---|---|
LoadbalanceAlgorithm |
clone() |
void |
destroy()
This method should implement the destroying of the
implemented parts of the configuration.
|
int |
getCurrentRound() |
int |
getEndpointCursor() |
String |
getName()
Return the name of the load balancing algorithm
|
org.apache.axis2.clustering.Member |
getNextApplicationMember(AlgorithmContext algorithmContext)
This method returns the next member to which the request has been sent to,
according to the algorithm implementation.
|
Endpoint |
getNextEndpoint(MessageContext messageContext,
AlgorithmContext algorithmContext)
This method returns the next node according to the algorithm implementation.
|
int |
getRoundsPerRecalculation() |
int |
getTotalConnections() |
int |
getTotalWeight() |
void |
init(SynapseEnvironment se)
This method should implement the initialization of the
implemented parts of the configuration.
|
void |
reset(AlgorithmContext algorithmContext)
Resets the algorithm to its initial position.
|
void |
setApplicationMembers(List<org.apache.axis2.clustering.Member> members)
Set the application members
|
void |
setEndpoints(List<Endpoint> endpoints)
Set the endpoints
|
void |
setLoadBalanceEndpoint(Endpoint endpoint)
Set the loadbalance endpoint
|
public static final String LB_WEIGHTED_RRLC_ROUNDS_PER_RECAL
public static final String LB_WEIGHTED_RRLC_WEIGHT
public static final String LB_WEIGHTED_RRLC_WEIGHT_MIN
public static final String LB_WEIGHTED_RRLC_WEIGHT_MAX
public static final int LB_WEIGHTED_RRLC_WEIGHT_SKEW
public void setApplicationMembers(List<org.apache.axis2.clustering.Member> members)
LoadbalanceAlgorithmsetApplicationMembers in interface LoadbalanceAlgorithmmembers - The application memberspublic void setEndpoints(List<Endpoint> endpoints)
LoadbalanceAlgorithmsetEndpoints in interface LoadbalanceAlgorithmendpoints - The endpointspublic void setLoadBalanceEndpoint(Endpoint endpoint)
LoadbalanceAlgorithmsetLoadBalanceEndpoint in interface LoadbalanceAlgorithmendpoint - the endpoint which uses this algorithmpublic Endpoint getNextEndpoint(MessageContext messageContext, AlgorithmContext algorithmContext)
LoadbalanceAlgorithmgetNextEndpoint in interface LoadbalanceAlgorithmmessageContext - SynapseMessageContext of the current messagealgorithmContext - The context in which holds run time states related to the algorithmpublic org.apache.axis2.clustering.Member getNextApplicationMember(AlgorithmContext algorithmContext)
LoadbalanceAlgorithmgetNextApplicationMember in interface LoadbalanceAlgorithmalgorithmContext - The context in which holds run time states related to the algorithmpublic void reset(AlgorithmContext algorithmContext)
LoadbalanceAlgorithmreset in interface LoadbalanceAlgorithmalgorithmContext - The context in which holds run time states related to the algorithmpublic String getName()
LoadbalanceAlgorithmgetName in interface LoadbalanceAlgorithmpublic LoadbalanceAlgorithm clone()
clone in interface LoadbalanceAlgorithmclone in class Objectpublic int getEndpointCursor()
public int getRoundsPerRecalculation()
public int getCurrentRound()
public int getTotalWeight()
public int getTotalConnections()
public void init(SynapseEnvironment se)
ManagedLifecycleinit in interface ManagedLifecyclese - SynapseEnvironment to be used for initializationpublic void destroy()
ManagedLifecycledestroy in interface ManagedLifecycleCopyright © 2005-2017 Apache Software Foundation. All Rights Reserved.