Package com.linkedin.venice.controller.stats

Class AdminConsumptionStats

    • Constructor Detail

      • AdminConsumptionStats

        public AdminConsumptionStats​(io.tehuti.metrics.MetricsRepository metricsRepository,
                             java.lang.String name)

    • Method Detail

      • recordFailedAdminConsumption

        public void recordFailedAdminConsumption()
        Record the number of failed admin messages in the past one minute; if controller keeps retrying the admin messages, this metric will keep growing; this metric will be reset to 0 once the blocked admin message is processed.

      • recordFailedRetriableAdminConsumption

        public void recordFailedRetriableAdminConsumption()

      • recordAdminTopicDIVErrorReportCount

        public void recordAdminTopicDIVErrorReportCount()

      • recordAdminConsumptionCycleDurationMs

        public void recordAdminConsumptionCycleDurationMs​(double value)

      • recordPendingAdminMessagesCount

        public void recordPendingAdminMessagesCount​(double value)

      • recordStoresWithPendingAdminMessagesCount

        public void recordStoresWithPendingAdminMessagesCount​(double value)

      • setAdminConsumptionFailedOffset

        public void setAdminConsumptionFailedOffset​(long adminConsumptionFailedOffset)

      • recordAdminMessageMMLatency

        public void recordAdminMessageMMLatency​(double value)

      • recordAdminMessageDelegateLatency

        public void recordAdminMessageDelegateLatency​(double value)

      • recordAdminMessageStartProcessingLatency

        public void recordAdminMessageStartProcessingLatency​(double value)

      • recordAdminMessageProcessLatency

        public void recordAdminMessageProcessLatency​(double value)

      • recordAdminMessageAddVersionProcessLatency

        public void recordAdminMessageAddVersionProcessLatency​(double value)

      • recordAdminMessageTotalLatency

        public void recordAdminMessageTotalLatency​(double value)

      • setAdminConsumptionCheckpointOffset

        public void setAdminConsumptionCheckpointOffset​(long adminConsumptionCheckpointOffset)

      • registerAdminConsumptionCheckpointOffset

        public void registerAdminConsumptionCheckpointOffset()
        Lazily register the checkpoint offset metric after knowing the latest checkpoint offset, so that restarting the controller node will not result in the metric value dipping to 0.

      • setAdminConsumptionOffsetLag

        public void setAdminConsumptionOffsetLag​(long adminConsumptionOffsetLag)

      • setMaxAdminConsumptionOffsetLag

        public void setMaxAdminConsumptionOffsetLag​(long maxAdminConsumptionOffsetLag)