public class BrokerStats extends Object
Constructor and Description |
---|
BrokerStats(KafkaCruiseControlConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
addSingleBrokerStats(String host,
int id,
Broker.Strategy strategy,
double diskUtil,
double cpuUtil,
double leaderBytesInRate,
double followerBytesInRate,
double bytesOutRate,
double potentialBytesOutRate,
int numReplicas,
int numLeaders,
boolean isEstimated,
double capacity,
Map<String,DiskStats> diskStatsByLogdir) |
Map<String,Object> |
getJsonStructure()
Return an object that can be further be used to encode into JSON
|
boolean |
isBrokerStatsEstimated() |
List<SingleBrokerStats> |
stats() |
String |
toString() |
public BrokerStats(KafkaCruiseControlConfig config)
public void addSingleBrokerStats(String host, int id, Broker.Strategy strategy, double diskUtil, double cpuUtil, double leaderBytesInRate, double followerBytesInRate, double bytesOutRate, double potentialBytesOutRate, int numReplicas, int numLeaders, boolean isEstimated, double capacity, Map<String,DiskStats> diskStatsByLogdir)
public boolean isBrokerStatsEstimated()
public Map<String,Object> getJsonStructure()
public List<SingleBrokerStats> stats()