@ThreadSafe public class SelfHealingStateTracker extends Object
Constructor and Description |
---|
SelfHealingStateTracker(KafkaCruiseControlConfig config)
Creates a
SelfHealingStateTracker with the provided KafkaCruiseControlConfig . |
Modifier and Type | Method and Description |
---|---|
Collection<String> |
allInProgressGoals()
Retrieves all in-progress self-healing goals.
|
boolean |
isInProgress(String goalName)
Determine if a Goal is considered IN_PROGRESS.
|
void |
markGoalAsSuccessful(String goalName)
Removes the in-progress status for the provided goal.
|
void |
recordIteration(String goalName)
Records an iteration for the provided goal.
|
public SelfHealingStateTracker(KafkaCruiseControlConfig config)
SelfHealingStateTracker
with the provided KafkaCruiseControlConfig
.public Collection<String> allInProgressGoals()
Collection
of goal names that are considered in-progress.public boolean isInProgress(String goalName)
goalName
- name to the goal, usually the class simple namepublic void recordIteration(String goalName)
public void markGoalAsSuccessful(String goalName)