Package com.linkedin.venice.stats

Class AbstractVeniceAggStoreStats<T extends AbstractVeniceStats>

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceAggStats<T>

com.linkedin.venice.stats.AbstractVeniceAggStoreStats<T>

All Implemented Interfaces:

StoreDataChangedListener

Direct Known Subclasses:

AggHostLevelIngestionStats, AggKafkaConsumerServiceStats, AggPushHealthStats, AggPushStatusCleanUpStats, AggRouterHttpRequestStats, AggServerHttpRequestStats

public class AbstractVeniceAggStoreStats<T extends AbstractVeniceStats>
extends AbstractVeniceAggStats<T>
implements StoreDataChangedListener

This class is an aggregate place that keeps stats objects for multiple stores. getStoreStats(String) creates a stats object per store. Sensors are registered during stats object construction. Upon store deletion, if unregister metric for deleted store feature is enabled, handleStoreDeleted(String) will retrieve the stats object and unregister sensors.

Field Summary

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

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AbstractVeniceAggStoreStats(String clusterName, io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, boolean isUnregisterMetricForDeletedStoreEnabled)
AbstractVeniceAggStoreStats(String clusterName, io.tehuti.metrics.MetricsRepository metricsRepository, StatsSupplier<T> statsSupplier, ReadOnlyStoreRepository metadataRepository, boolean isUnregisterMetricForDeletedStoreEnabled, boolean perClusterAggregate)

Method Summary

Modifier and Type	Method	Description
T	getStoreStats(String storeName)
void	handleStoreDeleted(String storeName)

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

getNullableStoreStats, getTotalStats, setStatsSupplier

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.meta.StoreDataChangedListener

handleStoreChanged, handleStoreCreated, handleStoreDeleted

Constructor Details

AbstractVeniceAggStoreStats

public AbstractVeniceAggStoreStats(String clusterName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 StatsSupplier<T> statsSupplier,
 ReadOnlyStoreRepository metadataRepository,
 boolean isUnregisterMetricForDeletedStoreEnabled,
 boolean perClusterAggregate)

AbstractVeniceAggStoreStats

public AbstractVeniceAggStoreStats(String clusterName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 boolean isUnregisterMetricForDeletedStoreEnabled)

Method Details

getStoreStats

public T getStoreStats(String storeName)

Overrides:

getStoreStats in class AbstractVeniceAggStats<T extends AbstractVeniceStats>

handleStoreDeleted

public void handleStoreDeleted(String storeName)

Specified by:

handleStoreDeleted in interface StoreDataChangedListener