Package com.linkedin.venice.stats

Class AggServerQuotaUsageStats

java.lang.Object

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

com.linkedin.venice.stats.AggServerQuotaUsageStats

public class AggServerQuotaUsageStats
extends AbstractVeniceAggStats<ServerReadQuotaUsageStats>

AggServerQuotaUsageStats is the aggregate statistics for ServerReadQuotaUsageStats which measures requests and quota rejections of each store.

Field Summary

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

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AggServerQuotaUsageStats(String cluster, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
void	recordAllowed(String storeName, int version, long rcu)
void	recordAllowedUnintentionally(String storeName, int version, long rcu)
void	recordRejected(String storeName, int version, long rcu)
void	setNodeQuotaResponsibility(String storeName, int version, long nodeKpsResponsibility)
void	updateVersionInfo(String storeName, int currentVersion, int backupVersion)

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

getNullableStoreStats, getStoreStats, getTotalStats, setStatsSupplier

Methods inherited from class java.lang.Object

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

Constructor Details

AggServerQuotaUsageStats

public AggServerQuotaUsageStats(String cluster,
 io.tehuti.metrics.MetricsRepository metricsRepository)

Method Details

recordAllowed

public void recordAllowed(String storeName,
 int version,
 long rcu)

recordRejected

public void recordRejected(String storeName,
 int version,
 long rcu)

recordAllowedUnintentionally

public void recordAllowedUnintentionally(String storeName,
 int version,
 long rcu)

setNodeQuotaResponsibility

public void setNodeQuotaResponsibility(String storeName,
 int version,
 long nodeKpsResponsibility)

updateVersionInfo

public void updateVersionInfo(String storeName,
 int currentVersion,
 int backupVersion)