Package akka.persistence.query.typed.scaladsl

Interface Summary

Interface	Description
CurrentEventsByPersistenceIdStartingFromSnapshotQuery	A plugin may optionally support this query by implementing this trait.
CurrentEventsByPersistenceIdTypedQuery	A plugin may optionally support this query by implementing this trait.
CurrentEventsBySliceQuery	A plugin may optionally support this query by implementing this trait.
CurrentEventsBySliceStartingFromSnapshotsQuery	A plugin may optionally support this query by implementing this trait.
CurrentPersistenceIdsForEntityTypeQuery	A plugin may optionally support this query by implementing this trait.
DurableStateStoreBySliceQuery<A>	Query API for reading durable state objects.
EventsByPersistenceIdStartingFromSnapshotQuery	A plugin may optionally support this query by implementing this trait.
EventsByPersistenceIdTypedQuery	A plugin may optionally support this query by implementing this trait.
EventsBySliceQuery	A plugin may optionally support this query by implementing this trait.
EventsBySliceStartingFromSnapshotsQuery	A plugin may optionally support this query by implementing this trait.
EventTimestampQuery	EventsBySliceQuery that is using a timestamp based offset should also implement this query.
LatestEventTimestampQuery	Retrieve the latest timestamp for an entity type and slice range.
LoadEventQuery	EventsBySliceQuery that is using a timestamp based offset should also implement this query.

Class Summary

Class	Description
EventsBySliceFirehoseQuery	This wrapper of EventsBySliceQuery gives better scalability when many consumers retrieve the same events, for example many Projections of the same entity type.
EventsBySliceFirehoseQuery$