Uses of Interface
io.fluxcapacitor.common.tracking.Tracker

Packages that use Tracker

Package	Description
io.fluxcapacitor.common.tracking

Uses of Tracker in io.fluxcapacitor.common.tracking

Classes in io.fluxcapacitor.common.tracking that implement Tracker

Modifier and Type	Class	Description
class	SimpleTracker
class	WebSocketTracker

Fields in io.fluxcapacitor.common.tracking with type parameters of type Tracker

Modifier and Type	Field	Description
static final Comparator<Tracker>	Tracker.comparator	Default comparator based on consumer name and tracker ID.

Methods in io.fluxcapacitor.common.tracking that return Tracker

Modifier and Type	Method	Description
Tracker	Tracker.withLastTrackerIndex(Long lastTrackerIndex)	Returns a copy of this tracker with its last index updated.

Methods in io.fluxcapacitor.common.tracking that return types with arguments of type Tracker

Modifier and Type	Method	Description
Set<Tracker>	TrackerCluster.getTrackers()	Returns an unmodifiable view of the current set of trackers.

Methods in io.fluxcapacitor.common.tracking with parameters of type Tracker

Modifier and Type	Method	Description
protected int	DefaultTrackingStrategy.adjustMaxSize(Tracker tracker, int maxSize)
protected int[]	DefaultTrackingStrategy.claimSegment(Tracker tracker)
void	DefaultTrackingStrategy.claimSegment(Tracker tracker, PositionStore positionStore)
void	TrackingStrategy.claimSegment(Tracker tracker, PositionStore positionStore)	Claims one or more message segments for the given tracker.
default int	Tracker.compareTo(Tracker o)	Compares trackers based on consumer and tracker IDs for stable sorting.
boolean	TrackerCluster.contains(Tracker tracker)	Checks if the tracker is part of this cluster.
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
void	DefaultTrackingStrategy.getBatch(Tracker tracker, PositionStore positionStore)
void	TrackingStrategy.getBatch(Tracker tracker, PositionStore positionStore)	Requests a new batch of messages for the given tracker.
Optional<Duration>	TrackerCluster.getProcessingDuration(Tracker tracker)	Returns how long the given tracker has been active.
int[]	TrackerCluster.getSegment(Tracker tracker)	Returns the segment range assigned to the tracker.
boolean	TrackerCluster.isActive(Tracker tracker)	Checks if the tracker is currently marked as active.
protected Position	DefaultTrackingStrategy.position(Tracker tracker, PositionStore positionStore, int[] segment)
protected void	DefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch, PositionStore positionStore)
protected void	DefaultTrackingStrategy.waitForUpdate(Tracker tracker, MessageBatch emptyBatch, Runnable followUp)
TrackerCluster	TrackerCluster.withActiveTracker(Tracker tracker)	Marks the given tracker as actively processing messages.
TrackerCluster	TrackerCluster.withoutTracker(Tracker tracker)	Removes the tracker from the cluster.
TrackerCluster	TrackerCluster.withWaitingTracker(Tracker tracker)	Adds or updates the tracker as waiting (not currently processing).

Method parameters in io.fluxcapacitor.common.tracking with type arguments of type Tracker

Modifier and Type	Method	Description
void	DefaultTrackingStrategy.disconnectTrackers(Predicate<Tracker> predicate, boolean sendFinalEmptyBatch)
void	TrackingStrategy.disconnectTrackers(Predicate<Tracker> predicate, boolean sendFinalBatch)	Disconnects trackers that match the provided filter.
TrackerCluster	TrackerCluster.purgeTrackers(Predicate<Tracker> predicate)	Removes all trackers that match the provided predicate.