Package com.linkedin.venice.fastclient.stats

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

Nested Class Summary

Nested Classes

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

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

ClientStats.ClientTehutiMetricName

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

Method Summary

Modifier and Type	Method	Description
String	buildSensorStatSummary(String sensorName, 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, String statsPrefix, String storeName, RequestType requestType)
List<Double>	getMetricValues(String sensorName, String... stats)	This method is a utility method to get metric values useful in tests and for logging.
void	recordErrorRetryRequest()
void	recordFanoutSize(int size)
void	recordFastClientErrorThinClientSucceedRequest()
void	recordFastClientSlowerRequest()
void	recordLongTailRetryRequest()
void	recordNoAvailableReplicaRequest()
void	recordRejectedRequestByLoadController()
void	recordRejectionRatio(double rejectionRatio)
void	recordRetryFanoutSize(int size)
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, recordRequestSerializationTime, recordRequestSubmissionToResponseHandlingTime, recordResponseDecompressionTime, recordResponseDeserializationTime, recordRetryRequestKeyCount, recordRetryRequestSuccessKeyCount, recordStreamingResponseTimeToReceive50PctRecord, recordStreamingResponseTimeToReceive90PctRecord, recordStreamingResponseTimeToReceiveFirstRecord, recordSuccessDuplicateRequestKeyCount

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

Method Details

getClientStats

public static FastClientStats getClientStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String statsPrefix,
 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()

Overrides:

recordErrorRetryRequest in class ClientStats

recordRetryRequestWin

public void recordRetryRequestWin()

updateCacheTimestamp

public void updateCacheTimestamp(long cacheTimeStampInMs)

recordFanoutSize

public void recordFanoutSize(int size)

recordRetryFanoutSize

public void recordRetryFanoutSize(int size)

recordRejectedRequestByLoadController

public void recordRejectedRequestByLoadController()

recordRejectionRatio

public void recordRejectionRatio(double rejectionRatio)

buildSensorStatSummary

public String buildSensorStatSummary(String sensorName,
 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 List<Double> getMetricValues(String sensorName,
 String... stats)

This method is a utility method to get metric values useful in tests and for logging.

Parameters:

sensorName -

Returns: