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 a list of counters in order to mainly measure the performance of handling requests from Routers.

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, RequestType requestType, boolean isKeyValueProfilingEnabled, ServerHttpRequestStats totalStats, boolean isDaVinciClient)

Method Summary

Modifier and Type	Method	Description
void	recordCosineSimilarityCount(int count)
void	recordCountOperator(int count)
void	recordDatabaseLookupLatency(double latency, boolean assembledMultiChunkLargeValue)
void	recordDotProductCount(int count)
void	recordEarlyTerminatedEarlyRequest()
void	recordErrorRequest()
void	recordErrorRequestLatency(double latency)
void	recordFlushLatency(double latency)
void	recordHadamardProduct(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, boolean assembledMultiChunkLargeValue)
void	recordRequestFirstPartLatency(double latency)
void	recordRequestKeyCount(int keyCount)
void	recordRequestPartCount(int partCount)
void	recordRequestPartsInvokeDelayLatency(double latency)
void	recordRequestSecondPartLatency(double latency)
void	recordRequestSizeInBytes(int requestSizeInBytes)
void	recordResponseSize(int size)
void	recordStorageExecutionHandlerSubmissionWaitTime(double submissionWaitTime)
void	recordStorageExecutionQueueLen(int len)
void	recordSuccessRequest()
void	recordSuccessRequestKeyCount(int successKeyCount)
void	recordSuccessRequestLatency(double latency)
void	recordValueSizeInByte(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,
 RequestType requestType,
 boolean isKeyValueProfilingEnabled,
 ServerHttpRequestStats totalStats,
 boolean isDaVinciClient)

Method Details

recordSuccessRequest

public void recordSuccessRequest()

recordErrorRequest

public void recordErrorRequest()

recordSuccessRequestLatency

public void recordSuccessRequestLatency(double latency)

recordErrorRequestLatency

public void recordErrorRequestLatency(double latency)

recordDatabaseLookupLatency

public void recordDatabaseLookupLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordRequestKeyCount

public void recordRequestKeyCount(int keyCount)

recordSuccessRequestKeyCount

public void recordSuccessRequestKeyCount(int successKeyCount)

recordRequestSizeInBytes

public void recordRequestSizeInBytes(int requestSizeInBytes)

recordMultiChunkLargeValueCount

public void recordMultiChunkLargeValueCount(int multiChunkLargeValueCount)

recordStorageExecutionHandlerSubmissionWaitTime

public void recordStorageExecutionHandlerSubmissionWaitTime(double submissionWaitTime)

recordStorageExecutionQueueLen

public void recordStorageExecutionQueueLen(int len)

recordRequestFirstPartLatency

public void recordRequestFirstPartLatency(double latency)

recordRequestSecondPartLatency

public void recordRequestSecondPartLatency(double latency)

recordRequestPartsInvokeDelayLatency

public void recordRequestPartsInvokeDelayLatency(double latency)

recordRequestPartCount

public void recordRequestPartCount(int partCount)

recordReadComputeLatency

public void recordReadComputeLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordReadComputeDeserializationLatency

public void recordReadComputeDeserializationLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordReadComputeSerializationLatency

public void recordReadComputeSerializationLatency(double latency,
 boolean assembledMultiChunkLargeValue)

recordReadComputeEfficiency

public void recordReadComputeEfficiency(double efficiency)

recordDotProductCount

public void recordDotProductCount(int count)

recordCosineSimilarityCount

public void recordCosineSimilarityCount(int count)

recordHadamardProduct

public void recordHadamardProduct(int count)

recordCountOperator

public void recordCountOperator(int count)

recordEarlyTerminatedEarlyRequest

public void recordEarlyTerminatedEarlyRequest()

recordKeySizeInByte

public void recordKeySizeInByte(int keySize)

recordValueSizeInByte

public void recordValueSizeInByte(int valueSize)

recordMisroutedStoreVersionRequest

public void recordMisroutedStoreVersionRequest()

recordFlushLatency

public void recordFlushLatency(double latency)

recordResponseSize

public void recordResponseSize(int size)