public class Host extends Object implements Serializable, ResourceStats
Modifier and Type | Method and Description |
---|---|
Broker |
broker(int brokerId) |
Collection<Broker> |
brokers() |
Capacity |
capacity() |
Map<String,Object> |
getJsonStructure() |
boolean |
isAlive() |
boolean |
isEligibleDestination() |
Load |
load()
The load on the rack.
|
String |
name()
The name of the host
|
int |
numTopicReplicas(String topic)
Get the number of replicas with the given topic name in this host.
|
Rack |
rack() |
Set<Replica> |
replicas() |
Set<String> |
topics() |
String |
toString() |
Utilization |
utilization() |
void |
writeTo(OutputStream out) |
public Rack rack()
public Broker broker(int brokerId)
public Collection<Broker> brokers()
public int numTopicReplicas(String topic)
topic
- Name of the topic for which the number of replicas in this rack will be counted.public Set<String> topics()
public Capacity capacity()
capacity
in interface ResourceStats
public boolean isEligibleDestination()
public boolean isAlive()
public Load load()
load
in interface ResourceStats
public Utilization utilization()
utilization
in interface ResourceStats
public String name()
public void writeTo(OutputStream out) throws IOException
IOException