Package org.apache.pekko.persistence.testkit.query.internal

Class TimestampOffsets$

java.lang.Object

org.apache.pekko.persistence.testkit.query.internal.TimestampOffsets$

public class TimestampOffsets$
extends Object

INTERNAL API

The test kit journal assigns a strictly increasing timestamp to each atomic write, and an atomic write only contains events of a single persistence id, so (timestamp, persistenceId, sequenceNr) identifies the position of an event.

Field Summary

Fields

Modifier and Type	Field	Description
static final TimestampOffsets$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
TimestampOffsets$()

Method Summary

Modifier and Type	Method	Description
scala.Function1<PersistentRepr,Object>	isAfter(Offset offset)	Returns a predicate that selects the events after the given offset, which must be a TimestampOffset or pekko.persistence.query.NoOffset.
TimestampOffset	offsetFor(PersistentRepr pr)

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final TimestampOffsets$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

TimestampOffsets$

public TimestampOffsets$()

Method Details

offsetFor

public TimestampOffset offsetFor(PersistentRepr pr)

isAfter

public scala.Function1<PersistentRepr,Object> isAfter(Offset offset)

Returns a predicate that selects the events after the given offset, which must be a TimestampOffset or pekko.persistence.query.NoOffset. The offset is exclusive.