Package akka.persistence.query.typed.scaladsl

Interface EventsBySliceStartingFromSnapshotsQuery

All Superinterfaces:

ReadJournal

All Known Implementing Classes:

EventsBySliceFirehoseQuery

public interface EventsBySliceStartingFromSnapshotsQuery
extends ReadJournal

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

Method Summary

Modifier and Type	Method	Description
<Snapshot,Event> Source<EventEnvelope<Event>,NotUsed>	eventsBySlicesStartingFromSnapshots(java.lang.String entityType, int minSlice, int maxSlice, Offset offset, scala.Function1<Snapshot,Event> transformSnapshot)	Same as EventsBySliceQuery but with the purpose to use snapshots as starting points and thereby reducing number of events that have to be loaded.
int	sliceForPersistenceId(java.lang.String persistenceId)
scala.collection.immutable.Seq<scala.collection.immutable.Range>	sliceRanges(int numberOfRanges)

Method Detail

eventsBySlicesStartingFromSnapshots

<Snapshot,Event> Source<EventEnvelope<Event>,NotUsed> eventsBySlicesStartingFromSnapshots(java.lang.String entityType,
                                                                                                      int minSlice,
                                                                                                      int maxSlice,
                                                                                                      Offset offset,
                                                                                                      scala.Function1<Snapshot,Event> transformSnapshot)

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.

sliceForPersistenceId

int sliceForPersistenceId(java.lang.String persistenceId)

sliceRanges

scala.collection.immutable.Seq<scala.collection.immutable.Range> sliceRanges(int numberOfRanges)