Package akka.persistence.query
Class TimestampOffset$
- java.lang.Object
-
- akka.persistence.query.TimestampOffset$
-
- All Implemented Interfaces:
java.io.Serializable
public class TimestampOffset$ extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static TimestampOffset$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description TimestampOffset$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TimestampOffset
apply(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
Timestamp based offset.TimestampOffset
apply(java.time.Instant timestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
TimestampOffset
toTimestampOffset(Offset offset)
Try to convert the Offset to a TimestampOffset.scala.Option<scala.Tuple3<java.time.Instant,java.time.Instant,scala.collection.immutable.Map<java.lang.String,java.lang.Object>>>
unapply(TimestampOffset x$0)
TimestampOffset
Zero()
-
-
-
Field Detail
-
MODULE$
public static final TimestampOffset$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
Zero
public TimestampOffset Zero()
-
apply
public TimestampOffset apply(java.time.Instant timestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
-
toTimestampOffset
public TimestampOffset toTimestampOffset(Offset offset)
Try to convert the Offset to a TimestampOffset. Epoch timestamp is used forNoOffset
.
-
apply
public TimestampOffset apply(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.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 inEventEnvelope
as theoffset
parameter in a subsequent query.API May Change
- Parameters:
timestamp
- time when the event was stored, microsecond granularity database timestampreadTimestamp
- time when the event was read, microsecond granularity database timestampseen
- List of sequence nrs for every persistence id seen at this timestamp
-
unapply
public scala.Option<scala.Tuple3<java.time.Instant,java.time.Instant,scala.collection.immutable.Map<java.lang.String,java.lang.Object>>> unapply(TimestampOffset x$0)
-
-