Package | Description |
---|---|
io.fabric8.partition | |
io.fabric8.partition.internal | |
io.fabric8.partition.internal.profile |
Modifier and Type | Method and Description |
---|---|
void |
Worker.assign(TaskContext context,
Set<WorkItem> workItems)
Start processing the assigned
WorkItem items of the specified task. |
void |
BalancingPolicy.rebalance(TaskContext context,
Collection<String> workItems,
Collection<String> members)
Distribute the items to the specified members.
|
void |
Worker.release(TaskContext context,
Set<WorkItem> workItems)
Stop processing the assigned
WorkItem items of the specified task. |
void |
Worker.stop(TaskContext context)
Stops processing of items.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskContextImpl |
Modifier and Type | Method and Description |
---|---|
void |
LoggingWorker.assign(TaskContext context,
Set<WorkItem> workItems) |
void |
EvenBalancingPolicy.rebalance(TaskContext context,
Collection<String> workItems,
Collection<String> members) |
void |
LoggingWorker.release(TaskContext context,
Set<WorkItem> workItems) |
void |
LoggingWorker.stop(TaskContext context) |
Constructor and Description |
---|
TaskCoordinator(TaskContext context,
WorkItemRepository repository,
BalancingPolicy balancingPolicy,
org.apache.curator.framework.CuratorFramework curator) |
TaskHandler(String name,
TaskContext context,
org.apache.curator.framework.CuratorFramework curator,
Worker worker,
WorkItemRepository repository) |
Modifier and Type | Method and Description |
---|---|
void |
ProfileTemplateWorker.assign(TaskContext context,
Set<WorkItem> workItems) |
void |
ProfileTemplateWorker.release(TaskContext context,
Set<WorkItem> workItems) |
void |
ProfileTemplateWorker.stop(TaskContext context) |
Copyright © 2011–2014 Red Hat. All rights reserved.