package query
- Alphabetic
- Public
- All
Type Members
-
final
class
EventEnvelope extends Product4[Offset, String, Long, Any] with Serializable
Event wrapper adding meta data for the events in the result stream of akka.persistence.query.scaladsl.EventsByTagQuery query, or similar queries.
Event wrapper adding meta data for the events in the result stream of akka.persistence.query.scaladsl.EventsByTagQuery query, or similar queries.
The
timestamp
is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same asSystem.currentTimeMillis
). - abstract class Offset extends AnyRef
- class PersistenceQuery extends PersistencePlugin[ReadJournal, ReadJournal, ReadJournalProvider] with Extension
-
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
andakka.persistence.query.javadsl.ReadJournal
. The plugin must implement both thescaladsl
and thejavadsl
traits because theakka.stream.scaladsl.Source
andakka.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 ScalaSource
directly. One of the implementations can delegate to the other. -
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 inEventEnvelope
as theoffset
parameter in a subsequent query. -
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 inEventEnvelope
as theoffset
parameter in a subsequent query.
Value Members
- object EventEnvelope extends AbstractFunction4[Offset, String, Long, Any, EventEnvelope] with Serializable
-
object
NoOffset extends Offset with Product with Serializable
Used when retrieving all events.
- object Offset
-
object
PersistenceQuery extends ExtensionId[PersistenceQuery] with ExtensionIdProvider
Persistence extension for queries.