Package com.opencqrs.framework.eventhandler.progress

Interface ProgressTracker

All Known Implementing Classes:
InMemoryProgressTracker, JdbcProgressTracker
public interface ProgressTracker
Interface specifying operations for tracking progress of event processing groups.

  • Method Summary

    Modifier and Type
    Method
    Description
    Progress
    current(String group, long partition)
    Retrieves the current Progress for the specified event processing group and partition.
    void
    proceed(String group, long partition, Supplier<Progress> execution)
    Proceeds the current Progress by executing the given Supplier, which in turn yields the new progress for the specified event processing group and partition.

  • Method Details

    • current

      Progress current(String group, long partition)
      Retrieves the current Progress for the specified event processing group and partition.
      Parameters:
      group - the processing group identifier
      partition - the partition number
      Returns:
      the current progress

    • proceed

      void proceed(String group, long partition, Supplier<Progress> execution)
      Proceeds the current Progress by executing the given Supplier, which in turn yields the new progress for the specified event processing group and partition.
      Parameters:
      group - the processing group identifier
      partition - the partition number
      execution - the supplier returning the new progress, if executed successfully