Class TelemetryEmitter

java.lang.Object

io.confluent.telemetry.emitter.TelemetryEmitter

All Implemented Interfaces:

Emitter

public class TelemetryEmitter
extends Object
implements Emitter

Must construct after 1. TelemetryReporter.configure(java.util.Map<java.lang.String, ?>) [must be called first invalid input: '&' only once] 2. TelemetryReporter.contextChange(org.apache.kafka.common.metrics.MetricsContext) [must be called second]

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
TelemetryEmitter(Context context, Supplier<Collection<Exporter>> exportersSupplier, org.apache.kafka.common.metrics.Metrics metrics)

Method Summary

Modifier and Type	Method	Description
boolean	emitMetric(ContextExportableMetric exportableMetric)
boolean	emitMetric(SinglePointMetric metric)	Emits a metric to all configured Exporter objects.
void	reconfigurePredicate(Predicate<? super Keyed> metricsPredicate)
boolean	shouldEmitMetric(Keyed key)	Tests whether this metric object could actually be emitted based on its key.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.telemetry.emitter.Emitter

maybeEmitMetric

Field Details

log

public static final org.slf4j.Logger log

Constructor Details

TelemetryEmitter

public TelemetryEmitter(Context context,
 Supplier<Collection<Exporter>> exportersSupplier,
 org.apache.kafka.common.metrics.Metrics metrics)

Method Details

shouldEmitMetric

public boolean shouldEmitMetric(Keyed key)

Description copied from interface: Emitter

Tests whether this metric object could actually be emitted based on its key. This is useful when materializing the metric object is an expensive operation.

Specified by:

shouldEmitMetric in interface Emitter

Parameters:

key - metric key to test against

Returns:

true if it is possible for this object to get emitted, false otherwise

emitMetric

public boolean emitMetric(SinglePointMetric metric)

Description copied from interface: Emitter

Emits a metric to all configured Exporter objects.

Specified by:

emitMetric in interface Emitter

Parameters:

metric - to emit

Returns:

true if exported by at least one exporter, false otherwise

emitMetric

public boolean emitMetric(ContextExportableMetric exportableMetric)

reconfigurePredicate

public void reconfigurePredicate(Predicate<? super Keyed> metricsPredicate)