Class ForwardSlidingWindowEventTracker

java.lang.Object

org.ngengine.nostr4j.event.tracker.ForwardSlidingWindowEventTracker

All Implemented Interfaces:

EventTracker

public class ForwardSlidingWindowEventTracker
extends Object
implements EventTracker

Tracks current events in a bounded forward window. Expired events and events more than 30 seconds in the future are treated as seen without changing the window.

Field Summary

Fields

Modifier and Type	Field	Description
protected long	cutOffS
protected int	maxTrackedEvents
protected final int	minTrackedEvents
protected final Set<String>	seenEventIds
protected final LinkedList<SignedNostrEvent.Identifier>	seenEvents
protected final long	trackingWindowS
protected final long	trackingWindowsMarginS

Constructor Summary

Constructors

Constructor	Description
ForwardSlidingWindowEventTracker()
ForwardSlidingWindowEventTracker(int maxTrackedEvents, int minTrackedEvents, long trackingWindow, TimeUnit trackingWindowTimeUnit, long trackingWindowMargin, TimeUnit trackingWindowMarginTimeUnit)

Method Summary

Modifier and Type	Method	Description
protected boolean	checkIndex()
protected boolean	checkOrder()
protected int	count()
protected long	currentTimeSeconds()
protected Collection<SignedNostrEvent.Identifier>	getAll()
boolean	seen(SignedNostrEvent event)
void	tuneFor(NostrSubscription sub)
protected void	update()

Methods inherited from class Object

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

Field Details

seenEvents

protected final LinkedList<SignedNostrEvent.Identifier> seenEvents

seenEventIds

protected final Set<String> seenEventIds

maxTrackedEvents

protected int maxTrackedEvents

minTrackedEvents

protected final int minTrackedEvents

trackingWindowS

protected final long trackingWindowS

trackingWindowsMarginS

protected final long trackingWindowsMarginS

cutOffS

protected long cutOffS

Constructor Details

ForwardSlidingWindowEventTracker

public ForwardSlidingWindowEventTracker()

ForwardSlidingWindowEventTracker

public ForwardSlidingWindowEventTracker(int maxTrackedEvents,
 int minTrackedEvents,
 long trackingWindow,
 TimeUnit trackingWindowTimeUnit,
 long trackingWindowMargin,
 TimeUnit trackingWindowMarginTimeUnit)

Method Details

seen

public boolean seen(SignedNostrEvent event)

Specified by:

seen in interface EventTracker

count

protected int count()

currentTimeSeconds

protected long currentTimeSeconds()

getAll

protected Collection<SignedNostrEvent.Identifier> getAll()

update

protected void update()

checkIndex

protected boolean checkIndex()

checkOrder

protected boolean checkOrder()

tuneFor

public void tuneFor(NostrSubscription sub)

Specified by:

tuneFor in interface EventTracker