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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	AdminConsumptionStats.AdminConsumptionOtelMetricEntity

Field Summary

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

DELIMITER

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	recordAdminConsumptionCycleDurationMs(double value)
void	recordAdminMessageDelegateLatency(double value, AdminMessageType adminMessageType)
void	recordAdminMessageMMLatency(double value, AdminMessageType adminMessageType)
void	recordAdminMessageProcessLatency(double value, AdminMessageType adminMessageType)
void	recordAdminMessageStartProcessingLatency(double value, AdminMessageType adminMessageType)
void	recordAdminMessagesWithFutureProtocolVersionCount()
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	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 clusterName)

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)

recordAdminMessageMMLatency

public void recordAdminMessageMMLatency(double value,
 AdminMessageType adminMessageType)

recordAdminMessageDelegateLatency

public void recordAdminMessageDelegateLatency(double value,
 AdminMessageType adminMessageType)

recordAdminMessageStartProcessingLatency

public void recordAdminMessageStartProcessingLatency(double value,
 AdminMessageType adminMessageType)

recordAdminMessageProcessLatency

public void recordAdminMessageProcessLatency(double value,
 AdminMessageType adminMessageType)

recordAdminMessageTotalLatency

public void recordAdminMessageTotalLatency(double value)

setAdminConsumptionOffsetLag

public void setAdminConsumptionOffsetLag(long adminConsumptionOffsetLag)

setMaxAdminConsumptionOffsetLag

public void setMaxAdminConsumptionOffsetLag(long maxAdminConsumptionOffsetLag)

recordAdminMessagesWithFutureProtocolVersionCount

public void recordAdminMessagesWithFutureProtocolVersionCount()