package query
- Alphabetic
- Public
- All
Type Members
-
final
case class
EventEnvelope
(offset: Long, 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.
-
final
case class
EventEnvelope2
(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.EventsByTagQuery2 query, or similar queries.
- trait Offset extends AnyRef
- class PersistenceQuery extends 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.javaadsl.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
- final case class TimeBasedUUID (value: UUID) extends Offset with Ordered[TimeBasedUUID] with Product with Serializable
Value Members
- object NoOffset extends Offset with Product with Serializable
- object Offset
-
object
PersistenceQuery
extends ExtensionId[PersistenceQuery] with ExtensionIdProvider
Persistence extension for queries.