Interface | Description |
---|---|
BalanceOpExecutionCompletionCallback |
A callback routine to be invoked when a CruiseControl ProposalExecution (rebalance plan) completes execution,
whether successfully or otherwise.
|
BrokerRemovalProgressListener |
A listener for the progress of a broker removal operation
|
BrokerRemovalTerminationListener |
A listener that gets called when the broker removal operation reaches a terminal state
|
Class | Description |
---|---|
BrokerRemovalStateMachine |
This is an ASCII representation of the state machine diagram in
https://confluentinc.atlassian.net/wiki/spaces/CNKAF/pages/1219931556/SBK+Remove+Broker+Mega-Pager
SUCCESS SUCCESS SUCCESS SUCCESS
+-----------------------------------------------+ +--------------------------------+ +---------------------------+ +----------------------------------------+
| | | | | | | |
| v | v | v | v
+----------------+-------------------+ +--------------+-+----------+ +-------------+--+-----------+ +---------+--+-------------+ +-----------+--------------+
| INITIAL_PLAN_COMPUTATION_INITIATED | | BROKER_SHUTDOWN_INITIATED | | PLAN_COMPUTATION_INITIATED | | PLAN_EXECUTION_INITIATED | | PLAN_EXECUTION_SUCCEEDED |
| | | | | | | | | |
| PAR=PENDING | | PAR=IN_PROGRESS | | PAR=IN_PROGRESS | | PAR=IN_PROGRESS | | PAR=COMPLETE |
| BSS=PENDING | | BSS=PENDING | | BSS=COMPLETE | | BSS=COMPLETE | | BSS=COMPLETE |
+-------------------+-+--------------+ +-----------+-+-------------+ +-------------+-----+--------+ +--------------------+---+-+ +--------------------------+
| | | | | | |
ERROR | ERROR | | ERROR | | BROKER ERROR | | BROKER
| | | | | RESTART | | RESTART
| | | | | | |
+---------------------------------+ | +------------------------+ | | +-------------------------+ | | +-----------------------+ | |
| INITIAL_PLAN_COMPUTATION_FAILED | | | BROKER_SHUTDOWN_FAILED | | | | PLAN_COMPUTATION_FAILED | | | | PLAN_EXECUTION_FAILED | | |
| | | | | | | | | | | | | | |
| PAR=FAILED +<-----+ | PAR=CANCELED +<----------+ | | PAR=FAILED <-----+ | | PAR=FAILED +<---+ |
| BSS=CANCELED | | BSS=FAILED | | | BSS=COMPLETE | | | BSS=COMPLETE | |
+---------------------------------+ +------------------------+ | +-------------------------+ | +-----------------------+ |
| | |
| | |
+------------------------+ | +-------------------------+ | +------------------------+ |
|BROKER_SHUTDOWN_CANCELED| | |PLAN_COMPUTATION_CANCELED| | | PLAN_EXECUTION_CANCELED| |
| | | | | | | | |
| PAR=CANCELED +<------------+ | PAR=CANCELED +<----------+ | PAR=CANCELED +<------+
| BSS=CANCELED | | BSS=COMPLETE | | BSS=COMPLETE |
+------------------------+ +-------------------------+ +------------------------+
Created via https://asciiflow.com/
|
BrokerRemovalStateTracker |
This class encapsulates the nitty-gritty logic of tracking and advancing the broker removal state machine.
|
PersistRemoveApiStateListener |
An implementation of #
BrokerRemovalProgressListener that
persists all state updates for a single broker removal operation to disk |
Enum | Description |
---|---|
BrokerRemovalCancellationMode |
An enumeration of the possible modes of cancelling a broker removal operation.
|
BrokerRemovalStateMachine.BrokerRemovalState |
All the valid removal states with links to valid state transitions
|