io.confluent.telemetry.exporter

Class AbstractExporter

java.lang.Object

io.confluent.telemetry.exporter.AbstractExporter

All Implemented Interfaces:

Exporter, AutoCloseable

Direct Known Subclasses:

HttpExporter, KafkaExporter

public abstract class AbstractExporter
extends Object
implements Exporter

Constructor Summary

Constructors

Constructor and Description
AbstractExporter()
AbstractExporter(Predicate<Keyed> metricsPredicate)

Method Summary

Modifier and Type	Method and Description
abstract void	doEmit(SerializedMetric metric)
boolean	emit(SerializedMetric metric)
Predicate<Keyed>	getPredicate()
void	reconfigurePredicate(Predicate<Keyed> metricsPredicate) Reconfigure the metrics predicate.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.telemetry.exporter.Exporter

setMetricsRegistry

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

AbstractExporter

public AbstractExporter()

AbstractExporter

public AbstractExporter(Predicate<Keyed> metricsPredicate)

Method Detail

getPredicate

public Predicate<Keyed> getPredicate()

Specified by:

getPredicate in interface Exporter

reconfigurePredicate

public void reconfigurePredicate(Predicate<Keyed> metricsPredicate)

Reconfigure the metrics predicate.

Specified by:

reconfigurePredicate in interface Exporter

Parameters:

metricsPredicate - predicate to switch to

doEmit

public abstract void doEmit(SerializedMetric metric)

emit

public final boolean emit(SerializedMetric metric)

Specified by:

emit in interface Exporter