public class BrokerStats
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.util.List<SingleBrokerStats> |
_brokerStats |
protected int |
_hostFieldLength |
protected java.util.SortedMap<java.lang.String,com.linkedin.kafka.cruisecontrol.servlet.response.stats.BasicStats> |
_hostStats |
protected boolean |
_isBrokerStatsEstimated |
protected int |
_logdirFieldLength |
protected static java.lang.String |
BROKERS |
protected static java.lang.String |
HOST |
protected static java.lang.String |
HOSTS |
Constructor and Description |
---|
BrokerStats(KafkaCruiseControlConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
addSingleBrokerStats(java.lang.String host,
int id,
Broker.State state,
double diskUtil,
double cpuUtil,
double leaderBytesInRate,
double followerBytesInRate,
double bytesOutRate,
double potentialBytesOutRate,
int numReplicas,
int numLeaders,
boolean isEstimated,
double capacity,
java.util.Map<java.lang.String,DiskStats> diskStatsByLogdir) |
java.util.Map<java.lang.String,java.lang.Object> |
getJsonStructure()
Return an object that can be further be used to encode into JSON
|
boolean |
isBrokerStatsEstimated() |
java.util.List<SingleBrokerStats> |
stats() |
java.lang.String |
toString() |
protected static final java.lang.String HOST
protected static final java.lang.String HOSTS
protected static final java.lang.String BROKERS
protected final java.util.List<SingleBrokerStats> _brokerStats
protected final java.util.SortedMap<java.lang.String,com.linkedin.kafka.cruisecontrol.servlet.response.stats.BasicStats> _hostStats
protected int _hostFieldLength
protected int _logdirFieldLength
protected boolean _isBrokerStatsEstimated
public BrokerStats(KafkaCruiseControlConfig config)
public void addSingleBrokerStats(java.lang.String host, int id, Broker.State state, double diskUtil, double cpuUtil, double leaderBytesInRate, double followerBytesInRate, double bytesOutRate, double potentialBytesOutRate, int numReplicas, int numLeaders, boolean isEstimated, double capacity, java.util.Map<java.lang.String,DiskStats> diskStatsByLogdir)
public boolean isBrokerStatsEstimated()
public java.util.Map<java.lang.String,java.lang.Object> getJsonStructure()
public java.lang.String toString()
toString
in class java.lang.Object
public java.util.List<SingleBrokerStats> stats()