Package com.linkedin.venice.stats

Class VeniceOpenTelemetryMetricsRepository

java.lang.Object

com.linkedin.venice.stats.VeniceOpenTelemetryMetricsRepository

public class VeniceOpenTelemetryMetricsRepository
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final io.tehuti.utils.RedundantLogFilter	REDUNDANT_LOG_FILTER

Constructor Summary

Constructors

Constructor	Description
VeniceOpenTelemetryMetricsRepository(VeniceMetricsConfig metricsConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
io.opentelemetry.api.common.Attributes	createAttributes(MetricEntity metricEntity, Map<VeniceMetricsDimensions,String> baseDimensionsMap, VeniceDimensionInterface... additionalDimensionEnums)
io.opentelemetry.api.common.Attributes	createAttributes(MetricEntity metricEntity, Map<VeniceMetricsDimensions,String> baseDimensionsMap, Map<VeniceMetricsDimensions,String> additionalDimensionsMap)
io.opentelemetry.api.metrics.LongCounter	createCounter(MetricEntity metricEntity)
io.opentelemetry.api.metrics.DoubleHistogram	createHistogram(MetricEntity metricEntity)
Object	createInstrument(MetricEntity metricEntity)
boolean	emitOpenTelemetryMetrics()
String	getDimensionName(VeniceMetricsDimensions dimension)
VeniceOpenTelemetryMetricNamingFormat	getMetricFormat()
VeniceMetricsConfig	getMetricsConfig()
MetricEntityStateBase	getRecordFailureMetric()	for testing purposes
void	recordFailureMetric()

Methods inherited from class java.lang.Object

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

Field Details

REDUNDANT_LOG_FILTER

public static final io.tehuti.utils.RedundantLogFilter REDUNDANT_LOG_FILTER

Constructor Details

VeniceOpenTelemetryMetricsRepository

public VeniceOpenTelemetryMetricsRepository(VeniceMetricsConfig metricsConfig)

Method Details

createHistogram

public io.opentelemetry.api.metrics.DoubleHistogram createHistogram(MetricEntity metricEntity)

createCounter

public io.opentelemetry.api.metrics.LongCounter createCounter(MetricEntity metricEntity)

createInstrument

public Object createInstrument(MetricEntity metricEntity)

getDimensionName

public String getDimensionName(VeniceMetricsDimensions dimension)

createAttributes

public io.opentelemetry.api.common.Attributes createAttributes(MetricEntity metricEntity,
 Map<VeniceMetricsDimensions,String> baseDimensionsMap,
 VeniceDimensionInterface... additionalDimensionEnums)

createAttributes

public io.opentelemetry.api.common.Attributes createAttributes(MetricEntity metricEntity,
 Map<VeniceMetricsDimensions,String> baseDimensionsMap,
 Map<VeniceMetricsDimensions,String> additionalDimensionsMap)

close

public void close()

recordFailureMetric

public void recordFailureMetric()

emitOpenTelemetryMetrics

public boolean emitOpenTelemetryMetrics()

getMetricsConfig

public VeniceMetricsConfig getMetricsConfig()

getMetricFormat

public VeniceOpenTelemetryMetricNamingFormat getMetricFormat()

getRecordFailureMetric

public MetricEntityStateBase getRecordFailureMetric()

for testing purposes