BasicConsumerStats (venice API)

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.davinci.consumer.stats.BasicConsumerStats

public class BasicConsumerStats extends AbstractVeniceStats

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats
DELIMITER
Constructor Summary

Constructors

Constructor

Description

BasicConsumerStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name)
Method Summary

Modifier and Type

Method

Description

void

recordLag(Long lag)

void

recordMaximumConsumingVersion(int version)

void

recordMinimumConsumingVersion(int version)

void

recordRecordsConsumed(int count)

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats
avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- BasicConsumerStats
  
  public BasicConsumerStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name)
Method Details
- recordMaximumConsumingVersion
  
  public void recordMaximumConsumingVersion(int version)
- recordMinimumConsumingVersion
  
  public void recordMinimumConsumingVersion(int version)
- recordLag
  
  public void recordLag(Long lag)
- recordRecordsConsumed
  
  public void recordRecordsConsumed(int count)