Package 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	Description
AbstractExporter(Predicate<Keyed> metricsPredicate, String name)

Method Summary

Modifier and Type	Method	Description
abstract void	doEmit(ContextExportableMetric metric)
final boolean	emit(ContextExportableMetric 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 java.lang.AutoCloseable

close

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

setMetricsRegistry

Constructor Details

AbstractExporter

public AbstractExporter(Predicate<Keyed> metricsPredicate,
 String name)

Method Details

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

emit

public final boolean emit(ContextExportableMetric exportableMetric)

Specified by:

emit in interface Exporter

getName

public String getName()

Specified by:

getName in interface Exporter