trait DurableStateStorePagedPersistenceIdsQuery[A] extends DurableStateStore[A]
Ordering
- Alphabetic
- By Inheritance
Inherited
- DurableStateStorePagedPersistenceIdsQuery
- DurableStateStore
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def currentPersistenceIds(afterId: Optional[String], limit: Long): Source[String, NotUsed]
Get the current persistence ids.
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.
- 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.
- abstract def getObject(persistenceId: String): [GetObjectResult[A]]
- Definition Classes
- DurableStateStore
A DurableStateStore may optionally support this query by implementing this trait.