Package com.linkedin.venice.pushmonitor

Class AggPushHealthStats

java.lang.Object

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

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

com.linkedin.venice.pushmonitor.AggPushHealthStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggPushHealthStats
extends AbstractVeniceAggStoreStats<PushHealthStats>

Field Summary

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

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AggPushHealthStats(String clusterName, io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, boolean isUnregisterMetricForDeletedStoreEnabled)

Method Summary

Modifier and Type	Method	Description
void	recordFailedPush(String storeName, long durationInSec)
void	recordPushPrepartionDuration(String storeName, long durationInSec)
void	recordSuccessfulPush(String storeName, long durationInSec)
void	recordSuccessfulPushGauge(String storeName, long durationInSec)

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

getStoreStats, handleStoreDeleted

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

AggPushHealthStats

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

Method Details

recordFailedPush

public void recordFailedPush(String storeName,
 long durationInSec)

recordSuccessfulPush

public void recordSuccessfulPush(String storeName,
 long durationInSec)

recordSuccessfulPushGauge

public void recordSuccessfulPushGauge(String storeName,
 long durationInSec)

recordPushPrepartionDuration

public void recordPushPrepartionDuration(String storeName,
 long durationInSec)