Package akka.persistence.query.scaladsl
Interface PagedPersistenceIdsQuery
- 
- All Superinterfaces:
 ReadJournal
- All Known Implementing Classes:
 PersistenceTestKitReadJournal
public interface PagedPersistenceIdsQuery extends ReadJournal
A plugin ReadJournal may optionally support this query by implementing this trait. 
- 
- 
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<java.lang.String,NotUsed>currentPersistenceIds(scala.Option<java.lang.String> afterId, long limit)Get the current persistence ids. 
 - 
 
- 
- 
Method Detail
- 
currentPersistenceIds
Source<java.lang.String,NotUsed> currentPersistenceIds(scala.Option<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, orNoneto 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.MaxValue to return all results. Must be greater than zero.- Returns:
 - A source containing all the persistence ids, limited as specified.
 
 
 - 
 
 -