Packages

o

akka.projection.eventsourced.javadsl

EventSourcedProvider

object EventSourcedProvider

Source
EventSourcedProvider.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventSourcedProvider
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def eventsBySlices[Event](system: ActorSystem[_], eventsBySlicesQuery: EventsBySliceQuery, entityType: String, minSlice: Int, maxSlice: Int, adjustStartOffset: Function[Optional[Offset], CompletionStage[Optional[Offset]]]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]

    By default, the SourceProvider uses the stored offset when starting the Projection.

    By default, the SourceProvider uses the stored offset when starting the Projection. This offset can be adjusted by defining the adjustStartOffset function, which is a function from loaded offset (if any) to the adjusted offset that will be used to by the eventsBySlicesQuery.

  2. def eventsBySlices[Event](system: ActorSystem[_], eventsBySlicesQuery: EventsBySliceQuery, entityType: String, minSlice: Int, maxSlice: Int): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]
  3. def eventsBySlices[Event](system: ActorSystem[_], readJournalPluginId: String, entityType: String, minSlice: Int, maxSlice: Int, adjustStartOffset: Function[Optional[Offset], CompletionStage[Optional[Offset]]]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]

    By default, the SourceProvider uses the stored offset when starting the Projection.

    By default, the SourceProvider uses the stored offset when starting the Projection. This offset can be adjusted by defining the adjustStartOffset function, which is a function from loaded offset (if any) to the adjusted offset that will be used to by the eventsBySlicesQuery.

  4. def eventsBySlices[Event](system: ActorSystem[_], readJournalPluginId: String, entityType: String, minSlice: Int, maxSlice: Int): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]
  5. def eventsBySlicesStartingFromSnapshots[Snapshot, Event](system: ActorSystem[_], eventsBySlicesQuery: EventsBySliceStartingFromSnapshotsQuery, entityType: String, minSlice: Int, maxSlice: Int, transformSnapshot: Function[Snapshot, Event], adjustStartOffset: Function[Optional[Offset], CompletionStage[Optional[Offset]]]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]
  6. def eventsBySlicesStartingFromSnapshots[Snapshot, Event](system: ActorSystem[_], eventsBySlicesQuery: EventsBySliceStartingFromSnapshotsQuery, entityType: String, minSlice: Int, maxSlice: Int, transformSnapshot: Function[Snapshot, Event]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]
  7. def eventsBySlicesStartingFromSnapshots[Snapshot, Event](system: ActorSystem[_], readJournalPluginId: String, entityType: String, minSlice: Int, maxSlice: Int, transformSnapshot: Function[Snapshot, Event], adjustStartOffset: Function[Optional[Offset], CompletionStage[Optional[Offset]]]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]

    By default, the SourceProvider uses the stored offset when starting the Projection.

    By default, the SourceProvider uses the stored offset when starting the Projection. This offset can be adjusted by defining the adjustStartOffset function, which is a function from loaded offset (if any) to the adjusted offset that will be used to by the eventsBySlicesQuery.

  8. def eventsBySlicesStartingFromSnapshots[Snapshot, Event](system: ActorSystem[_], readJournalPluginId: String, entityType: String, minSlice: Int, maxSlice: Int, transformSnapshot: Function[Snapshot, Event]): SourceProvider[Offset, persistence.query.typed.EventEnvelope[Event]]
  9. def eventsByTag[Event](system: ActorSystem[_], eventsByTagQuery: EventsByTagQuery, tag: String): SourceProvider[Offset, EventEnvelope[Event]]
  10. def eventsByTag[Event](system: ActorSystem[_], readJournalPluginId: String, tag: String): SourceProvider[Offset, EventEnvelope[Event]]
  11. def sliceForPersistenceId(system: ActorSystem[_], readJournalPluginId: String, persistenceId: String): Int
  12. def sliceRanges(system: ActorSystem[_], readJournalPluginId: String, numberOfRanges: Int): List[Pair[Integer, Integer]]