Package com.linkedin.davinci.stats

Class AggVersionedBlobTransferStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<BlobTransferStats,BlobTransferStatsReporter>

com.linkedin.davinci.stats.AggVersionedBlobTransferStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedBlobTransferStats
extends AbstractVeniceAggVersionedStats<BlobTransferStats,BlobTransferStatsReporter>

The store level stats for blob transfer

Field Summary

Fields inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

metadataRepository

Constructor Summary

Constructors

Constructor	Description
AggVersionedBlobTransferStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, VeniceServerConfig serverConfig)

Method Summary

Modifier and Type	Method	Description
void	recordBlobTransferFileReceiveThroughput(String storeName, int version, double throughput)	Record the blob transfer file send throughput
void	recordBlobTransferResponsesBasedOnBoostrapStatus(String storeName, int version, boolean isBlobTransferSuccess)	Record the blob transfer request count based on the bootstrap status
void	recordBlobTransferResponsesCount(String storeName, int version)	Record the blob transfer request count
void	recordBlobTransferTimeInSec(String storeName, int version, double timeInSec)	Record the blob transfer file receive throughput

Methods inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

addStore, getCurrentVersion, getFutureVersion, getStats, getTotalStats, handleStoreChanged, handleStoreCreated, handleStoreDeleted, isFutureVersion, loadAllStats, recordVersionedAndTotalStat, registerConditionalStats, updateStatsVersionInfo, updateTotalStats

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.linkedin.venice.meta.StoreDataChangedListener

handleStoreDeleted

Constructor Details

AggVersionedBlobTransferStats

public AggVersionedBlobTransferStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 VeniceServerConfig serverConfig)

Method Details

recordBlobTransferResponsesCount

public void recordBlobTransferResponsesCount(String storeName,
 int version)

Record the blob transfer request count

Parameters:

storeName -

version -

recordBlobTransferResponsesBasedOnBoostrapStatus

public void recordBlobTransferResponsesBasedOnBoostrapStatus(String storeName,
 int version,
 boolean isBlobTransferSuccess)

Record the blob transfer request count based on the bootstrap status

Parameters:

storeName - the store name

version - the version of the store

isBlobTransferSuccess - true if the blob transfer is successful, false otherwise

recordBlobTransferFileReceiveThroughput

public void recordBlobTransferFileReceiveThroughput(String storeName,
 int version,
 double throughput)

Record the blob transfer file send throughput

Parameters:

storeName - the store name

version - the version of the store

throughput - the throughput in MB/sec

recordBlobTransferTimeInSec

public void recordBlobTransferTimeInSec(String storeName,
 int version,
 double timeInSec)

Record the blob transfer file receive throughput

Parameters:

storeName - the store name

version - the version of the store

timeInSec - the time in seconds