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
-
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
ConstructorsModifierConstructorDescriptionprotected
ClientStats
(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, RequestType requestType, ClientType clientType) -
Method Summary
Modifier and TypeMethodDescriptionstatic ClientStats
getClientStats
(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, RequestType requestType, ClientConfig clientConfig, ClientType clientType) void
void
recordAppTimedOutRequestResultRatio
(double ratio) void
recordClientFutureTimeout
(long clientFutureTimeout) void
recordHttpRequest
(int httpStatus) void
recordMultiGetFallback
(int keyCount) void
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
-
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)
-