public class SingleBrokerStats extends Object
Modifier and Type | Field and Description |
---|---|
protected com.linkedin.kafka.cruisecontrol.monitor.BasicStats |
basicStats |
protected static String |
BROKER |
protected static String |
BROKER_STATE |
protected static String |
DISK_STATE |
protected Map<String,DiskStats> |
diskStatsByLogdir |
protected String |
host |
protected static String |
HOST |
protected int |
id |
protected boolean |
isEstimated |
protected Broker.State |
state |
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()