Package io.fluxcapacitor.common.tracking

Class TrackerCluster

java.lang.Object

io.fluxcapacitor.common.tracking.TrackerCluster

public class TrackerCluster
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int[]	emptyRange

Constructor Summary

Constructors

Constructor	Description
TrackerCluster(int segments)

Method Summary

Modifier and Type	Method	Description
boolean	contains(Tracker tracker)
Optional<Duration>	getProcessingDuration(Tracker tracker)
int[]	getSegment(Tracker tracker)
Set<Tracker>	getTrackers()
boolean	isActive(Tracker tracker)
boolean	isEmpty()
TrackerCluster	purgeCeasedTrackers(Instant threshold)
TrackerCluster	purgeTrackers(Predicate<Tracker> predicate)
TrackerCluster	withActiveTracker(Tracker tracker)
TrackerCluster	withoutTracker(Tracker tracker)
TrackerCluster	withWaitingTracker(Tracker tracker)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

emptyRange

public static final int[] emptyRange

Constructor Details

TrackerCluster

public TrackerCluster(int segments)

Method Details

withActiveTracker

public TrackerCluster withActiveTracker(Tracker tracker)

withWaitingTracker

public TrackerCluster withWaitingTracker(Tracker tracker)

withoutTracker

public TrackerCluster withoutTracker(Tracker tracker)

purgeTrackers

public TrackerCluster purgeTrackers(Predicate<Tracker> predicate)

purgeCeasedTrackers

public TrackerCluster purgeCeasedTrackers(Instant threshold)

getProcessingDuration

public Optional<Duration> getProcessingDuration(Tracker tracker)

getSegment

public int[] getSegment(Tracker tracker)

contains

public boolean contains(Tracker tracker)

isActive

public boolean isActive(Tracker tracker)

getTrackers

public Set<Tracker> getTrackers()

isEmpty

public boolean isEmpty()