Package com.linkedin.davinci.stats.ingestion.heartbeat

Class HeartbeatVersionedStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatVersionedStats

All Implemented Interfaces:

StoreDataChangedListener

public class HeartbeatVersionedStats
extends AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

Field Summary

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

metadataRepository

Constructor Summary

Constructors

Constructor

Description

HeartbeatVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, Supplier<HeartbeatStat> statsInitiator, StatsSupplier<HeartbeatStatReporter> reporterSupplier, Map<String,Map<Integer,Map<Integer,Map<String,HeartbeatTimeStampEntry>>>> leaderMonitors, Map<String,Map<Integer,Map<Integer,Map<String,HeartbeatTimeStampEntry>>>> followerMonitors, String clusterName)

Method Summary

Modifier and Type	Method	Description
void	handleStoreChanged(Store store)
void	handleStoreCreated(Store store)	Do NOT try to acquire the lock of store repository again in the implementation, otherwise a dead lock issue will happen.
void	loadAllStats()
protected void	onVersionInfoUpdated(String storeName, int currentVersion, int futureVersion)	Hook method called when version info is updated for a store.
void	recordFollowerLag(String storeName, int version, String region, long heartbeatTs, boolean isReadyToServe)
void	recordLeaderLag(String storeName, int version, String region, long heartbeatTs)

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

addStore, getCurrentVersion, getFutureVersion, getMetricsRepository, getStats, getTotalStats, handleStoreDeleted, recordVersionedAndTotalStat, registerConditionalStats, updateStatsVersionInfo, updateTotalStats

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 Details

HeartbeatVersionedStats

public HeartbeatVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 Supplier<HeartbeatStat> statsInitiator,
 StatsSupplier<HeartbeatStatReporter> reporterSupplier,
 Map<String,Map<Integer,Map<Integer,Map<String,HeartbeatTimeStampEntry>>>> leaderMonitors,
 Map<String,Map<Integer,Map<Integer,Map<String,HeartbeatTimeStampEntry>>>> followerMonitors,
 String clusterName)

Method Details

recordLeaderLag

public void recordLeaderLag(String storeName,
 int version,
 String region,
 long heartbeatTs)

recordFollowerLag

public void recordFollowerLag(String storeName,
 int version,
 String region,
 long heartbeatTs,
 boolean isReadyToServe)

loadAllStats

public void loadAllStats()

Overrides:

loadAllStats in class AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

handleStoreCreated

public void handleStoreCreated(Store store)

Description copied from interface: StoreDataChangedListener

Do NOT try to acquire the lock of store repository again in the implementation, otherwise a dead lock issue will happen.

Specified by:

handleStoreCreated in interface StoreDataChangedListener

Overrides:

handleStoreCreated in class AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

handleStoreChanged

public void handleStoreChanged(Store store)

Specified by:

handleStoreChanged in interface StoreDataChangedListener

Overrides:

handleStoreChanged in class AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

onVersionInfoUpdated

protected void onVersionInfoUpdated(String storeName,
 int currentVersion,
 int futureVersion)

Description copied from class: AbstractVeniceAggVersionedStats

Hook method called when version info is updated for a store. Subclasses can override this to react to version changes.

Overrides:

onVersionInfoUpdated in class AbstractVeniceAggVersionedStats<HeartbeatStat,HeartbeatStatReporter>

Parameters:

storeName - The store whose version info changed

currentVersion - The new current version

futureVersion - The new future version