public class MetricsCollectorTask extends Object
Constructor and Description |
---|
MetricsCollectorTask(Collection<MetricsCollector> collectors,
long collectIntervalMs,
Emitter emitter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
setAggregationRules(Set<io.confluent.telemetry.config.v2.AggregationRule> aggregationRules) |
void |
start() |
public MetricsCollectorTask(Collection<MetricsCollector> collectors, long collectIntervalMs, Emitter emitter)
public void setAggregationRules(Set<io.confluent.telemetry.config.v2.AggregationRule> aggregationRules)
public void start()
public void close()