Constructor and Description |
---|
AggregatingEmitter(Set<io.confluent.telemetry.config.v2.AggregationRule> aggregationRule,
Emitter delegate) |
Modifier and Type | Method and Description |
---|---|
boolean |
emitMetric(SinglePointMetric metric)
Emits a metric to all configured
Exporter
objects. |
void |
flushAggregates() |
boolean |
shouldEmitMetric(Keyed key)
Tests whether this metric object could actually be emitted based on its key.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
maybeEmitMetric
public boolean shouldEmitMetric(Keyed key)
Emitter
shouldEmitMetric
in interface Emitter
key
- metric key to test againstpublic boolean emitMetric(SinglePointMetric metric)
Emitter
Exporter
objects.emitMetric
in interface Emitter
metric
- to emitpublic void flushAggregates()