Package com.linkedin.davinci.listener.response

Interface ReadResponseStats

All Known Implementing Classes:
AbstractReadResponseStats, ComputeResponseStats, ComputeResponseStatsWithSizeProfiling, MultiGetResponseStatsWithSizeProfiling, MultiKeyResponseStats, NoOpReadResponseStats, SingleGetResponseStats
public interface ReadResponseStats
This class is used to accumulate stats associated with a read response. This container is purely for metrics-related work, and should not be used to store any state which is functionally required to achieve the service's goal. Contrast with ReadResponse, which wraps this one. The reason to keep them separate is that the state used for metrics has a slightly longer lifespan than that used for functional purposes, since we record metrics at the very end, after the response is sent back. This allows us to free up the functional state sooner, even while we need to hang on to the metrics state.

  • Method Details

    • getCurrentTimeInNanos

      long getCurrentTimeInNanos()

    • addDatabaseLookupLatency

      void addDatabaseLookupLatency(long startTimeInNanos)
      The implementer is responsible for doing the subtraction between the current time and the start time.
      Parameters:
      startTimeInNanos - the timestamp in nanoseconds of beginning of the period to measure.

    • addReadComputeLatency

      void addReadComputeLatency(double latency)

    • addReadComputeDeserializationLatency

      void addReadComputeDeserializationLatency(double latency)

    • addReadComputeSerializationLatency

      void addReadComputeSerializationLatency(double latency)

    • addKeySize

      void addKeySize(int size)

    • addValueSize

      void addValueSize(int size)

    • addReadComputeOutputSize

      void addReadComputeOutputSize(int size)

    • incrementDotProductCount

      void incrementDotProductCount(int count)

    • incrementCountOperatorCount

      void incrementCountOperatorCount(int count)

    • incrementCosineSimilarityCount

      void incrementCosineSimilarityCount(int count)

    • incrementHadamardProductCount

      void incrementHadamardProductCount(int count)

    • setStorageExecutionSubmissionWaitTime

      void setStorageExecutionSubmissionWaitTime(double storageExecutionSubmissionWaitTime)

    • setStorageExecutionQueueLen

      void setStorageExecutionQueueLen(int storageExecutionQueueLen)

    • incrementMultiChunkLargeValueCount

      void incrementMultiChunkLargeValueCount()