Package io.confluent.telemetry

Class MetricsCollectorTask

java.lang.Object

io.confluent.telemetry.MetricsCollectorTask

public class MetricsCollectorTask
extends Object

Constructor Summary

Constructors

Constructor	Description
MetricsCollectorTask(Collection<MetricsCollector> collectors, long collectIntervalMs, Emitter emitter)

Method Summary

Modifier and Type	Method	Description
void	close()
void	setAggregationRules(Set<io.confluent.telemetry.config.v2.AggregationRule> aggregationRules)
void	start()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MetricsCollectorTask

public MetricsCollectorTask(Collection<MetricsCollector> collectors,
 long collectIntervalMs,
 Emitter emitter)

Method Details

setAggregationRules

public void setAggregationRules(Set<io.confluent.telemetry.config.v2.AggregationRule> aggregationRules)

start

public void start()

close

public void close()