Class GridClientRoundRobinBalancer
- java.lang.Object
-
- org.apache.ignite.internal.client.balancer.GridClientBalancerAdapter
-
- org.apache.ignite.internal.client.balancer.GridClientRoundRobinBalancer
-
- All Implemented Interfaces:
GridClientLoadBalancer,GridClientTopologyListener
public class GridClientRoundRobinBalancer extends GridClientBalancerAdapter implements GridClientTopologyListener
Simple balancer that implements round-robin balancing.
-
-
Constructor Summary
Constructors Constructor Description GridClientRoundRobinBalancer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description GridClientNodebalancedNode(Collection<? extends GridClientNode> nodes)Gets next node for executing client command.voidonNodeAdded(GridClientNode node)Callback for new nodes joining the remote grid.voidonNodeRemoved(GridClientNode node)Callback for nodes leaving the remote grid.-
Methods inherited from class org.apache.ignite.internal.client.balancer.GridClientBalancerAdapter
isPreferDirectNodes, selectDirectNodes, setPreferDirectNodes
-
-
-
-
Method Detail
-
balancedNode
public GridClientNode balancedNode(Collection<? extends GridClientNode> nodes) throws GridClientException
Gets next node for executing client command.- Specified by:
balancedNodein interfaceGridClientLoadBalancer- Parameters:
nodes- Nodes to pick from, should not be empty.- Returns:
- Next node to pick.
- Throws:
GridClientException- If balancer can't match given nodes with current topology snapshot.
-
onNodeAdded
public void onNodeAdded(GridClientNode node)
Callback for new nodes joining the remote grid.- Specified by:
onNodeAddedin interfaceGridClientTopologyListener- Parameters:
node- New remote node.
-
onNodeRemoved
public void onNodeRemoved(GridClientNode node)
Callback for nodes leaving the remote grid.- Specified by:
onNodeRemovedin interfaceGridClientTopologyListener- Parameters:
node- Left node.
-
-