t

akka.persistence.query.typed.javadsl

CurrentEventsBySliceStartingFromSnapshotsQuery

trait CurrentEventsBySliceStartingFromSnapshotsQuery extends ReadJournal

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

API May Change

Annotations
@ApiMayChange()
Source
CurrentEventsBySliceStartingFromSnapshotsQuery.scala
Linear Supertypes
ReadJournal, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CurrentEventsBySliceStartingFromSnapshotsQuery
  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 currentEventsBySlicesStartingFromSnapshots[Snapshot, Event](entityType: String, minSlice: Int, maxSlice: Int, offset: Offset, transformSnapshot: Function[Snapshot, Event]): [EventEnvelope[Event], NotUsed]

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

    Same as EventsBySliceStartingFromSnapshotsQuery 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.

    Same type of query as EventsBySliceStartingFromSnapshotsQuery.eventsBySlicesStartingFromSnapshots but the event stream is completed immediately when it reaches the end of the "result set".

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