public class PersistRemoveApiStateListener extends java.lang.Object implements BalancerOperationProgressListener<BrokerRemovalStateMachine.BrokerRemovalState>
BalancerOperationProgressListener
that
persists all state updates for a single broker removal operation to diskConstructor and Description |
---|
PersistRemoveApiStateListener(ApiStatePersistenceStore persistenceStore) |
Modifier and Type | Method and Description |
---|---|
void |
onProgressChanged(int brokerId,
BrokerRemovalStateMachine.BrokerRemovalState state,
java.lang.Exception e)
Called whenever the state of the balancer operation operation changes.
|
public PersistRemoveApiStateListener(ApiStatePersistenceStore persistenceStore)
public void onProgressChanged(int brokerId, BrokerRemovalStateMachine.BrokerRemovalState state, java.lang.Exception e)
BalancerOperationProgressListener
onProgressChanged
in interface BalancerOperationProgressListener<BrokerRemovalStateMachine.BrokerRemovalState>
brokerId
- Id of the broker this operation is working on.state
- the new state the operation is ine
- - nullable, an exception that occurred during the balancer operation