Class HostLevelIngestionStats


  • public class HostLevelIngestionStats
    extends AbstractVeniceStats
    This class contains stats for stats on the storage node host level. Stats inside this class can either: (1) Total only: The stat indicate total number of all the stores on this host. (2) Per store only: The stat is registered for each store on this host. (3) Per store and total: The stat is registered for each store on this host and the total number for this host.
    • Constructor Detail

      • HostLevelIngestionStats

        public HostLevelIngestionStats​(io.tehuti.metrics.MetricsRepository metricsRepository,
                                       VeniceServerConfig serverConfig,
                                       java.lang.String storeName,
                                       HostLevelIngestionStats totalStats,
                                       java.util.Map<java.lang.String,​StoreIngestionTask> ingestionTaskMap,
                                       Time time)
        Parameters:
        totalStats - the total stats singleton instance, or null if we are constructing the total stats
    • Method Detail

      • recordTotalBytesConsumed

        public void recordTotalBytesConsumed​(long bytes)
        Record a host-level byte consumption rate across all store versions
      • recordTotalRecordsConsumed

        public void recordTotalRecordsConsumed()
        Record a host-level record consumption rate across all store versions
      • recordTotalBytesReadFromKafkaAsUncompressedSize

        public void recordTotalBytesReadFromKafkaAsUncompressedSize​(long bytes)
      • recordStorageQuotaUsed

        public void recordStorageQuotaUsed​(double quotaUsed,
                                           long currentTimeMs)
      • recordDiskQuotaAllowed

        public void recordDiskQuotaAllowed​(long quotaAllowed,
                                           long currentTimeMs)
      • recordConsumerRecordsQueuePutLatency

        public void recordConsumerRecordsQueuePutLatency​(double latency,
                                                         long currentTimeMs)
      • recordViewProducerLatency

        public void recordViewProducerLatency​(double latency)
      • recordUnexpectedMessage

        public void recordUnexpectedMessage()
      • recordInconsistentStoreMetadata

        public void recordInconsistentStoreMetadata()
      • recordKeySize

        public void recordKeySize​(long bytes,
                                  long currentTimeMs)
      • recordValueSize

        public void recordValueSize​(long bytes,
                                    long currentTimeMs)
      • recordIngestionFailure

        public void recordIngestionFailure()
      • recordLeaderProducerSynchronizeLatency

        public void recordLeaderProducerSynchronizeLatency​(double latency)
      • recordWriteComputeLookUpLatency

        public void recordWriteComputeLookUpLatency​(double latency)
      • recordIngestionValueBytesLookUpLatency

        public void recordIngestionValueBytesLookUpLatency​(double latency,
                                                           long currentTime)
      • recordIngestionValueBytesCacheHitCount

        public void recordIngestionValueBytesCacheHitCount​(long currentTime)
      • recordIngestionReplicationMetadataLookUpLatency

        public void recordIngestionReplicationMetadataLookUpLatency​(double latency,
                                                                    long currentTimeMs)
      • recordIngestionActiveActivePutLatency

        public void recordIngestionActiveActivePutLatency​(double latency)
      • recordIngestionActiveActiveUpdateLatency

        public void recordIngestionActiveActiveUpdateLatency​(double latency)
      • recordIngestionActiveActiveDeleteLatency

        public void recordIngestionActiveActiveDeleteLatency​(double latency)
      • recordWriteComputeUpdateLatency

        public void recordWriteComputeUpdateLatency​(double latency)
      • recordProcessConsumerActionLatency

        public void recordProcessConsumerActionLatency​(double latency)
      • recordCheckLongRunningTasksLatency

        public void recordCheckLongRunningTasksLatency​(double latency)
      • recordStorageEnginePutLatency

        public void recordStorageEnginePutLatency​(double latency,
                                                  long currentTimeMs)
      • recordStorageEngineDeleteLatency

        public void recordStorageEngineDeleteLatency​(double latency,
                                                     long currentTimeMs)
      • recordWriteComputeCacheHitCount

        public void recordWriteComputeCacheHitCount()
      • recordIngestionReplicationMetadataCacheHitCount

        public void recordIngestionReplicationMetadataCacheHitCount​(long currentTimeMs)
      • recordUpdateIgnoredDCR

        public void recordUpdateIgnoredDCR()
      • recordTombstoneCreatedDCR

        public void recordTombstoneCreatedDCR()
      • recordTotalLeaderBytesConsumed

        public void recordTotalLeaderBytesConsumed​(long bytes)
      • recordTotalLeaderRecordsConsumed

        public void recordTotalLeaderRecordsConsumed()
      • recordTotalFollowerBytesConsumed

        public void recordTotalFollowerBytesConsumed​(long bytes)
      • recordTotalFollowerRecordsConsumed

        public void recordTotalFollowerRecordsConsumed()
      • recordTotalRegionHybridBytesConsumed

        public void recordTotalRegionHybridBytesConsumed​(int regionId,
                                                         long bytes,
                                                         long currentTimeMs)
      • recordTotalLeaderBytesProduced

        public void recordTotalLeaderBytesProduced​(long bytes)
      • recordTotalLeaderRecordsProduced

        public void recordTotalLeaderRecordsProduced​(int count)
      • recordChecksumVerificationFailure

        public void recordChecksumVerificationFailure()
      • recordTimestampRegressionDCRError

        public void recordTimestampRegressionDCRError()
      • recordOffsetRegressionDCRError

        public void recordOffsetRegressionDCRError()