Package com.linkedin.venice.controller.stats

Class AdminConsumptionStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.controller.stats.AdminConsumptionStats

public class AdminConsumptionStats
extends AbstractVeniceStats

Field Summary

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

DELIMITER

Constructor Summary

Constructors

Constructor	Description
AdminConsumptionStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name)

Method Summary

Modifier and Type	Method	Description
void	recordAdminConsumptionCycleDurationMs(double value)
void	recordAdminMessageAddVersionProcessLatency(double value)
void	recordAdminMessageDelegateLatency(double value)
void	recordAdminMessageMMLatency(double value)
void	recordAdminMessageProcessLatency(double value)
void	recordAdminMessageStartProcessingLatency(double value)
void	recordAdminMessageTotalLatency(double value)
void	recordAdminTopicDIVErrorReportCount()
void	recordFailedAdminConsumption()	Record the number of failed admin messages in the past one minute; if controller keeps retrying the admin messages, this metric will keep growing; this metric will be reset to 0 once the blocked admin message is processed.
void	recordFailedRetriableAdminConsumption()
void	recordPendingAdminMessagesCount(double value)
void	recordStoresWithPendingAdminMessagesCount(double value)
void	registerAdminConsumptionCheckpointOffset()	Lazily register the checkpoint offset metric after knowing the latest checkpoint offset, so that restarting the controller node will not result in the metric value dipping to 0.
void	setAdminConsumptionCheckpointOffset(long adminConsumptionCheckpointOffset)
void	setAdminConsumptionFailedOffset(long adminConsumptionFailedOffset)
void	setAdminConsumptionOffsetLag(long adminConsumptionOffsetLag)
void	setMaxAdminConsumptionOffsetLag(long maxAdminConsumptionOffsetLag)

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

AdminConsumptionStats

public AdminConsumptionStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String name)

Method Details

recordFailedAdminConsumption

public void recordFailedAdminConsumption()

Record the number of failed admin messages in the past one minute; if controller keeps retrying the admin messages, this metric will keep growing; this metric will be reset to 0 once the blocked admin message is processed.

recordFailedRetriableAdminConsumption

public void recordFailedRetriableAdminConsumption()

recordAdminTopicDIVErrorReportCount

public void recordAdminTopicDIVErrorReportCount()

recordAdminConsumptionCycleDurationMs

public void recordAdminConsumptionCycleDurationMs(double value)

recordPendingAdminMessagesCount

public void recordPendingAdminMessagesCount(double value)

recordStoresWithPendingAdminMessagesCount

public void recordStoresWithPendingAdminMessagesCount(double value)

setAdminConsumptionFailedOffset

public void setAdminConsumptionFailedOffset(long adminConsumptionFailedOffset)

recordAdminMessageMMLatency

public void recordAdminMessageMMLatency(double value)

recordAdminMessageDelegateLatency

public void recordAdminMessageDelegateLatency(double value)

recordAdminMessageStartProcessingLatency

public void recordAdminMessageStartProcessingLatency(double value)

recordAdminMessageProcessLatency

public void recordAdminMessageProcessLatency(double value)

recordAdminMessageAddVersionProcessLatency

public void recordAdminMessageAddVersionProcessLatency(double value)

recordAdminMessageTotalLatency

public void recordAdminMessageTotalLatency(double value)

setAdminConsumptionCheckpointOffset

public void setAdminConsumptionCheckpointOffset(long adminConsumptionCheckpointOffset)

registerAdminConsumptionCheckpointOffset

public void registerAdminConsumptionCheckpointOffset()

Lazily register the checkpoint offset metric after knowing the latest checkpoint offset, so that restarting the controller node will not result in the metric value dipping to 0.

setAdminConsumptionOffsetLag

public void setAdminConsumptionOffsetLag(long adminConsumptionOffsetLag)

setMaxAdminConsumptionOffsetLag

public void setMaxAdminConsumptionOffsetLag(long maxAdminConsumptionOffsetLag)