Package com.linkedin.davinci.notifier

Interface VeniceNotifier

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

ExceptionCaptorNotifier, IsolatedIngestionNotifier, LeaderFollowerIngestionProgressNotifier, LogNotifier, PushStatusNotifier, RelayNotifier, StateModelIngestionProgressNotifier

public interface VeniceNotifier
extends Closeable

Interface for listening to Notifications for Store consumption.

Method Summary

Modifier and Type	Method	Description
default void	batchEndOfIncrementalPushReceived(String kafkaTopic, int partitionId, long offset, List<String> historicalIncPushes)
default void	catchUpVersionTopicOffsetLag(String kafkaTopic, int partitionId)
default void	close()	The Process is shutting down and clean up the resources associated with the Notifier.
default void	completed(String kafkaTopic, int partitionId, long offset)	Consumption is completed for a store and partition.
default void	completed(String kafkaTopic, int partitionId, long offset, String message)
default void	dataRecoveryCompleted(String kafkaTopic, int partitionId, long offset, String message)
default void	endOfIncrementalPushReceived(String kafkaTopic, int partitionId, long offset)	Consumption is completed for an incremental push
default void	endOfIncrementalPushReceived(String kafkaTopic, int partitionId, long offset, String message)
default void	endOfPushReceived(String kafkaTopic, int partitionId, long offset)	The ControlMessageType.END_OF_PUSH control message was consumed.
default void	endOfPushReceived(String kafkaTopic, int partitionId, long offset, String message)
default void	error(String kafkaTopic, int partitionId, String message, Exception e)	Report an error, during the consumption for a Partitions and store.
default void	progress(String kafkaTopic, int partitionId, long offset)	Periodic progress report of consumption for a store and partition.
default void	progress(String kafkaTopic, int partitionId, long offset, String message)
default void	quotaNotViolated(String kafkaTopic, int partitionId, long offset)	Quota is not violated for a store.
default void	quotaNotViolated(String kafkaTopic, int partitionId, long offset, String message)
default void	quotaViolated(String kafkaTopic, int partitionId, long offset)	Quota is violated for a store.
default void	quotaViolated(String kafkaTopic, int partitionId, long offset, String message)
default void	restarted(String kafkaTopic, int partitionId, long offset)	Consumption is restarted from given offset for a store and partition
default void	restarted(String kafkaTopic, int partitionId, long offset, String message)
default void	started(String kafkaTopic, int partitionId)	Consumption is started for a store and partition
default void	started(String kafkaTopic, int partitionId, String message)
default void	startOfIncrementalPushReceived(String kafkaTopic, int partitionId, long offset)	Consumption is started for an incremental push
default void	startOfIncrementalPushReceived(String kafkaTopic, int partitionId, long offset, String message)
default void	stopped(String kafkaTopic, int partitionId, long offset)
default void	topicSwitchReceived(String kafkaTopic, int partitionId, long offset)	The ControlMessageType.TOPIC_SWITCH control message was consumed.
default void	topicSwitchReceived(String kafkaTopic, int partitionId, long offset, String message)

Method Details

started

default void started(String kafkaTopic,
 int partitionId)

Consumption is started for a store and partition

started

default void started(String kafkaTopic,
 int partitionId,
 String message)

restarted

default void restarted(String kafkaTopic,
 int partitionId,
 long offset)

Consumption is restarted from given offset for a store and partition

restarted

default void restarted(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

progress

default void progress(String kafkaTopic,
 int partitionId,
 long offset)

Periodic progress report of consumption for a store and partition.

progress

default void progress(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

endOfPushReceived

default void endOfPushReceived(String kafkaTopic,
 int partitionId,
 long offset)

The ControlMessageType.END_OF_PUSH control message was consumed.

This is only emitted for Hybrid Stores, since Batch-Only Stores report completed(String, int, long) right away when getting the EOP.

endOfPushReceived

default void endOfPushReceived(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

topicSwitchReceived

default void topicSwitchReceived(String kafkaTopic,
 int partitionId,
 long offset)

The ControlMessageType.TOPIC_SWITCH control message was consumed.

This is only emitted for Hybrid Stores using Leader/Follower model, after the report of endOfPushReceived(String, int, long) and before completed(String, int, long).

topicSwitchReceived

default void topicSwitchReceived(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

dataRecoveryCompleted

default void dataRecoveryCompleted(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

startOfIncrementalPushReceived

default void startOfIncrementalPushReceived(String kafkaTopic,
 int partitionId,
 long offset)

Consumption is started for an incremental push

startOfIncrementalPushReceived

default void startOfIncrementalPushReceived(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

endOfIncrementalPushReceived

default void endOfIncrementalPushReceived(String kafkaTopic,
 int partitionId,
 long offset)

Consumption is completed for an incremental push

endOfIncrementalPushReceived

default void endOfIncrementalPushReceived(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

batchEndOfIncrementalPushReceived

default void batchEndOfIncrementalPushReceived(String kafkaTopic,
 int partitionId,
 long offset,
 List<String> historicalIncPushes)

catchUpVersionTopicOffsetLag

default void catchUpVersionTopicOffsetLag(String kafkaTopic,
 int partitionId)

completed

default void completed(String kafkaTopic,
 int partitionId,
 long offset)

Consumption is completed for a store and partition.

completed

default void completed(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

quotaViolated

default void quotaViolated(String kafkaTopic,
 int partitionId,
 long offset)

Quota is violated for a store.

quotaViolated

default void quotaViolated(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

quotaNotViolated

default void quotaNotViolated(String kafkaTopic,
 int partitionId,
 long offset)

Quota is not violated for a store.

quotaNotViolated

default void quotaNotViolated(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

close

default void close()

The Process is shutting down and clean up the resources associated with the Notifier. N.B. When implementing the method, make it idempotent.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

error

default void error(String kafkaTopic,
 int partitionId,
 String message,
 Exception e)

Report an error, during the consumption for a Partitions and store. The error may or may not be fatal.

stopped

default void stopped(String kafkaTopic,
 int partitionId,
 long offset)