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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
buildSensorStatSummary(java.lang.String sensorName, java.lang.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, java.lang.String statsPrefix, java.lang.String storeName, RequestType requestType)
java.util.List<java.lang.Double>
getMetricValues(java.lang.String sensorName, java.lang.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, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors
-
-
-
-
Method Detail
-
getClientStats
public static FastClientStats getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository, java.lang.String statsPrefix, java.lang.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 java.lang.String buildSensorStatSummary(java.lang.String sensorName, java.lang.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 java.util.List<java.lang.Double> getMetricValues(java.lang.String sensorName, java.lang.String... stats)
This method is a utility method to get metric values useful in tests and for logging.- Parameters:
sensorName
-- Returns:
-
-