Type Members

1.  final case class EventEnvelope(offset: Offset, persistenceId: String, sequenceNr: Long, event: Any) extends Product with Serializable

   Event wrapper adding meta data for the events in the result stream of akka.persistence.query.scaladsl.EventsByTagQuery query, or similar queries.

2.  abstract class Offset extends AnyRef
3.  class PersistenceQuery extends PersistencePlugin[ReadJournal, ReadJournal, ReadJournalProvider] with Extension
4.  trait ReadJournalProvider extends AnyRef

   A query plugin must implement a class that implements this trait.

   A query plugin must implement a class that implements this trait. It provides the concrete implementations for the Java and Scala APIs.

   A read journal plugin must provide implementations for both akka.persistence.query.scaladsl.ReadJournal and akka.persistence.query.javaadsl.ReadJournal. The plugin must implement both the scaladsl and the javadsl traits because the akka.stream.scaladsl.Source and akka.stream.javadsl.Source are different types and even though those types can easily be converted to each other it is most convenient for the end user to get access to the Java or Scala Source directly. One of the implementations can delegate to the other.

5.  final case class Sequence(value: Long) extends Offset with Ordered[Sequence] with Product with Serializable

   Corresponds to an ordered sequence number for the events.

   Corresponds to an ordered sequence number for the events. Note that the corresponding offset of each event is provided in the akka.persistence.query.EventEnvelope, which makes it possible to resume the stream at a later point from a given offset.

   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.

6.  final case class TimeBasedUUID(value: UUID) extends Offset with Ordered[TimeBasedUUID] with Product with Serializable

   Corresponds to an ordered unique identifier of the events.

   Corresponds to an ordered unique identifier of the events. Note that the corresponding offset of each event is provided in the akka.persistence.query.EventEnvelope, which makes it possible to resume the stream at a later point from a given offset.

   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.