public interface BrokerCapacityConfigResolver extends CruiseControlConfigurable, java.lang.AutoCloseable
Modifier and Type | Method and Description |
---|---|
BrokerCapacityInfo |
capacityForBroker(java.lang.String rack,
java.lang.String host,
int brokerId)
Get the capacity of a broker based on rack, host and broker id.
|
default void |
updateDiskCapacityForBroker(java.lang.String rack,
java.lang.String host,
int brokerId,
double diskCapacity)
Update the disk capacity for a broker based on rack, host and broker id.
|
configure
BrokerCapacityInfo capacityForBroker(java.lang.String rack, java.lang.String host, int brokerId)
Resource
. The units for each resource are:
DISK - MegaBytes
CPU - Percentage (0 - 100)
Network Inbound - KB/s
Network Outbounds - KB/s
The response also contains the number of CPU cores and may contain disk capacities by logDirs (i.e. for JBOD).
May estimate the capacity of a broker, if it is not directly available.rack
- The rack of the brokerhost
- The host of the brokerbrokerId
- the id of the brokerdefault void updateDiskCapacityForBroker(java.lang.String rack, java.lang.String host, int brokerId, double diskCapacity)