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

This class provides the stats for Venice client.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ClientStats.ClientTehutiMetricName	Metric names for tehuti metrics used in this class.

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

baseAttributes, baseDimensionsMap, CLIENT_METRIC_ENTITIES, clientType, otelRepository

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 timeout)
void	recordErrorRetryRequest()
void	recordHttpRequest(int httpStatus)
void	recordMultiGetFallback(int keyCount)
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	recordStreamingResponseTimeToReceiveFirstRecord(double latency)
void	recordSuccessDuplicateRequestKeyCount(int duplicateKeyCount)

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

emitHealthyRequestMetrics, emitHealthyRequestMetrics, emitHealthyRequestMetricsForDavinciClient, emitOpenTelemetryMetrics, emitUnhealthyRequestMetrics, emitUnhealthyRequestMetrics, emitUnhealthyRequestMetricsForDavinciClient, getBaseAttributes, getHealthyRequestHttpStatus, getRequestRate, getSuccessfulKeyCount, getSuccessRequestKeyCountRate, getUnhealthyRequestHttpStatus, recordRequestKeyCount, recordResponseKeyCount

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)

recordErrorRetryRequest

public void recordErrorRetryRequest()

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)

recordAppTimedOutRequest

public void recordAppTimedOutRequest()

recordAppTimedOutRequestResultRatio

public void recordAppTimedOutRequestResultRatio(double ratio)

recordClientFutureTimeout

public void recordClientFutureTimeout(long timeout)

recordRetryRequestKeyCount

public void recordRetryRequestKeyCount(int numberOfKeysSentInRetryRequest)

recordRetryRequestSuccessKeyCount

public void recordRetryRequestSuccessKeyCount(int numberOfKeysCompletedInRetryRequest)

recordMultiGetFallback

public void recordMultiGetFallback(int keyCount)