Class BasicConsumerStats
java.lang.Object
com.linkedin.venice.stats.AbstractVeniceStats
com.linkedin.davinci.consumer.stats.BasicConsumerStats
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enum
static enum
Metric names for tehuti metrics used in this class. -
Field Summary
FieldsFields inherited from class com.linkedin.venice.stats.AbstractVeniceStats
DELIMITER
-
Constructor Summary
ConstructorsConstructorDescriptionBasicConsumerStats
(io.tehuti.metrics.MetricsRepository metricsRepository, String consumerName, String storeName) -
Method Summary
Modifier and TypeMethodDescriptionvoid
emitChunkedRecordCountMetrics
(VeniceResponseStatusCategory responseStatusCategory) This won't be emitted by DVRT CDC, since it doesn't have context into chunked records.void
emitCurrentConsumingVersionMetrics
(int minVersion, int maxVersion) void
emitHeartBeatDelayMetrics
(long heartBeatDelay) This won't be emitted by DVRT CDC, since it doesn't have context into heartbeat delay.void
emitPollCountMetrics
(VeniceResponseStatusCategory responseStatusCategory) void
emitRecordsConsumedCountMetrics
(int count) void
emitVersionSwapCountMetrics
(VeniceResponseStatusCategory responseStatusCategory) io.opentelemetry.api.common.Attributes
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
-
Field Details
-
CONSUMER_METRIC_ENTITIES
-
-
Constructor Details
-
BasicConsumerStats
-
-
Method Details
-
emitCurrentConsumingVersionMetrics
public void emitCurrentConsumingVersionMetrics(int minVersion, int maxVersion) -
emitHeartBeatDelayMetrics
public void emitHeartBeatDelayMetrics(long heartBeatDelay) This won't be emitted by DVRT CDC, since it doesn't have context into heartbeat delay. -
emitRecordsConsumedCountMetrics
public void emitRecordsConsumedCountMetrics(int count) -
emitPollCountMetrics
-
emitVersionSwapCountMetrics
-
emitChunkedRecordCountMetrics
This won't be emitted by DVRT CDC, since it doesn't have context into chunked records. -
getBaseAttributes
public io.opentelemetry.api.common.Attributes getBaseAttributes()
-