public interface DataBalanceEngineContext
Modifier and Type | Method and Description |
---|---|
java.util.Set<java.lang.Integer> |
brokersBeingAdded()
Returns a {#@link Set} of broker ids representing the brokers being added to the cluster
as part of a #
MultiBrokerAdditionOperation |
java.util.Map<java.lang.Integer,BrokerAdditionStateManager> |
getBrokerAdditionsStateManagers()
Return the #
BrokerAdditionStateManager s for the active broker addition operations |
java.util.Map<java.lang.Integer,BrokerRemovalStateTracker> |
getBrokerRemovalsStateTrackers()
Return the #
BrokerRemovalStateTracker for the active broker removal operations |
ApiStatePersistenceStore |
getPersistenceStore()
Return persistence store associated with this DataBalanceEngineContext.
|
void |
putBrokerStateManager(BrokerAdditionStateManager stateManager) |
ApiStatePersistenceStore getPersistenceStore()
java.util.Map<java.lang.Integer,BrokerRemovalStateTracker> getBrokerRemovalsStateTrackers()
BrokerRemovalStateTracker
for the active broker removal operationsjava.util.Map<java.lang.Integer,BrokerAdditionStateManager> getBrokerAdditionsStateManagers()
BrokerAdditionStateManager
s for the active broker addition operationsvoid putBrokerStateManager(BrokerAdditionStateManager stateManager)
java.util.Set<java.lang.Integer> brokersBeingAdded()
MultiBrokerAdditionOperation