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 ServerQuotaUsageStats 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, long rcu)
void	recordRejected(String storeName, int version, long rcu)
void	setBackupVersion(String storeName, int version)
void	setCurrentVersion(String storeName, int version)
void	setNodeQuotaResponsibility(String storeName, int version, long nodeKpsResponsibility)

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,
 long rcu)

setNodeQuotaResponsibility

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

setCurrentVersion

public void setCurrentVersion(String storeName,
 int version)

setBackupVersion

public void setBackupVersion(String storeName,
 int version)