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).
|
BalancerOperationState |
An interface to denote the state of an SBK operation (add broker, remove broker).
|
EvenClusterLoadStateProgressListener<S extends BalancerOperationState> |
A functional interface for listener for the progress of the balancer operation - EvenClusterLoad
|
MultiBrokerBalancerOperationProgressListener<S extends BalancerOperationState> |
A functional interface for a listener for the progress of a balancer operation consisting of multiple brokers
(as opposed to the single-broker #
SingleBrokerBalancerOperationProgressListener |
MultiBrokerBalancerOperationTerminationListener<S extends BalancerOperationState> |
A functional interface for a listener that gets called when a balancer atomic operation
consisting of multiple brokers reaches a terminal state.
|
SingleBrokerBalancerOperationProgressListener<S extends BalancerOperationState> |
A functional interface for a listener for the progress of a balancer operation for a single broker
|
SingleBrokerBalancerOperationTerminationListener<S extends BalancerOperationState> |
A functional interface for a listener that gets called when a
balancer operation (operating on one broker) reaches a terminal state
|
Class | Description |
---|---|
BalancerStatusStateMachine | |
BalancerStatusTracker |
This class encapsulates the logic of tracking and advancing the status of the balancer
component of the cluster.
|
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_EXCLUSION_DETECTED
BROKER_EXCLUSION_DETECTED | 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.
|
BrokerRemovalCancellationProposal |
A class that encapsulates the circumstances of a BrokerRemoval cancellation proposal.
|
BrokerRemovalCancellationProposal.BrokerRemovalCancellationProposalBuilder |
Create a BrokerRemovalCancellationProposal.
|
BrokerRemovalExclusionCancellationData |
Cancellation data for a
BrokerRemovalCancellationProposal due to an exclusion request. |
BrokerRemovalStateMachine |
This is an ASCII representation of the state machine diagram in
https://confluentinc.atlassian.net/wiki/spaces/CNKAF/pages/2097985596/Broker+Removal+v2+Multiple+Broker+Removal+With+Debarment+-+Kafka+1-pager
An error (which usually moves to an XXX_FAILED state) is a failure that occurs while executing the actual removal (e.g.
|
BrokerRemovalStateTracker |
This class encapsulates the nitty-gritty logic of tracking and advancing the broker removal operation state machine.
|
EvenClusterLoadStateMachine |
State machine to capture current running state of "even cluster load" rebalance operation triggered
by
GoalViolationDetector . |
NoOpEvenClusterLoadStateManager |
This NoOpEvenClusterLoadStateManager class is used to handle requests when
self healing is disabled for the GOAL_VIOLATION anomaly type.
|
PersistEvenClusterLoadStateListener |
An implementation of #
EvenClusterLoadStateProgressListener that persists all state
updates for EvenClusterLoad operation to disk. |
PersistRemoveApiStateListener |
An implementation of #
MultiBrokerBalancerOperationProgressListener that
persists all state updates for a single broker removal operation to disk |
SelfHealingEvenClusterLoadStateManager |
This class manages both current rebalance state and one-before-current rebalance (called previous)
run of "any uneven load" goal violation.
|
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 |
---|---|
BalancerOperationState.BalancerOperationStateCharacteristics |
Characteristics of a state machine state, and the general ("Balancer Operation State")
types of states present in a BalancerOperationStateMachine..
|
BalancerStatusStateMachine.BalancerEvent |
An #
BalancerOperationEvent that can take place while balancer is starting up or running
There are two more events - SBK_MISCONFIGURATION_CORRECTED and SBK_ENABLED that are related
to dynamic configuration update, which will be handled separately in a follow up PR. |
BalancerStatusStateMachine.BalancerState |
All possible states of the balancer component.
|
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 |
Events feeding into the BrokerRemovalStateMachine.
|
BrokerRemovalStateMachine.BrokerRemovalState |
All the possible states of the broker removal operation
|
EvenClusterLoadStateMachine.EvenClusterLoadEvent | |
EvenClusterLoadStateMachine.EvenClusterLoadState |
All possible states of the even cluster load component.
|
StateMachineInitializer.InitializationMode |
A setting to configure what state to return when no state initialization is registered for a given state
|