public class SingleBrokerStats extends Object
Modifier and Type | Field and Description |
---|---|
protected com.linkedin.kafka.cruisecontrol.monitor.BasicStats |
_basicStats |
protected Map<String,DiskStats> |
_diskStatsByLogdir |
protected String |
_host |
protected int |
_id |
protected boolean |
_isEstimated |
protected Broker.State |
_state |
protected static String |
BROKER |
protected static String |
BROKER_STATE |
protected static String |
DISK_STATE |
protected static String |
HOST |
Modifier and Type | Method and Description |
---|---|
double |
bytesIn() |
double |
bytesOut() |
Map<String,DiskStats> |
diskStatsByLogdir()
Get per-logdir disk statistics of the broker.
|
Map<String,Object> |
getJSONStructure() |
String |
host() |
int |
id() |
boolean |
isEstimated() |
Broker.State |
state() |
protected static final String HOST
protected static final String BROKER
protected static final String BROKER_STATE
protected static final String DISK_STATE
protected final String _host
protected final int _id
protected final Broker.State _state
protected final com.linkedin.kafka.cruisecontrol.monitor.BasicStats _basicStats
protected final boolean _isEstimated
public String host()
public Broker.State state()
public int id()
public Map<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()