Package akka.persistence.query

Class 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.

    • 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()  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

        public static final TimestampOffset$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • TimestampOffset$

        public TimestampOffset$()

    • Method Detail

      • 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 for NoOffset.

      • 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 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<java.time.Instant,​java.time.Instant,​scala.collection.immutable.Map<java.lang.String,​java.lang.Object>>> unapply​(TimestampOffset x$0)