Package com.linkedin.davinci.notifier
Class RelayNotifier
java.lang.Object
com.linkedin.davinci.notifier.RelayNotifier
- All Implemented Interfaces:
VeniceNotifier
,Closeable
,AutoCloseable
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 -
Method Summary
Modifier and TypeMethodDescriptionvoid
completed
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
dataRecoveryCompleted
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
endOfIncrementalPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) void
endOfPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
Report an error, during the consumption for a Partitions and store.void
quotaNotViolated
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
quotaViolated
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
restarted
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
void
startOfIncrementalPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) void
stopped
(String kafkaTopic, int partitionId, PubSubPosition position) void
topicSwitchReceived
(String kafkaTopic, int partitionId, PubSubPosition position, 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 Details
-
RelayNotifier
-
-
Method Details
-
completed
- Specified by:
completed
in interfaceVeniceNotifier
-
error
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
- Specified by:
started
in interfaceVeniceNotifier
-
restarted
- Specified by:
restarted
in interfaceVeniceNotifier
-
endOfPushReceived
public void endOfPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
endOfPushReceived
in interfaceVeniceNotifier
-
startOfIncrementalPushReceived
public void startOfIncrementalPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) - Specified by:
startOfIncrementalPushReceived
in interfaceVeniceNotifier
-
endOfIncrementalPushReceived
public void endOfIncrementalPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) - Specified by:
endOfIncrementalPushReceived
in interfaceVeniceNotifier
-
topicSwitchReceived
public void topicSwitchReceived(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
topicSwitchReceived
in interfaceVeniceNotifier
-
dataRecoveryCompleted
public void dataRecoveryCompleted(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
dataRecoveryCompleted
in interfaceVeniceNotifier
-
stopped
- Specified by:
stopped
in interfaceVeniceNotifier
-
quotaViolated
public void quotaViolated(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
quotaViolated
in interfaceVeniceNotifier
-
quotaNotViolated
public void quotaNotViolated(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
quotaNotViolated
in interfaceVeniceNotifier
-