Class GridLoadBalancerManager
- java.lang.Object
-
- org.apache.ignite.internal.managers.GridManagerAdapter<LoadBalancingSpi>
-
- org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager
-
- All Implemented Interfaces:
GridComponent,GridManager
public class GridLoadBalancerManager extends GridManagerAdapter<LoadBalancingSpi>
Load balancing manager.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent
GridComponent.DiscoveryDataExchangeType
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.managers.GridManagerAdapter
ctx, log
-
-
Constructor Summary
Constructors Constructor Description GridLoadBalancerManager(GridKernalContext ctx)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ClusterNodegetBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job)ComputeLoadBalancergetLoadBalancer(GridTaskSessionImpl ses, List<ClusterNode> top)voidstart()Starts grid component.voidstop(boolean cancel)Stops grid component.-
Methods inherited from class org.apache.ignite.internal.managers.GridManagerAdapter
assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, enabled, getSpi, getSpi, getSpis, inject, onAfterSpiStart, onBeforeSpiStart, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode, validateNode
-
-
-
-
Constructor Detail
-
GridLoadBalancerManager
public GridLoadBalancerManager(GridKernalContext ctx)
- Parameters:
ctx- Grid kernal context.
-
-
Method Detail
-
start
public void start() throws IgniteCheckedExceptionStarts grid component.- Throws:
IgniteCheckedException- Throws in case of any errors.
-
stop
public void stop(boolean cancel) throws IgniteCheckedExceptionStops grid component.- Parameters:
cancel- Iftrue, then all ongoing tasks or jobs for relevant components need to be cancelled.- Throws:
IgniteCheckedException- Thrown in case of any errors.
-
getBalancedNode
public ClusterNode getBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job) throws IgniteException
- Parameters:
ses- Task session.top- Task topology.job- Job to balance.- Returns:
- Next balanced node.
- Throws:
IgniteException- If anything failed.
-
getLoadBalancer
public ComputeLoadBalancer getLoadBalancer(GridTaskSessionImpl ses, List<ClusterNode> top)
- Parameters:
ses- Grid task session.top- Task topology.- Returns:
- Load balancer.
-
-