Package com.linkedin.venice.router.stats

Class AggHostHealthStats

java.lang.Object

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

com.linkedin.venice.router.stats.AggHostHealthStats

public class AggHostHealthStats
extends AbstractVeniceAggStats<HostHealthStats>

Field Summary

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

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AggHostHealthStats(String clusterName, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
void	recordLeakedPendingRequestCount(String hostName)
void	recordPendingRequestCount(String hostName, long cnt)
void	recordPendingRequestUnhealthyDuration(String hostName, double duration)
void	recordUnhealthyHostCountCausedByPendingQueue(int count)
void	recordUnhealthyHostCountCausedByRouterHeartBeat(int count)
void	recordUnhealthyHostDelayJoin(String hostName)
void	recordUnhealthyHostHeartBeatFailure(String hostName)
void	recordUnhealthyHostOfflineInstance(String hostName)
void	recordUnhealthyHostTooManyPendingRequest(String hostName)

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

AggHostHealthStats

public AggHostHealthStats(String clusterName,
 io.tehuti.metrics.MetricsRepository metricsRepository)

Method Details

recordUnhealthyHostOfflineInstance

public void recordUnhealthyHostOfflineInstance(String hostName)

recordUnhealthyHostTooManyPendingRequest

public void recordUnhealthyHostTooManyPendingRequest(String hostName)

recordUnhealthyHostHeartBeatFailure

public void recordUnhealthyHostHeartBeatFailure(String hostName)

recordPendingRequestCount

public void recordPendingRequestCount(String hostName,
 long cnt)

recordLeakedPendingRequestCount

public void recordLeakedPendingRequestCount(String hostName)

recordPendingRequestUnhealthyDuration

public void recordPendingRequestUnhealthyDuration(String hostName,
 double duration)

recordUnhealthyHostCountCausedByPendingQueue

public void recordUnhealthyHostCountCausedByPendingQueue(int count)

recordUnhealthyHostCountCausedByRouterHeartBeat

public void recordUnhealthyHostCountCausedByRouterHeartBeat(int count)

recordUnhealthyHostDelayJoin

public void recordUnhealthyHostDelayJoin(String hostName)