public class SLOMetricsCollector extends Object implements MetricsCollector
collect(io.confluent.telemetry.emitter.Emitter)
.
When collect(io.confluent.telemetry.emitter.Emitter)
is called, the over-sampled metrics are aggregated to produce one metric per minute.
The behavior provided by this collector is needed for the calculation of Confluent's internal SLO. Our SLO is defined with a granularity of one minute, so we must capture the relevant metrics at precisely that granularity.
LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE
Constructor and Description |
---|
SLOMetricsCollector(com.yammer.metrics.core.MetricsRegistry metricsRegistry,
MetricNamingStrategy<com.yammer.metrics.core.MetricName> metricNamingStrategy) |
public SLOMetricsCollector(com.yammer.metrics.core.MetricsRegistry metricsRegistry, MetricNamingStrategy<com.yammer.metrics.core.MetricName> metricNamingStrategy)
public void start()
start
in interface MetricsCollector
public void stop()
stop
in interface MetricsCollector
public void collect(Emitter emitter)
collect
in interface MetricsCollector