A B C E G H I L M N P R S T V W Z 

A

addListener(WorkItemListener) - Method in class io.fabric8.partition.internal.BaseWorkItemRepository
 
addListener(WorkItemListener) - Method in interface io.fabric8.partition.WorkItemRepository
 
apply(ChildData) - Method in enum io.fabric8.partition.internal.functions.ChildDataToPath
 
apply(String) - Method in enum io.fabric8.partition.internal.profile.MvelPredicate
 
assign(TaskContext, Set<WorkItem>) - Method in class io.fabric8.partition.internal.LoggingWorker
 
assign(TaskContext, Set<WorkItem>) - Method in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
assign(TaskContext, Set<WorkItem>) - Method in interface io.fabric8.partition.Worker
Start processing the assigned WorkItem items of the specified task.

B

BalancingPolicy - Interface in io.fabric8.partition
An interface that describes a way to distribute a number of work items to group of members.
BaseWorkItemRepository - Class in io.fabric8.partition.internal
 
BaseWorkItemRepository() - Constructor for class io.fabric8.partition.internal.BaseWorkItemRepository
 
build(String) - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 
build(String) - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 
build(String) - Method in interface io.fabric8.partition.WorkItemRepositoryFactory
 

C

ChildDataToPath - Enum in io.fabric8.partition.internal.functions
 
childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
close() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
close() - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
close() - Method in interface io.fabric8.partition.WorkItemRepository
Completely shuts down the repository.
CONTNTENT - Static variable in interface io.fabric8.partition.WorkItem
 

E

equals(Object) - Method in class io.fabric8.partition.internal.TaskContextImpl
 
equals(Object) - Method in class io.fabric8.partition.internal.WorkItemImpl
 
EvenBalancingPolicy - Class in io.fabric8.partition.internal
 
EvenBalancingPolicy() - Constructor for class io.fabric8.partition.internal.EvenBalancingPolicy
 

G

getConfiguration() - Method in class io.fabric8.partition.internal.TaskContextImpl
 
getConfiguration() - Method in interface io.fabric8.partition.TaskContext
 
getContent() - Method in class io.fabric8.partition.internal.WorkItemImpl
 
getContent() - Method in interface io.fabric8.partition.WorkItem
Returns the content of the item.
getData() - Method in class io.fabric8.partition.internal.WorkItemImpl
 
getData() - Method in interface io.fabric8.partition.WorkItem
Returns the work item data.
getId() - Method in class io.fabric8.partition.internal.TaskContextImpl
 
getId() - Method in class io.fabric8.partition.internal.WorkItemImpl
 
getId() - Method in interface io.fabric8.partition.TaskContext
 
getId() - Method in interface io.fabric8.partition.WorkItem
Returns the work item id.
getItems() - Method in class io.fabric8.partition.WorkerNode
 
getLocation() - Method in class io.fabric8.partition.internal.WorkItemImpl
 
getLocation() - Method in interface io.fabric8.partition.WorkItem
Returns the location of the item.
getServices() - Method in class io.fabric8.partition.WorkerNode
 
getType() - Method in interface io.fabric8.partition.BalancingPolicy
An identifier for the policy.
getType() - Method in class io.fabric8.partition.internal.EvenBalancingPolicy
 
getType() - Method in class io.fabric8.partition.internal.LoggingWorker
 
getType() - Method in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
getType() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 
getType() - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 
getType() - Method in interface io.fabric8.partition.Worker
 
getType() - Method in interface io.fabric8.partition.WorkItemRepositoryFactory
 
groupEvent(Group<WorkerNode>, GroupListener.GroupEvent) - Method in class io.fabric8.partition.internal.TaskCoordinator
 

H

hashCode() - Method in class io.fabric8.partition.internal.TaskContextImpl
 
hashCode() - Method in class io.fabric8.partition.internal.WorkItemImpl
 

I

ID - Static variable in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 
ID - Static variable in class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 
ID_PREFIX - Static variable in interface io.fabric8.partition.WorkItemRepositoryFactory
 
ID_PROPERTY_NAME - Static variable in interface io.fabric8.partition.WorkItem
 
io.fabric8.partition - package io.fabric8.partition
 
