Class 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 Detail

    • Method Detail

      • 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