public class TaskCoordinator extends Object implements io.fabric8.groups.GroupListener<WorkerNode>, WorkItemListener
Constructor and Description |
---|
TaskCoordinator(TaskContext context,
WorkItemRepository repository,
BalancingPolicy balancingPolicy,
org.apache.curator.framework.CuratorFramework curator) |
Modifier and Type | Method and Description |
---|---|
void |
groupEvent(io.fabric8.groups.Group<WorkerNode> group,
io.fabric8.groups.GroupListener.GroupEvent event) |
void |
partitionUpdated()
Call whenever the partitions are updated.
|
void |
rebalance()
Re-balances all available
WorkItem items to all available Workers. |
void |
start() |
void |
stop() |
public TaskCoordinator(TaskContext context, WorkItemRepository repository, BalancingPolicy balancingPolicy, org.apache.curator.framework.CuratorFramework curator)
public void start()
public void stop()
public void groupEvent(io.fabric8.groups.Group<WorkerNode> group, io.fabric8.groups.GroupListener.GroupEvent event)
groupEvent
in interface io.fabric8.groups.GroupListener<WorkerNode>
public void partitionUpdated()
WorkItemListener
partitionUpdated
in interface WorkItemListener
public void rebalance()
WorkItem
items to all available Workers.Copyright © 2011–2014 Red Hat. All rights reserved.