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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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 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
batchEndOfIncrementalPushReceived, 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)
- Specified by:
completed
in interfaceVeniceNotifier
-
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 interfaceVeniceNotifier
-
started
public void started(java.lang.String kafkaTopic, int partitionId, java.lang.String message)
- Specified by:
started
in interfaceVeniceNotifier
-
restarted
public void restarted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
restarted
in interfaceVeniceNotifier
-
endOfPushReceived
public void endOfPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
endOfPushReceived
in interfaceVeniceNotifier
-
startOfIncrementalPushReceived
public void startOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
- Specified by:
startOfIncrementalPushReceived
in interfaceVeniceNotifier
-
endOfIncrementalPushReceived
public void endOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
- Specified by:
endOfIncrementalPushReceived
in interfaceVeniceNotifier
-
topicSwitchReceived
public void topicSwitchReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
topicSwitchReceived
in interfaceVeniceNotifier
-
dataRecoveryCompleted
public void dataRecoveryCompleted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
dataRecoveryCompleted
in interfaceVeniceNotifier
-
stopped
public void stopped(java.lang.String kafkaTopic, int partitionId, long offset)
- Specified by:
stopped
in interfaceVeniceNotifier
-
quotaViolated
public void quotaViolated(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
quotaViolated
in interfaceVeniceNotifier
-
quotaNotViolated
public void quotaNotViolated(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
- Specified by:
quotaNotViolated
in interfaceVeniceNotifier
-
-