Package io.fluxcapacitor.common.tracking

Interface Tracker

All Superinterfaces:
Comparable<Tracker>
All Known Implementing Classes:
SimpleTracker, WebSocketTracker
public interface Tracker extends Comparable<Tracker>

  • Field Details

  • Method Details

    • getConsumerName

      String getConsumerName()

    • sendEmptyBatch

      default void sendEmptyBatch(MessageBatch batch)

    • send

      void send(MessageBatch batch)

    • canHandle

      default boolean canHandle(SerializedMessage message, int[] segmentRange)

    • getClientId

      String getClientId()

    • getTypeFilter

      default Predicate<String> getTypeFilter()

    • singleTracker

      default boolean singleTracker()

    • isFilterMessageTarget

      default boolean isFilterMessageTarget()

    • ignoreSegment

      boolean ignoreSegment()

    • clientControlledIndex

      boolean clientControlledIndex()

    • getTrackerId

      String getTrackerId()

    • getLastTrackerIndex

      Long getLastTrackerIndex()

    • getDeadline

      long getDeadline()

    • maxTimeout

      long maxTimeout()

    • hasMissedDeadline

      default boolean hasMissedDeadline()

    • getPurgeDelay

      Long getPurgeDelay()

    • getMaxSize

      int getMaxSize()

    • withLastTrackerIndex

      Tracker withLastTrackerIndex(Long lastTrackerIndex)

    • compareTo

      default int compareTo(Tracker o)
      Specified by:
      compareTo in interface Comparable<Tracker>