Uses of Class
io.fluxcapacitor.common.tracking.TrackerCluster
Packages that use TrackerCluster
-
Uses of TrackerCluster in io.fluxcapacitor.common.tracking
Methods in io.fluxcapacitor.common.tracking that return TrackerClusterModifier and TypeMethodDescriptionTrackerCluster.purgeCeasedTrackers
(Instant threshold) Removes trackers that have not sent activity after the given timestamp.TrackerCluster.purgeTrackers
(Predicate<Tracker> predicate) Removes all trackers that match the provided predicate.TrackerCluster.withActiveTracker
(Tracker tracker) Marks the given tracker as actively processing messages.TrackerCluster.withoutTracker
(Tracker tracker) Removes the tracker from the cluster.TrackerCluster.withWaitingTracker
(Tracker tracker) Adds or updates the tracker as waiting (not currently processing).Methods in io.fluxcapacitor.common.tracking with parameters of type TrackerClusterModifier and TypeMethodDescriptionprotected void
DefaultTrackingStrategy.onClusterUpdate
(TrackerCluster cluster)