Package com.linkedin.davinci.stats

Class IngestionStatsReporter

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.davinci.stats.AbstractVeniceStatsReporter<IngestionStats>

com.linkedin.davinci.stats.IngestionStatsReporter

public class IngestionStatsReporter
extends AbstractVeniceStatsReporter<IngestionStats>

This class is the reporting class for stats class IngestionStats. Metrics reporting logics are registered into MetricsRepository here and send out to external metrics collection/visualization system.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	IngestionStatsReporter.IngestionStatsGauge

Field Summary

Fields inherited from class com.linkedin.davinci.stats.AbstractVeniceStatsReporter

storeName

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats

DELIMITER

Constructor Summary

Constructors

Constructor	Description
IngestionStatsReporter(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, String clusterName)

Method Summary

Modifier and Type	Method	Description
protected void	registerConditionalStats()
protected void	registerLatencySensor(String sensorBaseName, Function<IngestionStats,WritePathLatencySensor> sensorFunction)
protected void	registerStats()

Methods inherited from class com.linkedin.davinci.stats.AbstractVeniceStatsReporter

getStats, setStats, unregisterStats

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

IngestionStatsReporter

public IngestionStatsReporter(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 String clusterName)

Method Details

registerStats

protected void registerStats()

Specified by:

registerStats in class AbstractVeniceStatsReporter<IngestionStats>

registerConditionalStats

protected void registerConditionalStats()

Overrides:

registerConditionalStats in class AbstractVeniceStatsReporter<IngestionStats>

registerLatencySensor

protected void registerLatencySensor(String sensorBaseName,
 Function<IngestionStats,WritePathLatencySensor> sensorFunction)