Package com.linkedin.davinci.notifier

Class RelayNotifier

java.lang.Object

com.linkedin.davinci.notifier.RelayNotifier

All Implemented Interfaces:

VeniceNotifier, java.io.Closeable, java.lang.AutoCloseable

public class RelayNotifier
extends java.lang.Object
implements VeniceNotifier

RelayNotifier is a VeniceNotifier which takes in a target VeniceNotifier and forward all actions to the target notifier. This RelayNotifier can served as the base implementation and other notifier implementation can override the method implementation to achieve customized behaviors.

Constructor Summary

Constructors

Constructor	Description
RelayNotifier(VeniceNotifier notifier)

Method Summary

Modifier and Type	Method	Description
void	completed(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	completed(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message, java.util.Optional<LeaderFollowerStateType> leaderState)
void	dataRecoveryCompleted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	endOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
void	endOfPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	error(java.lang.String kafkaTopic, int partitionId, java.lang.String message, java.lang.Exception e)	Report an error, during the consumption for a Partitions and store.
void	quotaNotViolated(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	quotaViolated(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	restarted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	started(java.lang.String kafkaTopic, int partitionId, java.lang.String message)
void	startOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
void	stopped(java.lang.String kafkaTopic, int partitionId, long offset)
void	topicSwitchReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.davinci.notifier.VeniceNotifier

catchUpVersionTopicOffsetLag, close, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, progress, quotaNotViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, topicSwitchReceived

Constructor Detail

RelayNotifier

public RelayNotifier(VeniceNotifier notifier)

Method Detail

completed

public void completed(java.lang.String kafkaTopic,
                      int partitionId,
                      long offset,
                      java.lang.String message,
                      java.util.Optional<LeaderFollowerStateType> leaderState)

Specified by:

completed in interface VeniceNotifier

completed

public void completed(java.lang.String kafkaTopic,
                      int partitionId,
                      long offset,
                      java.lang.String message)

Specified by:

completed in interface VeniceNotifier

error

public void error(java.lang.String kafkaTopic,
                  int partitionId,
                  java.lang.String message,
                  java.lang.Exception e)

Description copied from interface: VeniceNotifier

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

Specified by:

error in interface VeniceNotifier

started

public void started(java.lang.String kafkaTopic,
                    int partitionId,
                    java.lang.String message)

Specified by:

started in interface VeniceNotifier

restarted

public void restarted(java.lang.String kafkaTopic,
                      int partitionId,
                      long offset,
                      java.lang.String message)

Specified by:

restarted in interface VeniceNotifier

endOfPushReceived

public void endOfPushReceived(java.lang.String kafkaTopic,
                              int partitionId,
                              long offset,
                              java.lang.String message)

Specified by:

endOfPushReceived in interface VeniceNotifier

startOfIncrementalPushReceived

public void startOfIncrementalPushReceived(java.lang.String kafkaTopic,
                                           int partitionId,
                                           long offset,
                                           java.lang.String incrementalPushVersion)

Specified by:

startOfIncrementalPushReceived in interface VeniceNotifier

endOfIncrementalPushReceived

public void endOfIncrementalPushReceived(java.lang.String kafkaTopic,
                                         int partitionId,
                                         long offset,
                                         java.lang.String incrementalPushVersion)

Specified by:

endOfIncrementalPushReceived in interface VeniceNotifier

topicSwitchReceived

public void topicSwitchReceived(java.lang.String kafkaTopic,
                                int partitionId,
                                long offset,
                                java.lang.String message)

Specified by:

topicSwitchReceived in interface VeniceNotifier

dataRecoveryCompleted

public void dataRecoveryCompleted(java.lang.String kafkaTopic,
                                  int partitionId,
                                  long offset,
                                  java.lang.String message)

Specified by:

dataRecoveryCompleted in interface VeniceNotifier

stopped

public void stopped(java.lang.String kafkaTopic,
                    int partitionId,
                    long offset)

Specified by:

stopped in interface VeniceNotifier

quotaViolated

public void quotaViolated(java.lang.String kafkaTopic,
                          int partitionId,
                          long offset,
                          java.lang.String message)

Specified by:

quotaViolated in interface VeniceNotifier

quotaNotViolated

public void quotaNotViolated(java.lang.String kafkaTopic,
                             int partitionId,
                             long offset,
                             java.lang.String message)

Specified by:

quotaNotViolated in interface VeniceNotifier