package scaladsl

Content Hierarchy
Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. trait CurrentEventsByPersistenceIdStartingFromSnapshotQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

    A plugin may optionally support this query by implementing this trait.

    Annotations
    @ApiMayChange()
  2. trait CurrentEventsByPersistenceIdTypedQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

  3. trait CurrentEventsBySliceQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

  4. trait CurrentEventsBySliceStartingFromSnapshotsQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

  5. trait DurableStateStoreBySliceQuery[A] extends DurableStateStore[A]

    Query API for reading durable state objects.

    Query API for reading durable state objects.

    For Java API see DurableStateStoreBySliceQuery.

  6. trait EventTimestampQuery extends ReadJournal

    EventsBySliceQuery that is using a timestamp based offset should also implement this query.

  7. trait EventsByPersistenceIdStartingFromSnapshotQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

    A plugin may optionally support this query by implementing this trait.

    Annotations
    @ApiMayChange()
  8. trait EventsByPersistenceIdTypedQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

  9. final class EventsBySliceFirehoseQuery extends ReadJournal with EventsBySliceQuery with EventsBySliceStartingFromSnapshotsQuery with EventTimestampQuery with LoadEventQuery

    This wrapper of EventsBySliceQuery gives better scalability when many consumers retrieve the same events, for example many Projections of the same entity type.

    This wrapper of EventsBySliceQuery gives better scalability when many consumers retrieve the same events, for example many Projections of the same entity type. The purpose is to share the stream of events from the database and fan out to connected consumer streams. Thereby fewer queries and loading of events from the database.

    It is retrieved with:

    val queries = PersistenceQuery(system).readJournalFor[EventsBySliceQuery](EventsBySliceFirehoseQuery.Identifier)

    Corresponding Java API is in akka.persistence.query.typed.javadsl.EventsBySliceFirehoseQuery.

    Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is "akka.persistence.query.events-by-slice-firehose" for the default EventsBySliceFirehoseQuery#Identifier. See reference.conf.

    Annotations
    @nowarn()
  10. trait EventsBySliceQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

    A plugin may optionally support this query by implementing this trait.

    EventsBySliceQuery that is using a timestamp based offset should also implement EventTimestampQuery and LoadEventQuery.

    See also EventsBySliceFirehoseQuery.

  11. trait EventsBySliceStartingFromSnapshotsQuery extends ReadJournal

    A plugin may optionally support this query by implementing this trait.

    A plugin may optionally support this query by implementing this trait.

    EventsBySliceStartingFromSnapshotsQuery that is using a timestamp based offset should also implement EventTimestampQuery and LoadEventQuery.

    See also EventsBySliceFirehoseQuery.

    API May Change

    Annotations
    @ApiMayChange()
  12. trait LoadEventQuery extends ReadJournal

    EventsBySliceQuery that is using a timestamp based offset should also implement this query.

Value Members

  1. object EventsBySliceFirehoseQuery

Ungrouped