Package com.linkedin.davinci.notifier

Class LogNotifier

java.lang.Object

com.linkedin.davinci.notifier.LogNotifier

All Implemented Interfaces:

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

Direct Known Subclasses:

ExceptionCaptorNotifier

public class LogNotifier
extends java.lang.Object
implements VeniceNotifier

Logs the Notification received.

Constructor Summary

Constructors

Constructor	Description
LogNotifier()

Method Summary

Modifier and Type	Method	Description
void	catchUpVersionTopicOffsetLag(java.lang.String kafkaTopic, int partitionId)
void	close()	The Process is shutting down and clean up the resources associated with the Notifier.
void	completed(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
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 message)
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 ex)	Report an error, during the consumption for a Partitions and store.
void	progress(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 message)
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

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

Constructor Detail

LogNotifier

public LogNotifier()

Method Detail

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

completed

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

Specified by:

completed in interface VeniceNotifier

progress

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

Specified by:

progress 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

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

startOfIncrementalPushReceived

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

Specified by:

startOfIncrementalPushReceived in interface VeniceNotifier

endOfIncrementalPushReceived

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

Specified by:

endOfIncrementalPushReceived in interface VeniceNotifier

catchUpVersionTopicOffsetLag

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

Specified by:

catchUpVersionTopicOffsetLag in interface VeniceNotifier

close

public void close()

Description copied from interface: VeniceNotifier

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 java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface VeniceNotifier

error

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

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

stopped

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

Specified by:

stopped in interface VeniceNotifier