Package com.linkedin.davinci.stats

Class AggVersionedDIVStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

com.linkedin.davinci.stats.AggVersionedDIVStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedDIVStats
extends AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

Field Summary

Fields inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

metadataRepository

Constructor Summary

Constructors

Constructor	Description
AggVersionedDIVStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, boolean unregisterMetricForDeletedStoreEnabled)

Method Summary

Modifier and Type	Method	Description
void	recordBenignLeaderOffsetRewind(java.lang.String storeName, int version)
void	recordBenignLeaderProducerFailure(java.lang.String storeName, int version)
void	recordCorruptedMsg(java.lang.String storeName, int version)
void	recordDuplicateMsg(java.lang.String storeName, int version)
void	recordException(java.lang.String storeName, int version, DataValidationException e)
void	recordFollowerLatencies(java.lang.String storeName, int version, long currentTimeMs, double producerBrokerLatencyMs, double brokerConsumerLatencyMs)
void	recordLeaderDIVCompletionTime(java.lang.String storeName, int version, double value, long currentTimeMs)
void	recordLeaderLatencies(java.lang.String storeName, int version, long currentTimeMs, double producerBrokerLatencyMs, double brokerConsumerLatencyMs)
void	recordLeaderProducerCompletionTime(java.lang.String storeName, int version, double value, long currentTimeMs)
void	recordLeaderProducerFailure(java.lang.String storeName, int version)
void	recordMissingMsg(java.lang.String storeName, int version)
void	recordPotentiallyLossyLeaderOffsetRewind(java.lang.String storeName, int version)
void	recordSuccessMsg(java.lang.String storeName, int version)
protected void	updateTotalStats(java.lang.String storeName)	Some versioned stats might always increasing; in this case, the value in the total stats should be updated with the aggregated values across the new version list.

Methods inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

addStore, getCurrentVersion, getFutureVersion, getStats, getTotalStats, handleStoreChanged, handleStoreCreated, handleStoreDeleted, isFutureVersion, loadAllStats, recordVersionedAndTotalStat, registerConditionalStats, updateStatsVersionInfo

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

handleStoreDeleted

Constructor Detail

AggVersionedDIVStats

public AggVersionedDIVStats(io.tehuti.metrics.MetricsRepository metricsRepository,
                            ReadOnlyStoreRepository metadataRepository,
                            boolean unregisterMetricForDeletedStoreEnabled)

Method Detail

recordException

public void recordException(java.lang.String storeName,
                            int version,
                            DataValidationException e)

recordDuplicateMsg

public void recordDuplicateMsg(java.lang.String storeName,
                               int version)

recordMissingMsg

public void recordMissingMsg(java.lang.String storeName,
                             int version)

recordCorruptedMsg

public void recordCorruptedMsg(java.lang.String storeName,
                               int version)

recordSuccessMsg

public void recordSuccessMsg(java.lang.String storeName,
                             int version)

recordLeaderLatencies

public void recordLeaderLatencies(java.lang.String storeName,
                                  int version,
                                  long currentTimeMs,
                                  double producerBrokerLatencyMs,
                                  double brokerConsumerLatencyMs)

recordFollowerLatencies

public void recordFollowerLatencies(java.lang.String storeName,
                                    int version,
                                    long currentTimeMs,
                                    double producerBrokerLatencyMs,
                                    double brokerConsumerLatencyMs)

recordLeaderProducerCompletionTime

public void recordLeaderProducerCompletionTime(java.lang.String storeName,
                                               int version,
                                               double value,
                                               long currentTimeMs)

recordLeaderDIVCompletionTime

public void recordLeaderDIVCompletionTime(java.lang.String storeName,
                                          int version,
                                          double value,
                                          long currentTimeMs)

recordBenignLeaderOffsetRewind

public void recordBenignLeaderOffsetRewind(java.lang.String storeName,
                                           int version)

recordPotentiallyLossyLeaderOffsetRewind

public void recordPotentiallyLossyLeaderOffsetRewind(java.lang.String storeName,
                                                     int version)

recordLeaderProducerFailure

public void recordLeaderProducerFailure(java.lang.String storeName,
                                        int version)

recordBenignLeaderProducerFailure

public void recordBenignLeaderProducerFailure(java.lang.String storeName,
                                              int version)

updateTotalStats

protected void updateTotalStats(java.lang.String storeName)

Description copied from class: AbstractVeniceAggVersionedStats

Some versioned stats might always increasing; in this case, the value in the total stats should be updated with the aggregated values across the new version list.

Overrides:

updateTotalStats in class AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>