public class BrokerRemovalPhaseBuilder extends Object
BrokerRemovalPhaseExecutor
s
that execute and handle failures for each phase.Constructor and Description |
---|
BrokerRemovalPhaseBuilder()
Build the necessary phase executors with the appropriate removal events on success/failure.
|
Modifier and Type | Method and Description |
---|---|
BrokerRemovalFuture |
composeRemoval(BrokerRemovalOptions removalOpts,
BrokerRemovalCallback progressCallback,
BrokerRemovalPhase<Void> executorReservationPhase,
BrokerRemovalPhase<Void> initialPlanComputationPhase,
BrokerRemovalPhase<Void> brokerShutdownPhase,
BrokerRemovalPhase<Void> planComputationPhase,
BrokerRemovalPhase<Future<?>> planExecutionPhase)
Returns all the phases chained together in a #
CompletableFuture object |
public BrokerRemovalPhaseBuilder()
BrokerRemovalStateMachine
public BrokerRemovalFuture composeRemoval(BrokerRemovalOptions removalOpts, BrokerRemovalCallback progressCallback, BrokerRemovalPhase<Void> executorReservationPhase, BrokerRemovalPhase<Void> initialPlanComputationPhase, BrokerRemovalPhase<Void> brokerShutdownPhase, BrokerRemovalPhase<Void> planComputationPhase, BrokerRemovalPhase<Future<?>> planExecutionPhase)
CompletableFuture
object