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.MetricsRepository	createMultiThreadedMetricsRepository()
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository()
static io.tehuti.metrics.MetricsRepository	createSingleThreadedMetricsRepository(long maxMetricsMeasurementTimeoutMs, long initialMetricsMeasurementTimeoutMs)
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)

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)

getMetricConfig

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