Package com.linkedin.venice.stats.routing

Class HelixGroupStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.stats.routing.HelixGroupStats

public class HelixGroupStats
extends AbstractVeniceStats

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HelixGroupStats.HelixGroupTehutiMetricDynamicName	Dynamic metric names for tehuti metrics used in this class.
static enum	HelixGroupStats.HelixGroupTehutiMetricName	Metric names for tehuti metrics used in this class.

Field Summary

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

DELIMITER

Constructor Summary

Constructors

Constructor	Description
HelixGroupStats(io.tehuti.metrics.MetricsRepository metricsRepository)
HelixGroupStats(io.tehuti.metrics.MetricsRepository metricsRepository, String prefix)

Method Summary

Modifier and Type	Method	Description
double	getGroupResponseWaitingTimeAvg(int groupId)
void	recordGroupNum(int groupNum)
void	recordGroupPendingRequest(int groupId, int value)
void	recordGroupRequest(int groupId)
void	recordGroupResponseWaitingTime(int groupId, double responseWaitingTime)

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

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object

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

Constructor Details

HelixGroupStats

public HelixGroupStats(io.tehuti.metrics.MetricsRepository metricsRepository)

HelixGroupStats

public HelixGroupStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String prefix)

Method Details

recordGroupNum

public void recordGroupNum(int groupNum)

recordGroupRequest

public void recordGroupRequest(int groupId)

recordGroupPendingRequest

public void recordGroupPendingRequest(int groupId,
 int value)

recordGroupResponseWaitingTime

public void recordGroupResponseWaitingTime(int groupId,
 double responseWaitingTime)

getGroupResponseWaitingTimeAvg

public double getGroupResponseWaitingTimeAvg(int groupId)