Package com.linkedin.davinci.stats

Class ParticipantStoreConsumptionStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.davinci.stats.ParticipantStoreConsumptionStats

public class ParticipantStoreConsumptionStats
extends AbstractVeniceStats

Field Summary

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

DELIMITER

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	recordFailedInitialization()
void	recordHeartbeat()
void	recordKilledPushJobs()
void	recordKillPushJobFailedConsumption()
void	recordKillPushJobLatency(double latencyInMs)

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

ParticipantStoreConsumptionStats

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

Method Details

recordKillPushJobLatency

public void recordKillPushJobLatency(double latencyInMs)

recordKilledPushJobs

public void recordKilledPushJobs()

recordFailedInitialization

public void recordFailedInitialization()

recordKillPushJobFailedConsumption

public void recordKillPushJobFailedConsumption()

recordHeartbeat

public void recordHeartbeat()