Package com.linkedin.venice.fastclient.stats

Class FastClientStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.stats.AbstractVeniceHttpStats

com.linkedin.venice.client.stats.BasicClientStats

com.linkedin.venice.client.stats.ClientStats

com.linkedin.venice.fastclient.stats.FastClientStats

public class FastClientStats
extends ClientStats

Field Summary

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

DELIMITER

Method Summary

Modifier and Type	Method	Description
String	buildSensorStatSummary(String sensorName, String... stats)	This method is a utility method to build concise summaries useful in tests and for logging.
static FastClientStats	getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository, String statsPrefix, String storeName, RequestType requestType)
List<Double>	getMetricValues(String sensorName, String... stats)	This method is a utility method to get metric values useful in tests and for logging.
void	recordErrorRetryRequest()
void	recordFanoutSize(int fanoutSize)
void	recordFastClientErrorThinClientSucceedRequest()
void	recordFastClientSlowerRequest()
void	recordLongTailRetryRequest()
void	recordNoAvailableReplicaRequest()
void	recordRetryFanoutSize(int retryFanoutSize)
void	recordRetryRequestWin()
void	recordThinClientFastClientLatencyDelta(double latencyDelta)
void	updateCacheTimestamp(long cacheTimeStampInMs)

Methods inherited from class com.linkedin.venice.client.stats.ClientStats

getClientStats, recordAppTimedOutRequest, recordAppTimedOutRequestResultRatio, recordClientFutureTimeout, recordHttpRequest, recordMultiGetFallback, recordRequestRetryCount, recordRequestSerializationTime, recordRequestSubmissionToResponseHandlingTime, recordResponseDecompressionTime, recordResponseDeserializationTime, recordRetryRequestKeyCount, recordRetryRequestSuccessKeyCount, recordStreamingResponseTimeToReceive50PctRecord, recordStreamingResponseTimeToReceive90PctRecord, recordStreamingResponseTimeToReceive95PctRecord, recordStreamingResponseTimeToReceive99PctRecord, recordStreamingResponseTimeToReceiveFirstRecord, recordSuccessDuplicateRequestKeyCount, recordUnhealthyLatency

Methods inherited from class com.linkedin.venice.client.stats.BasicClientStats

getRequestRate, getSuccessRequestKeyCountRate, recordHealthyLatency, recordHealthyRequest, recordRequestKeyCount, recordSuccessRequestKeyCount, recordUnhealthyRequest

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

getFullMetricName, getRequestType, registerSensor, registerSensor, registerSensor, registerSensorWithDetailedPercentiles

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

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, 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

Method Details

getClientStats

public static FastClientStats getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String statsPrefix,
 String storeName,
 RequestType requestType)

recordNoAvailableReplicaRequest

public void recordNoAvailableReplicaRequest()

recordFastClientSlowerRequest

public void recordFastClientSlowerRequest()

recordFastClientErrorThinClientSucceedRequest

public void recordFastClientErrorThinClientSucceedRequest()

recordThinClientFastClientLatencyDelta

public void recordThinClientFastClientLatencyDelta(double latencyDelta)

recordLongTailRetryRequest

public void recordLongTailRetryRequest()

recordErrorRetryRequest

public void recordErrorRetryRequest()

recordRetryRequestWin

public void recordRetryRequestWin()

updateCacheTimestamp

public void updateCacheTimestamp(long cacheTimeStampInMs)

recordFanoutSize

public void recordFanoutSize(int fanoutSize)

recordRetryFanoutSize

public void recordRetryFanoutSize(int retryFanoutSize)

buildSensorStatSummary

public String buildSensorStatSummary(String sensorName,
 String... stats)

This method is a utility method to build concise summaries useful in tests and for logging. It generates a single string for all metrics for a sensor

Parameters:

sensorName -

Returns:

getMetricValues

public List<Double> getMetricValues(String sensorName,
 String... stats)

This method is a utility method to get metric values useful in tests and for logging.

Parameters:

sensorName -

Returns: