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

Packages that use Tracker

Package	Description
io.fluxzero.common.tracking

Uses of Tracker in io.fluxzero.common.tracking

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

Modifier and Type	Class	Description
class	SimpleTracker
class	WebSocketTracker

Subinterfaces with type arguments of type Tracker in io.fluxzero.common.tracking

Modifier and Type	Interface	Description
interface	Tracker	A Tracker represents an active consumer of messages for a particular ConsumerConfiguration.

Fields in io.fluxzero.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.fluxzero.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.fluxzero.common.tracking that return types with arguments of type Tracker

Modifier and Type	Method	Description
Set<Tracker>	DefaultTrackingStrategy.disconnectTrackers(Predicate<Tracker> predicate, boolean sendFinalEmptyBatch)
Set<Tracker>	TrackingStrategy.disconnectTrackers(Predicate<Tracker> predicate, boolean sendFinalBatch)	Disconnects trackers that match the provided filter.
Set<Tracker>	TrackerCluster.getTrackers()	Returns an unmodifiable view of the current set of trackers.

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

Modifier and Type	Method	Description
protected int	DefaultTrackingStrategy.adjustMaxSize(Tracker tracker, int maxSize)
CompletableFuture<ClaimResult>	DefaultTrackingStrategy.claimSegment(Tracker tracker)
protected void	DefaultTrackingStrategy.claimSegment(Tracker tracker, DefaultTrackingStrategy.TrackerRequest<ClaimResult> request)
CompletableFuture<ClaimResult>	TrackingStrategy.claimSegment(Tracker tracker)	Claims one or more message segments for the given tracker.
protected int[]	DefaultTrackingStrategy.claimSegmentRange(Tracker 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)
protected Predicate<SerializedMessage>	DefaultTrackingStrategy.filterPredicate(int[] segmentRange, Position position, Tracker tracker)
CompletableFuture<MessageBatch>	DefaultTrackingStrategy.getBatch(Tracker tracker)
protected void	DefaultTrackingStrategy.getBatch(Tracker tracker, DefaultTrackingStrategy.TrackerRequest<MessageBatch> request)
CompletableFuture<MessageBatch>	TrackingStrategy.getBatch(Tracker tracker)	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, int[] segment)
protected void	DefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch)
protected void	DefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch, DefaultTrackingStrategy.TrackerRequest<MessageBatch> request)
protected void	DefaultTrackingStrategy.waitForUpdate(Tracker tracker, MessageBatch emptyBatch, Runnable followUp)
protected void	DefaultTrackingStrategy.waitForUpdate(Tracker tracker, MessageBatch emptyBatch, Runnable followUp, DefaultTrackingStrategy.TrackerRequest<?> request)
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.fluxzero.common.tracking with type arguments of type Tracker

Modifier and Type	Method	Description
Set<Tracker>	DefaultTrackingStrategy.disconnectTrackers(Predicate<Tracker> predicate, boolean sendFinalEmptyBatch)
Set<Tracker>	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.