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
recordFastClientErrorThinClientSucceedRequest()
void
recordFastClientSlowerRequest()
void
recordHealthyRequest(java.lang.String instance)
void
recordInternalServerErrorRequest(java.lang.String instance)
void
recordLeakedRequest(java.lang.String instance)
void
recordLongTailRetryRequest()
void
recordNoAvailableReplicaRequest()
void
recordOtherErrorRequest(java.lang.String instance)
void
recordQuotaExceededRequest(java.lang.String instance)
void
recordRequest(java.lang.String instance)
void
recordResponseWaitingTime(java.lang.String instance, double latency)
void
recordRetryRequestWin()
void
recordServiceUnavailableRequest(java.lang.String instance)
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, 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)
-
recordRequest
public void recordRequest(java.lang.String instance)
-
recordResponseWaitingTime
public void recordResponseWaitingTime(java.lang.String instance, double latency)
-
recordHealthyRequest
public void recordHealthyRequest(java.lang.String instance)
-
recordQuotaExceededRequest
public void recordQuotaExceededRequest(java.lang.String instance)
-
recordInternalServerErrorRequest
public void recordInternalServerErrorRequest(java.lang.String instance)
-
recordServiceUnavailableRequest
public void recordServiceUnavailableRequest(java.lang.String instance)
-
recordLeakedRequest
public void recordLeakedRequest(java.lang.String instance)
-
recordOtherErrorRequest
public void recordOtherErrorRequest(java.lang.String instance)
-
recordLongTailRetryRequest
public void recordLongTailRetryRequest()
-
recordErrorRetryRequest
public void recordErrorRetryRequest()
-
recordRetryRequestWin
public void recordRetryRequestWin()
-
updateCacheTimestamp
public void updateCacheTimestamp(long cacheTimeStampInMs)
-
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:
-
-