Package akka.persistence.query.javadsl
Interface DurableStateStorePagedPersistenceIdsQuery<A>
- 
- All Superinterfaces:
- DurableStateStore<A>
 - All Known Implementing Classes:
- PersistenceTestKitDurableStateStore
 
 public interface DurableStateStorePagedPersistenceIdsQuery<A> extends DurableStateStore<A> A DurableStateStore may optionally support this query by implementing this trait.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<java.lang.String,NotUsed>currentPersistenceIds(java.util.Optional<java.lang.String> afterId, long limit)Get the current persistence ids.- 
Methods inherited from interface akka.persistence.state.javadsl.DurableStateStoregetObject
 
- 
 
- 
- 
- 
Method Detail- 
currentPersistenceIdsSource<java.lang.String,NotUsed> currentPersistenceIds(java.util.Optional<java.lang.String> afterId, long limit) Get the current persistence ids.Not all plugins may support in database paging, and may simply use drop/take Akka streams operators to manipulate the result set according to the paging parameters. - Parameters:
- afterId- The ID to start returning results from, or empty to return all ids. This should be an id returned from a previous invocation of this command. Callers should not assume that ids are returned in sorted order.
- limit- The maximum results to return. Use Long.MAX_VALUE to return all results. Must be greater than zero.
- Returns:
- A source containing all the persistence ids, limited as specified.
 
 
- 
 
-