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	recordFailedKillPushJob(String storeName)	Records a push job kill attempt that failed (killConsumptionTask returned false).
void	recordHeartbeat()
void	recordKilledPushJobs(String storeName)	Records a successful push job kill on the storage node.
void	recordKillPushJobFailedConsumption(String storeName)	Records an exception thrown during consumption of the participant store, specifically for KillPushJob records.
void	recordKillPushJobLatency(String storeName, double latencyInMs)	Records the latency in ms from when the kill signal was generated in the child controller to when the kill is performed on the storage node.

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

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotal, 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)

Parameters:

clusterName - the cluster that this server belongs to. Used as the VENICE_CLUSTER_NAME base dimension on all OTel metrics and as the Tehuti sensor name prefix.

Method Details

recordKillPushJobLatency

public void recordKillPushJobLatency(String storeName,
 double latencyInMs)

Records the latency in ms from when the kill signal was generated in the child controller to when the kill is performed on the storage node.

recordKilledPushJobs

public void recordKilledPushJobs(String storeName)

Records a successful push job kill on the storage node. Tehuti + OTel (SUCCESS).

recordFailedKillPushJob

public void recordFailedKillPushJob(String storeName)

Records a push job kill attempt that failed (killConsumptionTask returned false). OTel-only (FAIL).

recordFailedInitialization

public void recordFailedInitialization()

recordKillPushJobFailedConsumption

public void recordKillPushJobFailedConsumption(String storeName)

Records an exception thrown during consumption of the participant store, specifically for KillPushJob records.

recordHeartbeat

public void recordHeartbeat()