Packages

package query

Content Hierarchy
TimeBasedUUIDSequenceOffsetNoOffset
Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

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

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

  3. trait Offset extends AnyRef
  4. class PersistenceQuery extends Extension
  5. 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.

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

Value Members

  1. object NoOffset extends Offset with Product with Serializable
  2. object Offset
  3. object PersistenceQuery extends ExtensionId[PersistenceQuery] with ExtensionIdProvider

    Persistence extension for queries.

Ungrouped