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

Method Summary

Modifier and Type	Method and Description
abstract void	doEmit(ExportableMetric metric)
boolean	emit(ExportableMetric exportableMetric)
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)

AbstractExporter

public AbstractExporter(Context context,
                        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(ExportableMetric metric)

emit

public final boolean emit(ExportableMetric exportableMetric)

Specified by:

emit in interface Exporter