public interface DataBalanceEngine
Modifier and Type | Method and Description |
---|---|
void |
addBrokers(java.util.Set<java.lang.Integer> brokersToAdd,
java.lang.String uid) |
boolean |
cancelBrokerRemoval(int brokerId)
Cancel the on-going broker removal operation for the given #
brokerId |
DataBalanceEngineContext |
getDataBalanceEngineContext()
Return
DataBalanceEngineContext associated with this DataBalanceEngine. |
boolean |
isActive() |
void |
onActivation(EngineInitializationContext initializationContext)
To be called when this DataBalanceEngine should be activated and start running.
|
void |
onDeactivation()
To be called when this DataBalanceEngine should stop execution.
|
void |
removeBroker(int brokerToRemove,
java.util.Optional<java.lang.Long> brokerToRemoveEpoch,
java.lang.String uid)
Schedules the removal of a broker
|
void |
setAutoHealMode(boolean shouldAutoHeal)
Enable or disable auto-healing (automatic execution of rebalance plans) when an imbalanced
cluster is detected and broker membership doesn't change.
|
void |
shutdown()
To be called when the object is going away.
|
void |
updateThrottle(java.lang.Long newThrottle)
Update the replication throttles to be used during proposal execution.
|
DataBalanceEngineContext getDataBalanceEngineContext()
DataBalanceEngineContext
associated with this DataBalanceEngine.void onActivation(EngineInitializationContext initializationContext)
void onDeactivation()
void shutdown() throws java.lang.InterruptedException
java.lang.InterruptedException
void updateThrottle(java.lang.Long newThrottle)
newThrottle
- -- new throttle in bytes/second.void setAutoHealMode(boolean shouldAutoHeal)
shouldAutoHeal
- -- if auto-healing should be enabled when goal violations are detected.boolean isActive()
void removeBroker(int brokerToRemove, java.util.Optional<java.lang.Long> brokerToRemoveEpoch, java.lang.String uid)
void addBrokers(java.util.Set<java.lang.Integer> brokersToAdd, java.lang.String uid)
boolean cancelBrokerRemoval(int brokerId)
brokerId