JavaScript is disabled on your browser.
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2011–2014
Red Hat
. All rights reserved.