Package com.linkedin.venice.client.stats

Class ClientStats

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

Direct Known Subclasses:

FastClientStats

public class ClientStats
extends BasicClientStats

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.client.stats.BasicClientStats

BasicClientStats.BasicClientMetricEntity, BasicClientStats.BasicClientTehutiMetricName

Field Summary

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

CLIENT_METRIC_ENTITIES

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

DELIMITER

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClientStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, RequestType requestType, ClientType clientType)

Method Summary

Modifier and Type	Method	Description
static ClientStats	getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, RequestType requestType, ClientConfig clientConfig, ClientType clientType)
void	recordAppTimedOutRequest()
void	recordAppTimedOutRequestResultRatio(double ratio)
void	recordClientFutureTimeout(long clientFutureTimeout)
void	recordHttpRequest(int httpStatus)
void	recordMultiGetFallback(int keyCount)
void	recordRequestRetryCount()
void	recordRequestSerializationTime(double latency)
void	recordRequestSubmissionToResponseHandlingTime(double latency)
void	recordResponseDecompressionTime(double latency)
void	recordResponseDeserializationTime(double latency)
void	recordRetryRequestKeyCount(int numberOfKeysSentInRetryRequest)
void	recordRetryRequestSuccessKeyCount(int numberOfKeysCompletedInRetryRequest)
void	recordStreamingResponseTimeToReceive50PctRecord(double latency)
void	recordStreamingResponseTimeToReceive90PctRecord(double latency)
void	recordStreamingResponseTimeToReceive95PctRecord(double latency)
void	recordStreamingResponseTimeToReceive99PctRecord(double latency)
void	recordStreamingResponseTimeToReceiveFirstRecord(double latency)
void	recordSuccessDuplicateRequestKeyCount(int duplicateKeyCount)

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

emitHealthyRequestMetrics, emitHealthyRequestMetrics, emitHealthyRequestMetricsForDavinciClient, emitUnhealthyRequestMetrics, emitUnhealthyRequestMetrics, emitUnhealthyRequestMetricsForDavinciClient, getHealthyRequestHttpStatus, getRequestRate, getSuccessfulKeyCount, getSuccessRequestKeyCountRate, getUnhealthyRequestHttpStatus, recordRequestKeyCount, recordSuccessRequestKeyCount

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

Constructor Details

ClientStats

protected ClientStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 RequestType requestType,
 ClientType clientType)

Method Details

getClientStats

public static ClientStats getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 RequestType requestType,
 ClientConfig clientConfig,
 ClientType clientType)

recordHttpRequest

public void recordHttpRequest(int httpStatus)

recordRequestRetryCount

public void recordRequestRetryCount()

recordSuccessDuplicateRequestKeyCount

public void recordSuccessDuplicateRequestKeyCount(int duplicateKeyCount)

recordRequestSerializationTime

public void recordRequestSerializationTime(double latency)

recordRequestSubmissionToResponseHandlingTime

public void recordRequestSubmissionToResponseHandlingTime(double latency)

recordResponseDeserializationTime

public void recordResponseDeserializationTime(double latency)

recordResponseDecompressionTime

public void recordResponseDecompressionTime(double latency)

recordStreamingResponseTimeToReceiveFirstRecord

public void recordStreamingResponseTimeToReceiveFirstRecord(double latency)

recordStreamingResponseTimeToReceive50PctRecord

public void recordStreamingResponseTimeToReceive50PctRecord(double latency)

recordStreamingResponseTimeToReceive90PctRecord

public void recordStreamingResponseTimeToReceive90PctRecord(double latency)

recordStreamingResponseTimeToReceive95PctRecord

public void recordStreamingResponseTimeToReceive95PctRecord(double latency)

recordStreamingResponseTimeToReceive99PctRecord

public void recordStreamingResponseTimeToReceive99PctRecord(double latency)

recordAppTimedOutRequest

public void recordAppTimedOutRequest()

recordAppTimedOutRequestResultRatio

public void recordAppTimedOutRequestResultRatio(double ratio)

recordClientFutureTimeout

public void recordClientFutureTimeout(long clientFutureTimeout)

recordRetryRequestKeyCount

public void recordRetryRequestKeyCount(int numberOfKeysSentInRetryRequest)

recordRetryRequestSuccessKeyCount

public void recordRetryRequestSuccessKeyCount(int numberOfKeysCompletedInRetryRequest)

recordMultiGetFallback

public void recordMultiGetFallback(int keyCount)