Package com.linkedin.davinci.stats

Class VeniceVersionedStats<STATS,STATS_REPORTER extends AbstractVeniceStatsReporter<STATS>>

java.lang.Object

com.linkedin.davinci.stats.VeniceVersionedStats<STATS,STATS_REPORTER>

public class VeniceVersionedStats<STATS,STATS_REPORTER extends AbstractVeniceStatsReporter<STATS>>
extends Object

Constructor Summary

Constructors

Constructor	Description
VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, Supplier<STATS> statsInitiator, StatsSupplier<STATS_REPORTER> reporterSupplier)
VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, Supplier<STATS> statsInitiator, StatsSupplier<STATS_REPORTER> reporterSupplier, boolean roleScopedStatsEnabled)

Method Summary

Modifier and Type	Method	Description
STATS	addVersion(int version)
it.unimi.dsi.fastutil.ints.IntSet	getAllVersionNumbers()	return a deep copy of all version numbers
int	getCurrentVersion()
int	getFutureVersion()
protected STATS	getRoleStats(int version)	Returns the stats for the role version currently holds, or null if disabled or the version is neither current nor future.
protected STATS	getStats(int version)
protected STATS	getTotalStats()
void	registerConditionalStats()
void	removeVersion(int version)
void	setCurrentVersion(int version)
void	setFutureVersion(int version)
void	unregisterStats()

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceVersionedStats

public VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 Supplier<STATS> statsInitiator,
 StatsSupplier<STATS_REPORTER> reporterSupplier)

VeniceVersionedStats

public VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 Supplier<STATS> statsInitiator,
 StatsSupplier<STATS_REPORTER> reporterSupplier,
 boolean roleScopedStatsEnabled)

Method Details

getTotalStats

protected STATS getTotalStats()

getRoleStats

protected STATS getRoleStats(int version)

Returns the stats for the role version currently holds, or null if disabled or the version is neither current nor future.

registerConditionalStats

public void registerConditionalStats()

unregisterStats

public void unregisterStats()

getCurrentVersion

public int getCurrentVersion()

getFutureVersion

public int getFutureVersion()

setCurrentVersion

public void setCurrentVersion(int version)

setFutureVersion

public void setFutureVersion(int version)

getAllVersionNumbers

public it.unimi.dsi.fastutil.ints.IntSet getAllVersionNumbers()

return a deep copy of all version numbers

getStats

protected STATS getStats(int version)

addVersion

public STATS addVersion(int version)

removeVersion

public void removeVersion(int version)