Package com.linkedin.davinci.stats

Class BlobTransferStats

java.lang.Object
com.linkedin.davinci.stats.BlobTransferStats
public class BlobTransferStats extends Object
Class that exposes stats related to blob transfers

  • Field Details

    • BLOB_TRANSFER_TOTAL_NUM_RESPONSES

      protected static final String BLOB_TRANSFER_TOTAL_NUM_RESPONSES
      See Also:

    • BLOB_TRANSFER_SUCCESSFUL_NUM_RESPONSES

      protected static final String BLOB_TRANSFER_SUCCESSFUL_NUM_RESPONSES
      See Also:

    • BLOB_TRANSFER_FAILED_NUM_RESPONSES

      protected static final String BLOB_TRANSFER_FAILED_NUM_RESPONSES
      See Also:

    • BLOB_TRANSFER_DAVINCI_PEER_SUCCESSFUL_NUM_REQUESTS

      protected static final String BLOB_TRANSFER_DAVINCI_PEER_SUCCESSFUL_NUM_REQUESTS
      See Also:

    • BLOB_TRANSFER_DAVINCI_PEER_FAILED_NUM_REQUESTS

      protected static final String BLOB_TRANSFER_DAVINCI_PEER_FAILED_NUM_REQUESTS
      See Also:

    • BLOB_TRANSFER_VENICE_SERVER_SUCCESSFUL_NUM_REQUESTS

      protected static final String BLOB_TRANSFER_VENICE_SERVER_SUCCESSFUL_NUM_REQUESTS
      See Also:

    • BLOB_TRANSFER_VENICE_SERVER_FAILED_NUM_REQUESTS

      protected static final String BLOB_TRANSFER_VENICE_SERVER_FAILED_NUM_REQUESTS
      See Also:

    • BLOB_TRANSFER_VERSION_TOPIC_FALLBACK_NO_CANDIDATES

      protected static final String BLOB_TRANSFER_VERSION_TOPIC_FALLBACK_NO_CANDIDATES
      See Also:

    • BLOB_TRANSFER_VERSION_TOPIC_FALLBACK_ALL_HOSTS_FAILED

      protected static final String BLOB_TRANSFER_VERSION_TOPIC_FALLBACK_ALL_HOSTS_FAILED
      See Also:

    • BLOB_TRANSFER_THROUGHPUT

      protected static final String BLOB_TRANSFER_THROUGHPUT
      See Also:

    • BLOB_TRANSFER_TIME

      protected static final String BLOB_TRANSFER_TIME
      See Also:

    • BLOB_TRANSFER_BYTES_RECEIVED

      protected static final String BLOB_TRANSFER_BYTES_RECEIVED
      See Also:

    • BLOB_TRANSFER_BYTES_SENT

      protected static final String BLOB_TRANSFER_BYTES_SENT
      See Also:

  • Constructor Details

    • BlobTransferStats

      public BlobTransferStats()

    • BlobTransferStats

      public BlobTransferStats(Time time)

  • Method Details

    • recordBlobTransferResponsesCount

      public void recordBlobTransferResponsesCount()
      Update the blob transfer response stats regardless the response status.

    • recordBlobTransferResponsesBasedOnBoostrapStatus

      public void recordBlobTransferResponsesBasedOnBoostrapStatus(boolean isblobTransferSuccess)
      When receiving a blob transfer response from other remote host, based on the blob transfer bootstrap status, bump the successful or failed responses amount.
      Parameters:
      isblobTransferSuccess - the status of the blob transfer response, true for success, false for failure

    • recordBlobTransferRequest

      public void recordBlobTransferRequest(VeniceBlobTransferSource source, VeniceResponseStatusCategory status)

    • recordBlobTransferVersionTopicFallback

      public void recordBlobTransferVersionTopicFallback(VeniceBlobTransferFallbackReason reason)

    • recordBlobTransferFileReceiveThroughput

      public void recordBlobTransferFileReceiveThroughput(double throughput)
      Record the blob transfer file receive throughput.
      Parameters:
      throughput - in MB/sec

    • recordBlobTransferTimeInSec

      public void recordBlobTransferTimeInSec(double time)
      Record the blob transfer time.
      Parameters:
      time - the time in second

    • getBlobTransferTotalNumResponses

      public double getBlobTransferTotalNumResponses()
      All get methods to get the sensor value
      Returns:
      the sensor value

    • getBlobTransferSuccessNumResponses

      public double getBlobTransferSuccessNumResponses()

    • getBlobTransferFailedNumResponses

      public double getBlobTransferFailedNumResponses()

    • getBlobTransferRequestCount

      public double getBlobTransferRequestCount(VeniceBlobTransferSource source, VeniceResponseStatusCategory status)

    • getBlobTransferVersionTopicFallbackCount

      public double getBlobTransferVersionTopicFallbackCount(VeniceBlobTransferFallbackReason reason)

    • getBlobTransferFileReceiveThroughput

      public double getBlobTransferFileReceiveThroughput()

    • getBlobTransferTime

      public double getBlobTransferTime()

    • getBlobTransferBytesReceived

      public double getBlobTransferBytesReceived()

    • recordBlobTransferBytesReceived

      public void recordBlobTransferBytesReceived(long value)

    • getBlobTransferBytesSent

      public double getBlobTransferBytesSent()

    • recordBlobTransferBytesSent

      public void recordBlobTransferBytesSent(long value)