Class BasicConsumerStats

java.lang.Object
com.linkedin.venice.stats.AbstractVeniceStats
com.linkedin.davinci.consumer.stats.BasicConsumerStats

public class BasicConsumerStats extends AbstractVeniceStats
  • Field Details

  • Constructor Details

    • BasicConsumerStats

      public BasicConsumerStats(io.tehuti.metrics.MetricsRepository metricsRepository, String consumerName, String storeName)
  • Method Details

    • emitCurrentConsumingVersionMetrics

      public void emitCurrentConsumingVersionMetrics(int minVersion, int maxVersion)
    • emitHeartBeatDelayMetrics

      public void emitHeartBeatDelayMetrics(long heartBeatDelay)
      This won't be emitted by DVRT CDC, since it doesn't have context into heartbeat delay.
    • emitRecordsConsumedCountMetrics

      public void emitRecordsConsumedCountMetrics(int count)
    • emitPollCountMetrics

      public void emitPollCountMetrics(VeniceResponseStatusCategory responseStatusCategory)
    • emitVersionSwapCountMetrics

      public void emitVersionSwapCountMetrics(VeniceResponseStatusCategory responseStatusCategory)
    • emitChunkedRecordCountMetrics

      public void emitChunkedRecordCountMetrics(VeniceResponseStatusCategory responseStatusCategory)
      This won't be emitted by DVRT CDC, since it doesn't have context into chunked records.
    • getBaseAttributes

      public io.opentelemetry.api.common.Attributes getBaseAttributes()