Package com.linkedin.venice.controller.stats

Class PartitionHealthStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.controller.stats.PartitionHealthStats

public class PartitionHealthStats
extends AbstractVeniceStats

Resource level partition health stats. Tracks under-replicated partitions for a given version topic. Both Tehuti and OTel metrics are combined into a single MetricEntityStateBase, following the same pattern used in the router (e.g., RouterHttpRequestStats).

For OTel, the store name dimension is derived from the version topic name at construction time. Total stats instances (created by AbstractVeniceAggStats) have OTel disabled via OpenTelemetryMetricsSetup.Builder.isTotalStats(boolean).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PartitionHealthStats.PartitionHealthOtelMetricEntity

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats

DELIMITER

Constructor Summary

Constructors

Constructor	Description
PartitionHealthStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name, String clusterName)
PartitionHealthStats(String resourceName)	Only for test usage.

Method Summary

Modifier and Type	Method	Description
void	recordUnderReplicatePartition(int num)

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotal, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionHealthStats

public PartitionHealthStats(String resourceName)

Only for test usage.

PartitionHealthStats

public PartitionHealthStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String name,
 String clusterName)

Method Details

recordUnderReplicatePartition

public void recordUnderReplicatePartition(int num)