Modifier and Type | Class and Description |
---|---|
static class |
GoalViolations.GoalResult |
Constructor and Description |
---|
GoalViolations(KafkaCruiseControl kafkaCruiseControl,
SelfHealingStateTracker selfHealingStateTracker,
boolean allowCapacityEstimation,
boolean excludeRecentlyRemovedBrokers,
GoalsConfig goalConfig) |
Modifier and Type | Method and Description |
---|---|
String |
anomalyId() |
boolean |
canViolationBeFixed() |
AnomalyFixStatus |
fix()
Fix the anomaly with the system.
|
GoalsConfig |
goalsConfig()
Returns the goals that will be used to fix this anomaly.
|
boolean |
hasUnfixableGoals() |
AnomalyNotificationResult |
notifyAnomalyInProgress(AnomalyNotifier anomalyNotifier) |
String |
toString() |
AnomalyFixStatus |
tryFix() |
Map<Boolean,List<GoalViolations.GoalResult>> |
violatedGoalsByFixability()
Get all the goal violations.
|
public GoalViolations(KafkaCruiseControl kafkaCruiseControl, SelfHealingStateTracker selfHealingStateTracker, boolean allowCapacityEstimation, boolean excludeRecentlyRemovedBrokers, GoalsConfig goalConfig)
public GoalsConfig goalsConfig()
Anomaly
public Map<Boolean,List<GoalViolations.GoalResult>> violatedGoalsByFixability()
public String anomalyId()
public AnomalyNotificationResult notifyAnomalyInProgress(AnomalyNotifier anomalyNotifier)
public boolean canViolationBeFixed()
public boolean hasUnfixableGoals()
public AnomalyFixStatus fix() throws KafkaCruiseControlException
Anomaly
AnomalyFixStatus
KafkaCruiseControlException
public AnomalyFixStatus tryFix() throws KafkaCruiseControlException
KafkaCruiseControlException
public String toString()