Package com.linkedin.davinci.notifier
Class PushStatusNotifier
java.lang.Object
com.linkedin.davinci.notifier.PushStatusNotifier
- All Implemented Interfaces:
VeniceNotifier
,Closeable
,AutoCloseable
Notifies both OfflinePushStatus and Helix Customized View
-
Constructor Summary
ConstructorsConstructorDescriptionPushStatusNotifier
(OfflinePushAccessor offlinePushAccessor, HelixPartitionStatusAccessor helixPartitionStatusAccessor, PushStatusStoreWriter pushStatusStoreWriter, ReadOnlyStoreRepository storeRepository, String instanceId, VeniceServerConfig.IncrementalPushStatusWriteMode incrementalPushStatusWriteMode) -
Method Summary
Modifier and TypeMethodDescriptionvoid
batchEndOfIncrementalPushReceived
(String topic, int partitionId, PubSubPosition position, List<String> pendingReportIncPushVersionList) void
close()
The Process is shutting down and clean up the resources associated with the Notifier.void
completed
(String topic, int partitionId, PubSubPosition position, String message) void
dataRecoveryCompleted
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
endOfIncrementalPushReceived
(String topic, int partitionId, PubSubPosition position, String message) void
endOfPushReceived
(String topic, int partitionId, PubSubPosition position, String message) void
Report an error, during the consumption for a Partitions and store.void
progress
(String topic, int partitionId, PubSubPosition position, String message) void
quotaNotViolated
(String topic, int partitionId, PubSubPosition position, String message) void
quotaViolated
(String topic, int partitionId, PubSubPosition position, String message) void
restarted
(String topic, int partitionId, PubSubPosition position, String message) void
void
startOfIncrementalPushReceived
(String topic, int partitionId, PubSubPosition position, String message) void
topicSwitchReceived
(String topic, 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
catchUpVersionTopicOffsetLag, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, quotaNotViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, stopped, topicSwitchReceived
-
Constructor Details
-
PushStatusNotifier
public PushStatusNotifier(OfflinePushAccessor offlinePushAccessor, HelixPartitionStatusAccessor helixPartitionStatusAccessor, PushStatusStoreWriter pushStatusStoreWriter, ReadOnlyStoreRepository storeRepository, String instanceId, VeniceServerConfig.IncrementalPushStatusWriteMode incrementalPushStatusWriteMode)
-
-
Method Details
-
started
- Specified by:
started
in interfaceVeniceNotifier
-
restarted
- Specified by:
restarted
in interfaceVeniceNotifier
-
completed
- Specified by:
completed
in interfaceVeniceNotifier
-
quotaViolated
- Specified by:
quotaViolated
in interfaceVeniceNotifier
-
quotaNotViolated
public void quotaNotViolated(String topic, int partitionId, PubSubPosition position, String message) - Specified by:
quotaNotViolated
in interfaceVeniceNotifier
-
progress
- Specified by:
progress
in interfaceVeniceNotifier
-
endOfPushReceived
public void endOfPushReceived(String topic, int partitionId, PubSubPosition position, String message) - Specified by:
endOfPushReceived
in interfaceVeniceNotifier
-
topicSwitchReceived
public void topicSwitchReceived(String topic, 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
-
startOfIncrementalPushReceived
public void startOfIncrementalPushReceived(String topic, int partitionId, PubSubPosition position, String message) - Specified by:
startOfIncrementalPushReceived
in interfaceVeniceNotifier
-
endOfIncrementalPushReceived
public void endOfIncrementalPushReceived(String topic, int partitionId, PubSubPosition position, String message) - Specified by:
endOfIncrementalPushReceived
in interfaceVeniceNotifier
-
batchEndOfIncrementalPushReceived
public void batchEndOfIncrementalPushReceived(String topic, int partitionId, PubSubPosition position, List<String> pendingReportIncPushVersionList) - Specified by:
batchEndOfIncrementalPushReceived
in interfaceVeniceNotifier
-
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 interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
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
-