Class AdminConsumptionStats
java.lang.Object
com.linkedin.venice.stats.AbstractVeniceStats
com.linkedin.venice.controller.stats.AdminConsumptionStats
-
Field Summary
Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats
DELIMITER -
Constructor Summary
ConstructorsConstructorDescriptionAdminConsumptionStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name) -
Method Summary
Modifier and TypeMethodDescriptionvoidrecordAdminConsumptionCycleDurationMs(double value) voidrecordAdminMessageAddVersionProcessLatency(double value) voidrecordAdminMessageDelegateLatency(double value) voidrecordAdminMessageMMLatency(double value) voidrecordAdminMessageProcessLatency(double value) voidrecordAdminMessageStartProcessingLatency(double value) voidrecordAdminMessageTotalLatency(double value) voidvoidRecord 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.voidvoidrecordPendingAdminMessagesCount(double value) voidrecordStoresWithPendingAdminMessagesCount(double value) voidsetAdminConsumptionFailedPosition(PubSubPosition adminConsumptionFailedPosition) voidsetAdminConsumptionOffsetLag(long adminConsumptionOffsetLag) voidsetMaxAdminConsumptionOffsetLag(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
-
Constructor Details
-
AdminConsumptionStats
-
-
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) -
setAdminConsumptionFailedPosition
-
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) -
setAdminConsumptionOffsetLag
public void setAdminConsumptionOffsetLag(long adminConsumptionOffsetLag) -
setMaxAdminConsumptionOffsetLag
public void setMaxAdminConsumptionOffsetLag(long maxAdminConsumptionOffsetLag)
-