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(Context context, Predicate<Keyed> metricsPredicate, String name)

Method Summary

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

Methods inherited from class java.lang.Object

equals, 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(Context context,
                        Predicate<Keyed> metricsPredicate,
                        String name)

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(ExportableMetric metric)

emit

public final boolean emit(ExportableMetric exportableMetric)

Specified by:

emit in interface Exporter

getName

public String getName()

Specified by:

getName in interface Exporter