public class SingleBrokerStats
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected com.linkedin.kafka.cruisecontrol.servlet.response.stats.BasicStats |
_basicStats |
protected java.util.Map<java.lang.String,DiskStats> |
_diskStatsByLogdir |
protected java.lang.String |
_host |
protected int |
_id |
protected boolean |
_isEstimated |
protected Broker.State |
_state |
protected static java.lang.String |
BROKER |
protected static java.lang.String |
BROKER_STATE |
protected static java.lang.String |
DISK_STATE |
protected static java.lang.String |
HOST |
Modifier and Type | Method and Description |
---|---|
double |
bytesIn() |
double |
bytesOut() |
java.util.Map<java.lang.String,DiskStats> |
diskStatsByLogdir()
Get per-logdir disk statistics of the broker.
|
java.util.Map<java.lang.String,java.lang.Object> |
getJSONStructure() |
java.lang.String |
host() |
int |
id() |
boolean |
isEstimated() |
Broker.State |
state() |
protected static final java.lang.String HOST
protected static final java.lang.String BROKER
protected static final java.lang.String BROKER_STATE
protected static final java.lang.String DISK_STATE
protected final java.lang.String _host
protected final int _id
protected final Broker.State _state
protected final com.linkedin.kafka.cruisecontrol.servlet.response.stats.BasicStats _basicStats
protected final boolean _isEstimated
protected final java.util.Map<java.lang.String,DiskStats> _diskStatsByLogdir
public java.lang.String host()
public Broker.State state()
public int id()
public java.util.Map<java.lang.String,DiskStats> diskStatsByLogdir()
ClusterModel
has been created with a request to populate
replica placement info, otherwise returns an empty map.public boolean isEstimated()
public double bytesIn()
public double bytesOut()
public java.util.Map<java.lang.String,java.lang.Object> getJSONStructure()