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

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

Modifier and Type	Method	Description
Tracker	Tracker.withLastTrackerIndex(Long lastTrackerIndex)

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

Modifier and Type	Method	Description
Set<Tracker>	TrackerCluster.getTrackers()

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)
default int	Tracker.compareTo(Tracker o)
boolean	TrackerCluster.contains(Tracker tracker)
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)
Optional<Duration>	TrackerCluster.getProcessingDuration(Tracker tracker)
int[]	TrackerCluster.getSegment(Tracker tracker)
boolean	TrackerCluster.isActive(Tracker tracker)
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)
TrackerCluster	TrackerCluster.withoutTracker(Tracker tracker)
TrackerCluster	TrackerCluster.withWaitingTracker(Tracker tracker)

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)
TrackerCluster	TrackerCluster.purgeTrackers(Predicate<Tracker> predicate)