package query
- Alphabetic
- Public
- Protected
Package Members
Type Members
- final class DeletedDurableState[A] extends DurableStateChange[A]
- A
the type of the value
- sealed trait DurableStateChange[A] extends AnyRef
The
DurableStateStoreQuery
stream elements forDurableStateStoreQuery
.The
DurableStateStoreQuery
stream elements forDurableStateStoreQuery
.The implementation can be a UpdatedDurableState or a DeletedDurableState.
Not for user extension
- A
the type of the value
- Annotations
- @DoNotInherit()
- final class EventEnvelope extends Product4[Offset, String, Long, Any] with Serializable
Event wrapper adding meta data for the events in the result stream of pekko.persistence.query.scaladsl.EventsByTagQuery query, or similar queries.
Event wrapper adding meta data for the events in the result stream of pekko.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
org.apache.pekko.persistence.query.scaladsl.ReadJournal
andorg.apache.pekko.persistence.query.javadsl.ReadJournal
. The plugin must implement both thescaladsl
and thejavadsl
traits because theorg.apache.pekko.stream.scaladsl.Source
andorg.apache.pekko.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 pekko.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 pekko.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 TimestampOffset(timestamp: Instant, readTimestamp: Instant, seen: Map[String, Long]) extends Offset with Product with Serializable
Timestamp based offset.
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
- 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
- Annotations
- @ApiMayChange()
- final class UpdatedDurableState[A] extends DurableStateChange[A]
- A
the type of the value
Value Members
- object DeletedDurableState
- object EventEnvelope extends AbstractFunction4[Offset, String, Long, Any, EventEnvelope] with Serializable
- case 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.
- object TimestampOffset extends Serializable
- object UpdatedDurableState