Interface | Description |
---|---|
BalanceOpExecutionCompletionCallback |
A callback routine to be invoked when a CruiseControl ProposalExecution (rebalance plan) completes execution,
whether successfully or otherwise.
|
BalancerOperationCallback<S extends BalancerOperationState,E extends BalancerOperationEvent> |
This class helps track the progress of a single balancer operation.
|
BalancerOperationEvent |
An interface to denote an event that is part of an SBK operation (add broker, remove broker).
|
BalancerOperationProgressListener<S extends BalancerOperationState> |
A functional interface for a listener for the progress of a balancer operation
|
BalancerOperationState |
An interface to denote the state of an SBK operation (add broker, remove broker).
|
BalancerOperationTerminationListener<S extends BalancerOperationState> |
A functional interface for a listener that gets called when a balancer operation reaches a terminal state
|
Class | Description |
---|---|
BrokerAdditionStateMachine |
This is an ASCII representation of the state machine diagram in
https://confluentinc.atlassian.net/wiki/spaces/CNKAF/pages/1549730493/SBK+Add+Broker+API+-+Kafka+1-Pager
+-----------------------------+
| REASSIGNMENT_CANCELED |
| <-------------------------+
| CANCELED | |
+-----------------------------+ |
|
+-----------------------------+ |
| PLAN_COMPUTATION_CANCELED | |
| <-----------+ |
| CANCELED | | |
+-----------------------------+ | |
| |
| BROKER_REMOVAL_REQUEST_OVERRIDES | BROKER_REMOVAL_REQUEST_OVERRIDES
| |
| |
+-------------+ +---------------+-------------+ SUCCESS +--------------+--------------+ SUCCESS +-----------------------------+
| | | PLAN_COMPUTATION | | REASSIGNMENT | | COMPLETED |
| START +--------->+ +------------------> +-----------------> |
| | | PENDING | | IN_PROGRESS | | COMPLETED |
+-------------+ +---------------+-------------+ +--------------+--------------+ +-----------------------------+
| |
| UNEXPECTED_ERROR | UNEXPECTED_ERROR
| |
+-----------------------------+ | |
| PLAN_COMPUTATION_FAILED | | |
| <-----------+ |
| ERROR | |
+-----------------------------+ |
+-----------------------------+ |
| REASSIGNMENT_FAILED | |
| <------------------------+
| ERROR |
+-----------------------------+
|
BrokerAdditionStateManager |
This class encapsulates the nitty-gritty logic of tracking and advancing the broker addition state machine for a single broker's addition.
|
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=SUCCESS |
| BSS=PENDING | | BSS=PENDING | | BSS=COMPLETED | | BSS=COMPLETED | | BSS=COMPLETED |
+-------------------+-+--------------+ +-----------+-+-------------+ +-------------+-----+--------+ +--------------------+---+-+ +--------------------------+
| | | | | | |
ERROR | ERROR | | ERROR | | BROKER ERROR | | BROKER
| | | | | RESTART | | RESTART
| | | | | | |
+---------------------------------+ | +------------------------+ | | +-------------------------+ | | +-----------------------+ | |
| INITIAL_PLAN_COMPUTATION_FAILED | | | BROKER_SHUTDOWN_FAILED | | | | PLAN_COMPUTATION_FAILED | | | | PLAN_EXECUTION_FAILED | | |
| | | | | | | | | | | | | | |
| PAR=ERROR +<-----+ | PAR=CANCELED +<----------+ | | PAR=ERROR <-----+ | | PAR=ERROR +<---+ |
| BSS=CANCELED | | BSS=FAILED | | | BSS=COMPLETED | | | BSS=COMPLETED | |
+---------------------------------+ +------------------------+ | +-------------------------+ | +-----------------------+ |
| | |
| | |
+------------------------+ | +-------------------------+ | +------------------------+ |
|BROKER_SHUTDOWN_CANCELED| | |PLAN_COMPUTATION_CANCELED| | | PLAN_EXECUTION_CANCELED| |
| | | | | | | | |
| PAR=CANCELED +<------------+ | PAR=CANCELED +<----------+ | PAR=CANCELED +<------+
| BSS=CANCELED | | BSS=COMPLETED | | BSS=COMPLETED |
+------------------------+ +-------------------------+ +------------------------+
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 #
BalancerOperationProgressListener that
persists all state updates for a single broker removal operation to disk |
StateMachine<S extends BalancerOperationState,E extends BalancerOperationEvent> |
An abstract state machine that helps facilitate the transition between different states for a given SBK operation (broker removal, broker addition)
|
StateMachineInitializer<S extends BalancerOperationState> |
A stateless class that defines the initialization rules of any given #
BalancerOperationState for a #StateMachine . |
StateMachineInitializer.Builder<S extends BalancerOperationState> |
A Builder for constructing a #
StateMachineInitializer with a set of #StateMachineInitializer.InitializationRule s added through the #Builder#with(InitializationRule) method. |
StateMachineInitializer.InitializationRule<S extends BalancerOperationState> |
A rule denoting what state a given state should be initialized to.
|
Enum | Description |
---|---|
BrokerAdditionStateMachine.BrokerAdditionEvent |
An #
BalancerOperationEvent that can take place during the broker addition operation |
BrokerAdditionStateMachine.BrokerAdditionState |
All the possible states of the broker addition operation
|
BrokerRemovalCancellationMode |
An enumeration of the possible modes of cancelling a broker removal operation.
|
BrokerRemovalStateMachine.BrokerRemovalEvent | |
BrokerRemovalStateMachine.BrokerRemovalState |
All the possible states of the broker removal operation
|
StateMachineInitializer.InitializationMode |
A setting to configure what state to return when no state initialization is registered for a given state
|