PagedPersistenceIdsQuery

All Superinterfaces:: ReadJournal

public interface PagedPersistenceIdsQuery extends ReadJournal

A ReadJournal may optionally support this query by implementing this trait.

Method Summary

Modifier and Type

Method

Description

Source<String,NotUsed>

currentPersistenceIds(Optional<String> afterId, long limit)

Get the current persistence ids.

Method Details
- currentPersistenceIds
  
  Source<String,NotUsed> currentPersistenceIds(Optional<String> afterId, long limit)
  
  Get the current persistence ids.
  Not all plugins may support in database paging, and may simply use drop/take Pekko 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.