public class CruiseControlState
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
CruiseControlState.SubState |
Modifier and Type | Field and Description |
---|---|
protected AnalyzerState |
_analyzerState |
protected AnomalyDetectorState |
_anomalyDetectorState |
protected ExecutorState |
_executorState |
protected LoadMonitorState |
_monitorState |
protected static java.lang.String |
ANALYZER_STATE |
protected static java.lang.String |
ANOMALY_DETECTOR_STATE |
protected static java.lang.String |
EXECUTOR_STATE |
protected static java.lang.String |
INTER_BROKER_PARTITION_MOVEMENTS |
protected static java.lang.String |
INTRA_BROKER_PARTITION_MOVEMENTS |
protected static java.lang.String |
LEADERSHIP_MOVEMENTS |
protected static java.lang.String |
MONITOR_STATE |
Constructor and Description |
---|
CruiseControlState(ExecutorState executionState,
LoadMonitorState monitorState,
AnalyzerState analyzerState,
AnomalyDetectorState anomalyDetectorState,
KafkaCruiseControlConfig config) |
Modifier and Type | Method and Description |
---|---|
AnalyzerState |
analyzerState() |
AnomalyDetectorState |
anomalyDetectorState() |
protected void |
discardIrrelevantAndCacheRelevant() |
ExecutorState |
executorState() |
java.util.Map<java.lang.String,java.lang.Object> |
getJsonStructure(boolean verbose) |
protected java.lang.String |
getPlaintext() |
LoadMonitorState |
monitorState() |
protected void |
writeSuperVerbose(java.lang.StringBuilder sb) |
protected void |
writeVerboseAnalyzerState(java.lang.StringBuilder sb) |
protected void |
writeVerboseExecutorState(java.lang.StringBuilder sb) |
protected void |
writeVerboseMonitorState(java.lang.StringBuilder sb) |
protected static final java.lang.String INTER_BROKER_PARTITION_MOVEMENTS
protected static final java.lang.String INTRA_BROKER_PARTITION_MOVEMENTS
protected static final java.lang.String LEADERSHIP_MOVEMENTS
protected static final java.lang.String MONITOR_STATE
protected static final java.lang.String EXECUTOR_STATE
protected static final java.lang.String ANALYZER_STATE
protected static final java.lang.String ANOMALY_DETECTOR_STATE
protected ExecutorState _executorState
protected LoadMonitorState _monitorState
protected AnalyzerState _analyzerState
protected AnomalyDetectorState _anomalyDetectorState
public CruiseControlState(ExecutorState executionState, LoadMonitorState monitorState, AnalyzerState analyzerState, AnomalyDetectorState anomalyDetectorState, KafkaCruiseControlConfig config)
public ExecutorState executorState()
public LoadMonitorState monitorState()
public AnalyzerState analyzerState()
public AnomalyDetectorState anomalyDetectorState()
public java.util.Map<java.lang.String,java.lang.Object> getJsonStructure(boolean verbose)
protected void writeVerboseMonitorState(java.lang.StringBuilder sb)
protected void writeVerboseAnalyzerState(java.lang.StringBuilder sb)
protected void writeVerboseExecutorState(java.lang.StringBuilder sb)
protected void writeSuperVerbose(java.lang.StringBuilder sb)
protected java.lang.String getPlaintext()
protected void discardIrrelevantAndCacheRelevant()