Package com.linkedin.venice.stats

Class ServerHttpRequestStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.stats.AbstractVeniceHttpStats

com.linkedin.venice.stats.ServerHttpRequestStats

public class ServerHttpRequestStats
extends AbstractVeniceHttpStats

ServerHttpRequestStats contains counters measuring the performance of handling requests from Routers. Both OTel MetricEntityState fields and Tehuti Sensor fields coexist in this class. The record methods on MetricEntityState subclasses write to both systems.

Field Summary

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

DELIMITER

Constructor Summary

Constructors

Constructor	Description
ServerHttpRequestStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, String clusterName, RequestType requestType, boolean isKeyValueProfilingEnabled, ServerHttpRequestStats totalStats, boolean isDaVinciClient, boolean readOtelStatsEnabled)

Method Summary

Modifier and Type	Method	Description
void	recordCosineSimilarityCount(int count)
void	recordCountOperatorCount(int count)
void	recordDatabaseLookupLatency(double latency, boolean assembledMultiChunkLargeValue)
void	recordDotProductCount(int count)
void	recordEarlyTerminatedEarlyRequest()
void	recordErrorRequest(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory)
void	recordErrorRequestAndLatency(io.netty.handler.codec.http.HttpResponseStatus responseStatus, VeniceResponseStatusCategory veniceCategory, double latency)
void	recordErrorRequestLatency(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory, double latency)
void	recordFlushLatency(double latency)
void	recordHadamardProductCount(int count)
void	recordKeyNotFoundCount(int count)
void	recordKeySizeInByte(int keySize)
void	recordMisroutedStoreVersionRequest()
void	recordMultiChunkLargeValueCount(int multiChunkLargeValueCount)
void	recordReadComputeDeserializationLatency(double latency, boolean assembledMultiChunkLargeValue)
void	recordReadComputeEfficiency(double efficiency)
void	recordReadComputeLatency(double latency, boolean assembledMultiChunkLargeValue)
void	recordReadComputeSerializationLatency(double latency)
void	recordRequestKeyCount(int keyCount)
void	recordRequestSizeInBytes(int requestSizeInBytes)
void	recordResponseSize(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory, int size)
void	recordResponseSize(io.netty.handler.codec.http.HttpResponseStatus responseStatus, VeniceResponseStatusCategory veniceCategory, int size)
void	recordStorageExecutionHandlerSubmissionWaitTime(double submissionWaitTime)
void	recordStorageExecutionQueueLen(int len)
void	recordSuccessRequest(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory)
void	recordSuccessRequestAndLatency(io.netty.handler.codec.http.HttpResponseStatus responseStatus, VeniceResponseStatusCategory veniceCategory, double latency)
void	recordSuccessRequestLatency(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory, double latency)
void	recordValueSizeInByte(HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory, int valueSize)

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

ServerHttpRequestStats

public ServerHttpRequestStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 String clusterName,
 RequestType requestType,
 boolean isKeyValueProfilingEnabled,
 ServerHttpRequestStats totalStats,
 boolean isDaVinciClient,
 boolean readOtelStatsEnabled)

Method Details

recordSuccessRequest

public void recordSuccessRequest(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory)

recordErrorRequest

public void recordErrorRequest(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory)

recordSuccessRequestLatency

public void recordSuccessRequestLatency(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory,
 double latency)

recordErrorRequestLatency

public void recordErrorRequestLatency(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory,
 double latency)

recordSuccessRequestAndLatency

public void recordSuccessRequestAndLatency(io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 VeniceResponseStatusCategory veniceCategory,
 double latency)

recordErrorRequestAndLatency

public void recordErrorRequestAndLatency(io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 VeniceResponseStatusCategory veniceCategory,
 double latency)

recordDatabaseLookupLatency

public void recordDatabaseLookupLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordRequestKeyCount

public void recordRequestKeyCount(int keyCount)

recordKeyNotFoundCount

public void recordKeyNotFoundCount(int count)

recordRequestSizeInBytes

public void recordRequestSizeInBytes(int requestSizeInBytes)

recordMultiChunkLargeValueCount

public void recordMultiChunkLargeValueCount(int multiChunkLargeValueCount)

recordStorageExecutionHandlerSubmissionWaitTime

public void recordStorageExecutionHandlerSubmissionWaitTime(double submissionWaitTime)

recordStorageExecutionQueueLen

public void recordStorageExecutionQueueLen(int len)

recordReadComputeLatency

public void recordReadComputeLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordReadComputeDeserializationLatency

public void recordReadComputeDeserializationLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordReadComputeSerializationLatency

public void recordReadComputeSerializationLatency(double latency)

recordReadComputeEfficiency

public void recordReadComputeEfficiency(double efficiency)

recordDotProductCount

public void recordDotProductCount(int count)

recordCosineSimilarityCount

public void recordCosineSimilarityCount(int count)

recordHadamardProductCount

public void recordHadamardProductCount(int count)

recordCountOperatorCount

public void recordCountOperatorCount(int count)

recordEarlyTerminatedEarlyRequest

public void recordEarlyTerminatedEarlyRequest()

recordKeySizeInByte

public void recordKeySizeInByte(int keySize)

recordValueSizeInByte

public void recordValueSizeInByte(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory,
 int valueSize)

recordMisroutedStoreVersionRequest

public void recordMisroutedStoreVersionRequest()

recordFlushLatency

public void recordFlushLatency(double latency)

recordResponseSize

public void recordResponseSize(HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory,
 int size)

recordResponseSize

public void recordResponseSize(io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 VeniceResponseStatusCategory veniceCategory,
 int size)