Package org.apache.pekko.persistence.query

Class TimestampOffset$

java.lang.Object

org.apache.pekko.persistence.query.TimestampOffset$

All Implemented Interfaces:

Serializable

public class TimestampOffset$
extends Object
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TimestampOffset$()

Method Summary

Modifier and Type	Method	Description
TimestampOffset	apply(Instant timestamp, Instant readTimestamp, scala.collection.immutable.Map<String,Object> seen)	Timestamp based offset.
TimestampOffset	apply(Instant timestamp, scala.collection.immutable.Map<String,Object> seen)
TimestampOffset	toTimestampOffset(Offset offset)	Try to convert the Offset to a TimestampOffset.
scala.Option<scala.Tuple3<Instant,Instant,scala.collection.immutable.Map<String,Object>>>	unapply(TimestampOffset x$0)
TimestampOffset	Zero()

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final TimestampOffset$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

TimestampOffset$

public TimestampOffset$()

Method Details

Zero

public TimestampOffset Zero()

apply

public TimestampOffset apply(Instant timestamp,
 scala.collection.immutable.Map<String,Object> seen)

toTimestampOffset

public TimestampOffset toTimestampOffset(Offset offset)

Try to convert the Offset to a TimestampOffset. Epoch timestamp is used for NoOffset.

apply

public TimestampOffset apply(Instant timestamp,
 Instant readTimestamp,
 scala.collection.immutable.Map<String,Object> seen)

Timestamp based offset. Since there can be several events for the same timestamp it keeps track of what sequence nrs for every persistence id that have been seen at this specific timestamp.

The offset is exclusive, i.e. the event with the exact same sequence number will not be included in the returned stream. This means that you can use the offset that is returned in EventEnvelope as the offset parameter in a subsequent query.

API May Change

Parameters:

timestamp - time when the event was stored, microsecond granularity database timestamp

readTimestamp - time when the event was read, microsecond granularity database timestamp

seen - List of sequence nrs for every persistence id seen at this timestamp

unapply

public scala.Option<scala.Tuple3<Instant,Instant,scala.collection.immutable.Map<String,Object>>> unapply(TimestampOffset x$0)