public class BrokerRemovalPhaseBuilder
extends java.lang.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<java.lang.Void> executorReservationPhase,
BrokerRemovalPhase<java.lang.Void> initialPlanComputationPhase,
BrokerRemovalPhase<java.lang.Void> brokerShutdownPhase,
BrokerRemovalPhase<java.lang.Void> planComputationPhase,
BrokerRemovalPhase<java.util.concurrent.Future<?>> planExecutionPhase)
Returns all the phases chained together in a #
CompletableFuture object |
public BrokerRemovalPhaseBuilder()
BrokerRemovalStateMachine
public BrokerRemovalFuture composeRemoval(BrokerRemovalOptions removalOpts, BrokerRemovalCallback progressCallback, BrokerRemovalPhase<java.lang.Void> executorReservationPhase, BrokerRemovalPhase<java.lang.Void> initialPlanComputationPhase, BrokerRemovalPhase<java.lang.Void> brokerShutdownPhase, BrokerRemovalPhase<java.lang.Void> planComputationPhase, BrokerRemovalPhase<java.util.concurrent.Future<?>> planExecutionPhase)
CompletableFuture
object