Package com.linkedin.venice.stats.metrics

Class AsyncMetricEntityState

java.lang.Object

com.linkedin.venice.stats.metrics.AsyncMetricEntityState

Direct Known Subclasses:

AsyncMetricEntityStateBase, MetricEntityState

public abstract class AsyncMetricEntityState
extends Object

Abstract operational state of a metric entity. Subclassed by:

1. AsyncMetricEntityStateBase — async gauge with a fixed attribute set (no dynamic dimensions).
2. MetricEntityState — non-async metrics (sync counter, histogram, gauge) and observable counters. Provides the record() API.

Async gauges with enum dimensions use AsyncMetricEntityStateOneEnum / AsyncMetricEntityStateTwoEnums instead — these register a single multi-emit observable gauge per metric entity and do not subclass this base.

This class holds:

• Whether OTel is enabled.
• The MetricEntity definition.
• At most one OTel instrument (stored in otelMetric).
• At most one Tehuti sensor. When one OTel metric corresponds to multiple Tehuti sensors (e.g., two Tehuti sensors mapped to a single OTel metric via a dimension), there are multiple instances of this class each with the same OTel instrument handle but a different Tehuti sensor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AsyncMetricEntityState.TehutiSensorRegistrationFunction	create the metrics/Sensors

Field Summary

Fields

Modifier and Type	Field	Description
protected final MetricEntity	metricEntity
protected Object	otelMetric	Otel metric
protected final VeniceOpenTelemetryMetricsRepository	otelRepository
protected io.tehuti.metrics.Sensor	tehutiSensor	Respective tehuti metric

Constructor Summary

Constructors

Constructor	Description
AsyncMetricEntityState(MetricEntity metricEntity, VeniceOpenTelemetryMetricsRepository otelRepository, Map<VeniceMetricsDimensions,String> baseDimensionsMap, AsyncMetricEntityState.TehutiSensorRegistrationFunction registerTehutiSensorFn, TehutiMetricNameEnum tehutiMetricNameEnum, List<io.tehuti.metrics.MeasurableStat> tehutiMetricStats, DoubleSupplier asyncDoubleCallback, io.opentelemetry.api.common.Attributes asyncAttributes)	Constructor for MetricType.ASYNC_DOUBLE_GAUGE metrics that use a DoubleSupplier callback.
AsyncMetricEntityState(MetricEntity metricEntity, VeniceOpenTelemetryMetricsRepository otelRepository, Map<VeniceMetricsDimensions,String> baseDimensionsMap, AsyncMetricEntityState.TehutiSensorRegistrationFunction registerTehutiSensorFn, TehutiMetricNameEnum tehutiMetricNameEnum, List<io.tehuti.metrics.MeasurableStat> tehutiMetricStats, LongSupplier asyncCallback, io.opentelemetry.api.common.Attributes asyncAttributes)

Method Summary

Modifier and Type	Method	Description
Object	getOtelMetric()
io.tehuti.metrics.Sensor	getTehutiSensor()
void	setOtelMetric(Object otelMetric)
void	setTehutiSensor(io.tehuti.metrics.Sensor tehutiSensor)

Methods inherited from class java.lang.Object

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

Field Details

otelRepository

protected final VeniceOpenTelemetryMetricsRepository otelRepository

metricEntity

protected final MetricEntity metricEntity

otelMetric

protected Object otelMetric

Otel metric

tehutiSensor

protected io.tehuti.metrics.Sensor tehutiSensor

Respective tehuti metric

Constructor Details

AsyncMetricEntityState

public AsyncMetricEntityState(MetricEntity metricEntity,
 VeniceOpenTelemetryMetricsRepository otelRepository,
 Map<VeniceMetricsDimensions,String> baseDimensionsMap,
 AsyncMetricEntityState.TehutiSensorRegistrationFunction registerTehutiSensorFn,
 TehutiMetricNameEnum tehutiMetricNameEnum,
 List<io.tehuti.metrics.MeasurableStat> tehutiMetricStats,
 LongSupplier asyncCallback,
 io.opentelemetry.api.common.Attributes asyncAttributes)

AsyncMetricEntityState

public AsyncMetricEntityState(MetricEntity metricEntity,
 VeniceOpenTelemetryMetricsRepository otelRepository,
 Map<VeniceMetricsDimensions,String> baseDimensionsMap,
 AsyncMetricEntityState.TehutiSensorRegistrationFunction registerTehutiSensorFn,
 TehutiMetricNameEnum tehutiMetricNameEnum,
 List<io.tehuti.metrics.MeasurableStat> tehutiMetricStats,
 DoubleSupplier asyncDoubleCallback,
 io.opentelemetry.api.common.Attributes asyncAttributes)

Constructor for MetricType.ASYNC_DOUBLE_GAUGE metrics that use a DoubleSupplier callback.

Method Details

setOtelMetric

public void setOtelMetric(Object otelMetric)

setTehutiSensor

public void setTehutiSensor(io.tehuti.metrics.Sensor tehutiSensor)

getTehutiSensor

public io.tehuti.metrics.Sensor getTehutiSensor()

getOtelMetric

public Object getOtelMetric()