Package io.opentelemetry.sdk.metrics.internal.exemplar

Class FilteredExemplarReservoir<T extends ExemplarData>

java.lang.Object

io.opentelemetry.sdk.metrics.internal.exemplar.FilteredExemplarReservoir<T>

All Implemented Interfaces:

ExemplarReservoir<T>

class FilteredExemplarReservoir<T extends ExemplarData>
extends java.lang.Object
implements ExemplarReservoir<T>

A reservoir that has a pre-filter on measurements.

Field Summary

Fields

Modifier and Type	Field	Description
private ExemplarFilter	filter
private ExemplarReservoir<T>	reservoir

Constructor Summary

Constructors

Constructor	Description
FilteredExemplarReservoir(ExemplarFilter filter, ExemplarReservoir<T> reservoir)

Method Summary

Modifier and Type	Method	Description
java.util.List<T>	collectAndReset(Attributes pointAttributes)	Returns an immutable list of Exemplars for exporting from the current reservoir.
void	offerDoubleMeasurement(double value, Attributes attributes, Context context)	Offers a double measurement to be sampled.
void	offerLongMeasurement(long value, Attributes attributes, Context context)	Offers a long measurement to be sampled.

Methods inherited from class java.lang.Object

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

Field Detail

filter

private final ExemplarFilter filter

reservoir

private final ExemplarReservoir<T extends ExemplarData> reservoir

Constructor Detail

FilteredExemplarReservoir

FilteredExemplarReservoir(ExemplarFilter filter,
                          ExemplarReservoir<T> reservoir)

Method Detail

offerDoubleMeasurement

public void offerDoubleMeasurement(double value,
                                   Attributes attributes,
                                   Context context)

Description copied from interface: ExemplarReservoir

Offers a double measurement to be sampled.

Specified by:

offerDoubleMeasurement in interface ExemplarReservoir<T extends ExemplarData>

offerLongMeasurement

public void offerLongMeasurement(long value,
                                 Attributes attributes,
                                 Context context)

Description copied from interface: ExemplarReservoir

Offers a long measurement to be sampled.

Specified by:

offerLongMeasurement in interface ExemplarReservoir<T extends ExemplarData>

collectAndReset

public java.util.List<T> collectAndReset(Attributes pointAttributes)

Description copied from interface: ExemplarReservoir

Returns an immutable list of Exemplars for exporting from the current reservoir.

Additionally, clears the reservoir for the next sampling period.

Specified by:

collectAndReset in interface ExemplarReservoir<T extends ExemplarData>

Parameters:

pointAttributes - the Attributes associated with the metric point. ExemplarDatas should filter these out of their final data state.

Returns:

An (immutable) list of sampled exemplars for this point. Implementers are expected to filter out pointAttributes from the original recorded attributes.