Class OpenTelemetryMetricSink

java.lang.Object

io.grpc.opentelemetry.OpenTelemetryMetricSink

All Implemented Interfaces:

io.grpc.MetricSink

final class OpenTelemetryMetricSink
extends Object
implements io.grpc.MetricSink

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OpenTelemetryMetricSink.MeasuresData

Nested classes/interfaces inherited from interface io.grpc.MetricSink

io.grpc.MetricSink.Registration

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	disableDefaultMetrics
private final Map<String,Boolean>	enableMetrics
private final Object	lock
private static final Logger	logger
private List<OpenTelemetryMetricSink.MeasuresData>	measures
private final io.opentelemetry.api.metrics.Meter	openTelemetryMeter
private final Set<String>	optionalLabels

Constructor Summary

Constructors

Constructor	Description
OpenTelemetryMetricSink(io.opentelemetry.api.metrics.Meter meter, Map<String,Boolean> enableMetrics, boolean disableDefaultMetrics, List<String> optionalLabels)

Method Summary

Modifier and Type	Method	Description
void	addDoubleCounter(io.grpc.DoubleCounterMetricInstrument metricInstrument, double value, List<String> requiredLabelValues, List<String> optionalLabelValues)
void	addLongCounter(io.grpc.LongCounterMetricInstrument metricInstrument, long value, List<String> requiredLabelValues, List<String> optionalLabelValues)
private io.opentelemetry.api.common.Attributes	createAttributes(List<String> requiredLabelKeys, List<String> optionalLabelKeys, List<String> requiredLabelValues, List<String> optionalLabelValues, BitSet bitSet)
Map<String,Boolean>	getEnabledMetrics()
(package private) List<OpenTelemetryMetricSink.MeasuresData>	getMeasures()
int	getMeasuresSize()
Set<String>	getOptionalLabels()
void	recordDoubleHistogram(io.grpc.DoubleHistogramMetricInstrument metricInstrument, double value, List<String> requiredLabelValues, List<String> optionalLabelValues)
void	recordLongGauge(io.grpc.LongGaugeMetricInstrument metricInstrument, long value, List<String> requiredLabelValues, List<String> optionalLabelValues)
void	recordLongHistogram(io.grpc.LongHistogramMetricInstrument metricInstrument, long value, List<String> requiredLabelValues, List<String> optionalLabelValues)
io.grpc.MetricSink.Registration	registerBatchCallback(Runnable callback, io.grpc.CallbackMetricInstrument... metricInstruments)
private boolean	shouldEnableMetric(io.grpc.MetricInstrument instrument)
void	updateMeasures(List<io.grpc.MetricInstrument> instruments)

Methods inherited from class Object

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

Field Details

logger

private static final Logger logger

lock

private final Object lock

openTelemetryMeter

private final io.opentelemetry.api.metrics.Meter openTelemetryMeter

enableMetrics

private final Map<String,Boolean> enableMetrics

disableDefaultMetrics

private final boolean disableDefaultMetrics

optionalLabels

private final Set<String> optionalLabels

measures

private volatile List<OpenTelemetryMetricSink.MeasuresData> measures

Constructor Details

OpenTelemetryMetricSink

OpenTelemetryMetricSink(io.opentelemetry.api.metrics.Meter meter,
 Map<String,Boolean> enableMetrics,
 boolean disableDefaultMetrics,
 List<String> optionalLabels)

Method Details

getEnabledMetrics

public Map<String,Boolean> getEnabledMetrics()

Specified by:

getEnabledMetrics in interface io.grpc.MetricSink

getOptionalLabels

public Set<String> getOptionalLabels()

Specified by:

getOptionalLabels in interface io.grpc.MetricSink

getMeasuresSize

public int getMeasuresSize()

Specified by:

getMeasuresSize in interface io.grpc.MetricSink

getMeasures

List<OpenTelemetryMetricSink.MeasuresData> getMeasures()

addDoubleCounter

public void addDoubleCounter(io.grpc.DoubleCounterMetricInstrument metricInstrument,
 double value,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues)

Specified by:

addDoubleCounter in interface io.grpc.MetricSink

addLongCounter

public void addLongCounter(io.grpc.LongCounterMetricInstrument metricInstrument,
 long value,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues)

Specified by:

addLongCounter in interface io.grpc.MetricSink

recordDoubleHistogram

public void recordDoubleHistogram(io.grpc.DoubleHistogramMetricInstrument metricInstrument,
 double value,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues)

Specified by:

recordDoubleHistogram in interface io.grpc.MetricSink

recordLongHistogram

public void recordLongHistogram(io.grpc.LongHistogramMetricInstrument metricInstrument,
 long value,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues)

Specified by:

recordLongHistogram in interface io.grpc.MetricSink

recordLongGauge

public void recordLongGauge(io.grpc.LongGaugeMetricInstrument metricInstrument,
 long value,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues)

Specified by:

recordLongGauge in interface io.grpc.MetricSink

registerBatchCallback

public io.grpc.MetricSink.Registration registerBatchCallback(Runnable callback,
 io.grpc.CallbackMetricInstrument... metricInstruments)

Specified by:

registerBatchCallback in interface io.grpc.MetricSink

updateMeasures

public void updateMeasures(List<io.grpc.MetricInstrument> instruments)

Specified by:

updateMeasures in interface io.grpc.MetricSink

shouldEnableMetric

private boolean shouldEnableMetric(io.grpc.MetricInstrument instrument)

createAttributes

private io.opentelemetry.api.common.Attributes createAttributes(List<String> requiredLabelKeys,
 List<String> optionalLabelKeys,
 List<String> requiredLabelValues,
 List<String> optionalLabelValues,
 BitSet bitSet)