Package com.linkedin.venice.utils.metrics

Class MetricsRepositoryUtils

java.lang.Object

com.linkedin.venice.utils.metrics.MetricsRepositoryUtils

public class MetricsRepositoryUtils
extends Object

Utility functions to help create common metrics repository.

Constructor Summary

Constructors

Constructor	Description
MetricsRepositoryUtils()

Method Summary

Modifier and Type	Method	Description
static io.tehuti.metrics.MetricConfig	createDefaultSingleThreadedMetricConfig()
static io.tehuti.metrics.MetricsRepository	createMultiThreadedMetricsRepository()
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository()
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository(long maxMetricsMeasurementTimeoutMs, long initialMetricsMeasurementTimeoutMs)
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository(long maxMetricsMeasurementTimeoutMs, long initialMetricsMeasurementTimeoutMs, io.tehuti.utils.Time time)
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository(io.tehuti.utils.Time time)	Variant that lets the caller inject a Time into the underlying MetricsRepository.
static io.tehuti.metrics.MetricsRepository	createSingleThreadedVeniceMetricsRepository()
static io.tehuti.metrics.MetricsRepository	createSingleThreadedVeniceMetricsRepository(boolean isOtelEnabled, VeniceOpenTelemetryMetricNamingFormat otelFormat, Collection<MetricEntity> metricEntities)
static io.tehuti.metrics.MetricsRepository	createSingleThreadedVeniceMetricsRepository(long maxMetricsMeasurementTimeoutMs, long initialMetricsMeasurementTimeoutMs, boolean isOtelEnabled, VeniceOpenTelemetryMetricNamingFormat otelFormat, Collection<MetricEntity> metricEntities)
static io.tehuti.metrics.MetricConfig	getMetricConfig(long maxMetricsMeasurementTimeoutMs, long initialMetricsMeasurementTimeoutMs)

Methods inherited from class java.lang.Object

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

Constructor Details

MetricsRepositoryUtils

public MetricsRepositoryUtils()

Method Details

createMultiThreadedMetricsRepository

public static io.tehuti.metrics.MetricsRepository createMultiThreadedMetricsRepository()

createSingleThreadedMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedMetricsRepository()

createSingleThreadedMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedMetricsRepository(long maxMetricsMeasurementTimeoutMs,
 long initialMetricsMeasurementTimeoutMs)

createSingleThreadedMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedMetricsRepository(io.tehuti.utils.Time time)

Variant that lets the caller inject a Time into the underlying MetricsRepository. Tehuti's Rate (and other sampled stats) read time on every measure() call to compute the window elapsed; using a Time mock makes those reads deterministic across consecutive value() calls in a test.

createSingleThreadedMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedMetricsRepository(long maxMetricsMeasurementTimeoutMs,
 long initialMetricsMeasurementTimeoutMs,
 io.tehuti.utils.Time time)

createSingleThreadedVeniceMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedVeniceMetricsRepository()

createSingleThreadedVeniceMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedVeniceMetricsRepository(boolean isOtelEnabled,
 VeniceOpenTelemetryMetricNamingFormat otelFormat,
 Collection<MetricEntity> metricEntities)

createSingleThreadedVeniceMetricsRepository

public static io.tehuti.metrics.MetricsRepository createSingleThreadedVeniceMetricsRepository(long maxMetricsMeasurementTimeoutMs,
 long initialMetricsMeasurementTimeoutMs,
 boolean isOtelEnabled,
 VeniceOpenTelemetryMetricNamingFormat otelFormat,
 Collection<MetricEntity> metricEntities)

createDefaultSingleThreadedMetricConfig

public static io.tehuti.metrics.MetricConfig createDefaultSingleThreadedMetricConfig()

getMetricConfig

public static io.tehuti.metrics.MetricConfig getMetricConfig(long maxMetricsMeasurementTimeoutMs,
 long initialMetricsMeasurementTimeoutMs)