io.fabric8.partition.internal - package io.fabric8.partition.internal
 
io.fabric8.partition.internal.functions - package io.fabric8.partition.internal.functions
 
io.fabric8.partition.internal.profile - package io.fabric8.partition.internal.profile
 
io.fabric8.partition.internal.repositories - package io.fabric8.partition.internal.repositories
 
ITEM - Static variable in interface io.fabric8.partition.WorkItem
 
ITEM_DATA_PREFIX - Static variable in interface io.fabric8.partition.WorkItem
 

L

listWorkItemLocations() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
listWorkItemLocations() - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
listWorkItemLocations() - Method in interface io.fabric8.partition.WorkItemRepository
 
LOCATION_PROPERTY_NAME - Static variable in interface io.fabric8.partition.WorkItem
 
LoggingWorker - Class in io.fabric8.partition.internal
 
LoggingWorker() - Constructor for class io.fabric8.partition.internal.LoggingWorker
 

M

MvelPredicate - Enum in io.fabric8.partition.internal.profile
 

N

nodeChanged() - Method in class io.fabric8.partition.internal.TaskHandler
 
notifyListeners() - Method in class io.fabric8.partition.internal.BaseWorkItemRepository
 
notifyListeners() - Method in interface io.fabric8.partition.WorkItemRepository
 

P

PartitionManager - Class in io.fabric8.partition.internal
 
PartitionManager() - Constructor for class io.fabric8.partition.internal.PartitionManager
 
partitionUpdated() - Method in class io.fabric8.partition.internal.TaskCoordinator
 
partitionUpdated() - Method in interface io.fabric8.partition.WorkItemListener
Call whenever the partitions are updated.
ProfileTemplateWorker - Class in io.fabric8.partition.internal.profile
 
ProfileTemplateWorker() - Constructor for class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
ProfileWorkItemRepository - Class in io.fabric8.partition.internal.repositories
 
ProfileWorkItemRepository(String, GitDataStore, String, FabricService) - Constructor for class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
ProfileWorkItemRepositoryFactory - Class in io.fabric8.partition.internal.repositories
 
ProfileWorkItemRepositoryFactory() - Constructor for class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 

R

readContent(String) - Method in class io.fabric8.partition.internal.BaseWorkItemRepository
 
readContent(String) - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
readContent(String) - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
readWorkItem(String) - Method in class io.fabric8.partition.internal.BaseWorkItemRepository
 
readWorkItem(String) - Method in interface io.fabric8.partition.WorkItemRepository
 
rebalance(TaskContext, Collection<String>, Collection<String>) - Method in interface io.fabric8.partition.BalancingPolicy
Distribute the items to the specified members.
rebalance(TaskContext, Collection<String>, Collection<String>) - Method in class io.fabric8.partition.internal.EvenBalancingPolicy
 
rebalance() - Method in class io.fabric8.partition.internal.TaskCoordinator
Re-balances all available WorkItem items to all available Workers.
release(TaskContext, Set<WorkItem>) - Method in class io.fabric8.partition.internal.LoggingWorker
 
release(TaskContext, Set<WorkItem>) - Method in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
release(TaskContext, Set<WorkItem>) - Method in interface io.fabric8.partition.Worker
Stop processing the assigned WorkItem items of the specified task.
removeListener(WorkItemListener) - Method in class io.fabric8.partition.internal.BaseWorkItemRepository
 
removeListener(WorkItemListener) - Method in interface io.fabric8.partition.WorkItemRepository
 
run() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 

S

SCHEME - Static variable in class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 
SCHME - Static variable in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 
setItems(String[]) - Method in class io.fabric8.partition.WorkerNode
 
setServices(String[]) - Method in class io.fabric8.partition.WorkerNode
 
start() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
start() - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
start() - Method in class io.fabric8.partition.internal.TaskCoordinator
 
start() - Method in class io.fabric8.partition.internal.TaskHandler
 
start() - Method in interface io.fabric8.partition.WorkItemRepository
Start or resume the repository.
stop(TaskContext) - Method in class io.fabric8.partition.internal.LoggingWorker
 
stop(TaskContext) - Method in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
stop() - Method in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepository
 
