Class DefaultSynchronousMetricStorage<T extends PointData, U extends ExemplarData>

java.lang.Object

io.opentelemetry.sdk.metrics.internal.state.DefaultSynchronousMetricStorage<T,U>

All Implemented Interfaces:

MetricStorage, SynchronousMetricStorage, WriteableMetricStorage

public final class DefaultSynchronousMetricStorage<T extends PointData, U extends ExemplarData>
extends Object
implements SynchronousMetricStorage

Stores aggregated MetricData for synchronous instruments.

This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.

Field Summary

Fields inherited from interface MetricStorage

CARDINALITY_OVERFLOW, DEFAULT_MAX_CARDINALITY

Method Summary

Modifier and Type	Method	Description
MetricData	collect(Resource resource, InstrumentationScopeInfo instrumentationScopeInfo, long startEpochNanos, long epochNanos)	Collects the metrics from this storage.
MetricDescriptor	getMetricDescriptor()	Returns a description of the metric produced in this storage.
boolean	isEnabled()	Returns true if the storage is actively recording measurements, and false otherwise (i.e. noop / empty metric storage is installed).
void	recordDouble(double value, Attributes attributes, Context context)	Records a measurement.
void	recordLong(long value, Attributes attributes, Context context)	Records a measurement.

Methods inherited from class Object

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

Methods inherited from interface MetricStorage

isEmpty

Method Details

recordLong

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

Description copied from interface: WriteableMetricStorage

Records a measurement.

Specified by:

recordLong in interface WriteableMetricStorage

recordDouble

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

Description copied from interface: WriteableMetricStorage

Records a measurement.

Specified by:

recordDouble in interface WriteableMetricStorage

isEnabled

public boolean isEnabled()

Description copied from interface: WriteableMetricStorage

Returns true if the storage is actively recording measurements, and false otherwise (i.e. noop / empty metric storage is installed).

Specified by:

isEnabled in interface WriteableMetricStorage

collect

public MetricData collect(Resource resource,
 InstrumentationScopeInfo instrumentationScopeInfo,
 long startEpochNanos,
 long epochNanos)

Description copied from interface: MetricStorage

Collects the metrics from this storage. If storing AggregationTemporality.DELTA metrics, reset for the next collection period.

Note: This is a stateful operation and will reset any interval-related state for the collector.

Specified by:

collect in interface MetricStorage

Parameters:

resource - The resource associated with the metrics.

instrumentationScopeInfo - The instrumentation scope generating the metrics.

startEpochNanos - The start timestamp for this SDK.

epochNanos - The timestamp for this collection.

Returns:

The MetricData from this collection period.

getMetricDescriptor

public MetricDescriptor getMetricDescriptor()

Description copied from interface: MetricStorage

Returns a description of the metric produced in this storage.

Specified by:

getMetricDescriptor in interface MetricStorage