Package com.linkedin.davinci.stats

Class DIVStats

  • public class DIVStats
extends java.lang.Object
    This class contains stats for DIV. The stat class is used in VeniceVersionedStats to serve for a single store version or total of all store versions. This class does not contain reporting logic as reporting is done by the DIVStatsReporter.

    • Constructor Detail

      • DIVStats

        public DIVStats()

    • Method Detail

      • getDuplicateMsg

        public long getDuplicateMsg()

      • recordDuplicateMsg

        public void recordDuplicateMsg()

      • setDuplicateMsg

        public void setDuplicateMsg​(long count)

      • getMissingMsg

        public long getMissingMsg()

      • recordMissingMsg

        public void recordMissingMsg()

      • setMissingMsg

        public void setMissingMsg​(long count)

      • getCorruptedMsg

        public long getCorruptedMsg()

      • recordCorruptedMsg

        public void recordCorruptedMsg()

      • setCorruptedMsg

        public void setCorruptedMsg​(long count)

      • getSuccessMsg

        public long getSuccessMsg()

      • recordSuccessMsg

        public void recordSuccessMsg()

      • setSuccessMsg

        public void setSuccessMsg​(long count)

      • recordProducerSourceBrokerLatencyMs

        public void recordProducerSourceBrokerLatencyMs​(double value,
                                                long currentTimeMs)

      • recordSourceBrokerLeaderConsumerLatencyMs

        public void recordSourceBrokerLeaderConsumerLatencyMs​(double value,
                                                      long currentTimeMs)

      • getSourceBrokerLeaderConsumerLatencySensor

        public WritePathLatencySensor getSourceBrokerLeaderConsumerLatencySensor()

      • recordProducerLocalBrokerLatencyMs

        public void recordProducerLocalBrokerLatencyMs​(double value,
                                               long currentTimeMs)

      • recordLocalBrokerFollowerConsumerLatencyMs

        public void recordLocalBrokerFollowerConsumerLatencyMs​(double value,
                                                       long currentTimeMs)

      • getLocalBrokerFollowerConsumerLatencySensor

        public WritePathLatencySensor getLocalBrokerFollowerConsumerLatencySensor()

      • recordLeaderProducerCompletionLatencyMs

        public void recordLeaderProducerCompletionLatencyMs​(double value,
                                                    long currentTimeMs)

      • getLeaderProducerCompletionLatencySensor

        public WritePathLatencySensor getLeaderProducerCompletionLatencySensor()

      • recordLeaderDIVCompletionLatencyMs

        public void recordLeaderDIVCompletionLatencyMs​(double value,
                                               long currentTimeMs)

      • recordBenignLeaderOffsetRewind

        public void recordBenignLeaderOffsetRewind()

      • getBenignLeaderOffsetRewindCount

        public long getBenignLeaderOffsetRewindCount()

      • setBenignLeaderOffsetRewindCount

        public void setBenignLeaderOffsetRewindCount​(long count)

      • recordPotentiallyLossyLeaderOffsetRewind

        public void recordPotentiallyLossyLeaderOffsetRewind()

      • getPotentiallyLossyLeaderOffsetRewindCount

        public long getPotentiallyLossyLeaderOffsetRewindCount()

      • setPotentiallyLossyLeaderOffsetRewindCount

        public void setPotentiallyLossyLeaderOffsetRewindCount​(long count)

      • recordLeaderProducerFailure

        public void recordLeaderProducerFailure()

      • getLeaderProducerFailure

        public long getLeaderProducerFailure()

      • setLeaderProducerFailure

        public void setLeaderProducerFailure​(long count)

      • recordBenignLeaderProducerFailure

        public void recordBenignLeaderProducerFailure()

      • getBenignLeaderProducerFailure

        public long getBenignLeaderProducerFailure()

      • setBenignLeaderProducerFailure

        public void setBenignLeaderProducerFailure​(long count)