Package com.linkedin.davinci.stats.ingestion

Class NoOpIngestionOtelStats

java.lang.Object

com.linkedin.davinci.stats.ingestion.IngestionOtelStats

com.linkedin.davinci.stats.ingestion.NoOpIngestionOtelStats

public class NoOpIngestionOtelStats
extends IngestionOtelStats

A no-op implementation of IngestionOtelStats that discards all recording calls. Used when ingestion OTel stats are disabled via config so that all recording call sites in AggVersionedIngestionStats stay as simple unconditional calls instead of being wrapped in null checks. This is a readability/maintainability choice, not a performance one — JIT would optimize null checks equally well via constant-folding of the final boolean guard in getIngestionOtelStats().

Field Summary

Fields

Modifier and Type	Field	Description
static final NoOpIngestionOtelStats	INSTANCE	Singleton instance — safe to share since all methods are stateless no-ops.

Method Summary

Modifier and Type	Method	Description
void	close()	Cleans up all per-version state for this store.
boolean	emitOtelMetrics()
void	recordBatchProcessingRequestCount(int version, long value)
void	recordBatchProcessingRequestErrorCount(int version, long value)
void	recordBatchProcessingRequestRecordCount(int version, long value)
void	recordBatchProcessingRequestTime(int version, double latencyMs)
void	recordBytesConsumed(int version, ReplicaType replicaType, long value)
void	recordBytesProduced(int version, ReplicaType replicaType, long value)
void	recordDcrEventCount(int version, VeniceDCREvent event, long value)
void	recordDcrTotalCount(int version, long value)
void	recordDuplicateKeyUpdateCount(int version, long value)
void	recordIdleTime(int version, long idleTimeMs)
void	recordIngestionTime(int version, double latencyMs)
void	recordPreprocessingInternalTime(int version, double latencyMs)
void	recordPreprocessingLeaderTime(int version, double latencyMs)
void	recordProducerCallbackTime(int version, ReplicaType replicaType, double latencyMs)
void	recordProducerTime(int version, double latencyMs)
void	recordRecordsConsumed(int version, ReplicaType replicaType, long value)
void	recordRecordsProduced(int version, ReplicaType replicaType, long value)
void	recordSubscribePrepTime(int version, double latencyMs)
void	recordTimeBetweenComponents(int version, VeniceIngestionSourceComponent sourceComponent, VeniceIngestionDestinationComponent destComponent, double latencyMs)
void	removeIngestionTask(int version)	Removes the StoreIngestionTask and associated per-version state for a specific version.
void	setIngestionTask(int version, StoreIngestionTask task)	Sets the StoreIngestionTask for a specific version.
void	setIngestionTaskPushTimeoutGauge(int version, int value)
void	updateVersionInfo(int currentVersion, int futureVersion)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final NoOpIngestionOtelStats INSTANCE

Singleton instance — safe to share since all methods are stateless no-ops.

Method Details

setIngestionTask

public void setIngestionTask(int version,
 StoreIngestionTask task)

Description copied from class: IngestionOtelStats

Sets the StoreIngestionTask for a specific version. This enables async gauge metrics to access task data.

Overrides:

setIngestionTask in class IngestionOtelStats

removeIngestionTask

public void removeIngestionTask(int version)

Description copied from class: IngestionOtelStats

Removes the StoreIngestionTask and associated per-version state for a specific version.

Overrides:

removeIngestionTask in class IngestionOtelStats

close

public void close()

Description copied from class: IngestionOtelStats

Cleans up all per-version state for this store. Call this when the store is being deleted.

Note: OTel instruments (counters, histograms, async gauges) are NOT deregistered here. OpenTelemetry SDK does not support deregistering individual instruments from a Meter. The instruments will remain registered but will report zero/stale values until the MeterProvider is shut down.

Overrides:

close in class IngestionOtelStats

setIngestionTaskPushTimeoutGauge

public void setIngestionTaskPushTimeoutGauge(int version,
 int value)

Overrides:

setIngestionTaskPushTimeoutGauge in class IngestionOtelStats

recordIdleTime

public void recordIdleTime(int version,
 long idleTimeMs)

Overrides:

recordIdleTime in class IngestionOtelStats

emitOtelMetrics

public boolean emitOtelMetrics()

Overrides:

emitOtelMetrics in class IngestionOtelStats

updateVersionInfo

public void updateVersionInfo(int currentVersion,
 int futureVersion)

Overrides:

updateVersionInfo in class IngestionOtelStats

recordSubscribePrepTime

public void recordSubscribePrepTime(int version,
 double latencyMs)

Overrides:

recordSubscribePrepTime in class IngestionOtelStats

recordIngestionTime

public void recordIngestionTime(int version,
 double latencyMs)

Overrides:

recordIngestionTime in class IngestionOtelStats

recordPreprocessingLeaderTime

public void recordPreprocessingLeaderTime(int version,
 double latencyMs)

Overrides:

recordPreprocessingLeaderTime in class IngestionOtelStats

recordPreprocessingInternalTime

public void recordPreprocessingInternalTime(int version,
 double latencyMs)

Overrides:

recordPreprocessingInternalTime in class IngestionOtelStats

recordProducerTime

public void recordProducerTime(int version,
 double latencyMs)

Overrides:

recordProducerTime in class IngestionOtelStats

recordBatchProcessingRequestCount

public void recordBatchProcessingRequestCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestCount in class IngestionOtelStats

recordBatchProcessingRequestRecordCount

public void recordBatchProcessingRequestRecordCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestRecordCount in class IngestionOtelStats

recordBatchProcessingRequestErrorCount

public void recordBatchProcessingRequestErrorCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestErrorCount in class IngestionOtelStats

recordBatchProcessingRequestTime

public void recordBatchProcessingRequestTime(int version,
 double latencyMs)

Overrides:

recordBatchProcessingRequestTime in class IngestionOtelStats

recordDcrTotalCount

public void recordDcrTotalCount(int version,
 long value)

Overrides:

recordDcrTotalCount in class IngestionOtelStats

recordDuplicateKeyUpdateCount

public void recordDuplicateKeyUpdateCount(int version,
 long value)

Overrides:

recordDuplicateKeyUpdateCount in class IngestionOtelStats

recordRecordsConsumed

public void recordRecordsConsumed(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordRecordsConsumed in class IngestionOtelStats

recordRecordsProduced

public void recordRecordsProduced(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordRecordsProduced in class IngestionOtelStats

recordBytesConsumed

public void recordBytesConsumed(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordBytesConsumed in class IngestionOtelStats

recordBytesProduced

public void recordBytesProduced(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordBytesProduced in class IngestionOtelStats

recordProducerCallbackTime

public void recordProducerCallbackTime(int version,
 ReplicaType replicaType,
 double latencyMs)

Overrides:

recordProducerCallbackTime in class IngestionOtelStats

recordDcrEventCount

public void recordDcrEventCount(int version,
 VeniceDCREvent event,
 long value)

Overrides:

recordDcrEventCount in class IngestionOtelStats

recordTimeBetweenComponents

public void recordTimeBetweenComponents(int version,
 VeniceIngestionSourceComponent sourceComponent,
 VeniceIngestionDestinationComponent destComponent,
 double latencyMs)

Overrides:

recordTimeBetweenComponents in class IngestionOtelStats