Interface EventsBySliceStartingFromSnapshotsQuery

    • 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)