stop() - Method in class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
stop() - Method in class io.fabric8.partition.internal.TaskCoordinator
 
stop() - Method in class io.fabric8.partition.internal.TaskHandler
 
stop(TaskContext) - Method in interface io.fabric8.partition.Worker
Stops processing of items.
stop() - Method in interface io.fabric8.partition.WorkItemRepository
Suspends the repository.
stopAll() - Method in class io.fabric8.partition.internal.LoggingWorker
 
stopAll() - Method in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
stopAll() - Method in interface io.fabric8.partition.Worker
Stops processing of items.

T

TASK_ID - Static variable in class io.fabric8.partition.internal.PartitionManager
 
TaskContext - Interface in io.fabric8.partition
 
TaskContextImpl - Class in io.fabric8.partition.internal
 
TaskContextImpl(String, Map<String, ?>) - Constructor for class io.fabric8.partition.internal.TaskContextImpl
 
TaskCoordinator - Class in io.fabric8.partition.internal
 
TaskCoordinator(TaskContext, WorkItemRepository, BalancingPolicy, CuratorFramework) - Constructor for class io.fabric8.partition.internal.TaskCoordinator
 
TaskHandler - Class in io.fabric8.partition.internal
 
TaskHandler(String, TaskContext, CuratorFramework, Worker, WorkItemRepository) - Constructor for class io.fabric8.partition.internal.TaskHandler
 
TEMPLATE_PROFILE_PROPERTY_NAME - Static variable in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
toString() - Method in class io.fabric8.partition.internal.WorkItemImpl
 
toString() - Method in class io.fabric8.partition.WorkerNode
 
TYPE - Static variable in class io.fabric8.partition.internal.EvenBalancingPolicy
 
TYPE - Static variable in class io.fabric8.partition.internal.LoggingWorker
 
TYPE - Static variable in class io.fabric8.partition.internal.profile.ProfileTemplateWorker
 
TYPE - Static variable in class io.fabric8.partition.internal.repositories.ProfileWorkItemRepositoryFactory
 
TYPE - Static variable in class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 

V

valueOf(String) - Static method in enum io.fabric8.partition.internal.functions.ChildDataToPath
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.fabric8.partition.internal.profile.MvelPredicate
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.fabric8.partition.internal.functions.ChildDataToPath
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.fabric8.partition.internal.profile.MvelPredicate
Returns an array containing the constants of this enum type, in the order they are declared.

W

WORK_BALANCING_POLICY - Static variable in class io.fabric8.partition.internal.PartitionManager
 
Worker - Interface in io.fabric8.partition
Describes a unit that can be assigned / removed multiple work items as part of a task.
WORKER_TYPE - Static variable in class io.fabric8.partition.internal.PartitionManager
 
WorkerNode - Class in io.fabric8.partition
 
WorkerNode() - Constructor for class io.fabric8.partition.WorkerNode
 
WorkerNode(String) - Constructor for class io.fabric8.partition.WorkerNode
 
WorkItem - Interface in io.fabric8.partition
 
WORKITEM_PATH - Static variable in class io.fabric8.partition.internal.PartitionManager
 
WORKITEM_REPO_TYPE - Static variable in class io.fabric8.partition.internal.PartitionManager
 
WorkItemImpl - Class in io.fabric8.partition.internal
 
WorkItemImpl(String, String, String, Map<String, String>) - Constructor for class io.fabric8.partition.internal.WorkItemImpl
 
WorkItemListener - Interface in io.fabric8.partition
 
WorkItemRepository - Interface in io.fabric8.partition
 
WorkItemRepositoryFactory - Interface in io.fabric8.partition
 

Z

ZkWorkItemRepository - Class in io.fabric8.partition.internal.repositories
 
ZkWorkItemRepository(CuratorFramework, String) - Constructor for class io.fabric8.partition.internal.repositories.ZkWorkItemRepository
 
ZkWorkItemRepositoryFactory - Class in io.fabric8.partition.internal.repositories
 
ZkWorkItemRepositoryFactory() - Constructor for class io.fabric8.partition.internal.repositories.ZkWorkItemRepositoryFactory
 
A B C E G H I L M N P R S T V W Z 

Copyright © 2017 Red Hat. All Rights Reserved.