Class AdminConsumptionStats

java.lang.Object
com.linkedin.venice.stats.AbstractVeniceStats
com.linkedin.venice.controller.stats.AdminConsumptionStats

public class AdminConsumptionStats extends AbstractVeniceStats
  • Constructor Details

    • AdminConsumptionStats

      public AdminConsumptionStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name)
  • Method Details

    • 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)
    • setAdminConsumptionFailedPosition

      public void setAdminConsumptionFailedPosition(PubSubPosition adminConsumptionFailedPosition)
    • 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)
    • setAdminConsumptionOffsetLag

      public void setAdminConsumptionOffsetLag(long adminConsumptionOffsetLag)
    • setMaxAdminConsumptionOffsetLag

      public void setMaxAdminConsumptionOffsetLag(long maxAdminConsumptionOffsetLag)