Package akka.persistence.query
Class TimestampOffset
- java.lang.Object
-
- akka.persistence.query.Offset
-
- akka.persistence.query.TimestampOffset
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Equals
,scala.Product
public final class TimestampOffset extends Offset implements scala.Product, java.io.Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TimestampOffset(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static TimestampOffset
apply(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
Timestamp based offset.static TimestampOffset
apply(java.time.Instant timestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
boolean
canEqual(java.lang.Object x$1)
TimestampOffset
copy(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
java.time.Instant
copy$default$1()
java.time.Instant
copy$default$2()
scala.collection.immutable.Map<java.lang.String,java.lang.Object>
copy$default$3()
boolean
equals(java.lang.Object obj)
java.util.Map<java.lang.String,java.lang.Long>
getSeen()
Java APIint
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
java.time.Instant
readTimestamp()
scala.collection.immutable.Map<java.lang.String,java.lang.Object>
seen()
java.time.Instant
timestamp()
java.lang.String
toString()
static TimestampOffset
toTimestampOffset(Offset offset)
Try to convert the Offset to a TimestampOffset.static scala.Option<scala.Tuple3<java.time.Instant,java.time.Instant,scala.collection.immutable.Map<java.lang.String,java.lang.Object>>>
unapply(TimestampOffset x$0)
static TimestampOffset
Zero()
-
Methods inherited from class akka.persistence.query.Offset
noOffset, sequence, timeBasedUUID, timestamp
-
-
-
-
Method Detail
-
Zero
public static TimestampOffset Zero()
-
apply
public static TimestampOffset apply(java.time.Instant timestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
-
toTimestampOffset
public static TimestampOffset toTimestampOffset(Offset offset)
Try to convert the Offset to a TimestampOffset. Epoch timestamp is used forNoOffset
.
-
apply
public static 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 static scala.Option<scala.Tuple3<java.time.Instant,java.time.Instant,scala.collection.immutable.Map<java.lang.String,java.lang.Object>>> unapply(TimestampOffset x$0)
-
timestamp
public java.time.Instant timestamp()
-
readTimestamp
public java.time.Instant readTimestamp()
-
seen
public scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen()
-
getSeen
public java.util.Map<java.lang.String,java.lang.Long> getSeen()
Java API
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
copy
public TimestampOffset copy(java.time.Instant timestamp, java.time.Instant readTimestamp, scala.collection.immutable.Map<java.lang.String,java.lang.Object> seen)
-
copy$default$1
public java.time.Instant copy$default$1()
-
copy$default$2
public java.time.Instant copy$default$2()
-
copy$default$3
public scala.collection.immutable.Map<java.lang.String,java.lang.Object> copy$default$3()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-