t

akka.persistence.query.typed.javadsl

EventsBySliceStartingFromSnapshotsQuery

trait EventsBySliceStartingFromSnapshotsQuery extends ReadJournal

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.

API May Change

Annotations
@ApiMayChange()
Source
EventsBySliceStartingFromSnapshotsQuery.scala
Linear Supertypes
ReadJournal, AnyRef, Any
Known Subclasses
EventsBySliceFirehoseQuery
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventsBySliceStartingFromSnapshotsQuery
  2. ReadJournal
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def eventsBySlicesStartingFromSnapshots[Snapshot, Event](entityType: String, minSlice: Int, maxSlice: Int, offset: Offset, transformSnapshot: Function[Snapshot, Event]): [EventEnvelope[Event], NotUsed]

    Same as EventsBySliceQuery but with the purpose to use snapshots as starting points and thereby reducing number of events that have to be loaded.

    Same as EventsBySliceQuery but with the purpose to use snapshots as starting points and thereby reducing number of events that have to be loaded. This can be useful if the consumer start from zero without any previously processed offset or if it has been disconnected for a long while and its offset is far behind.

  2. abstract def sliceForPersistenceId(persistenceId: String): Int
  3. abstract def sliceRanges(numberOfRanges: Int): [[, Integer]]