t

akka.persistence.query.javadsl

PagedPersistenceIdsQuery

trait PagedPersistenceIdsQuery extends ReadJournal

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

Source
PagedPersistenceIdsQuery.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PagedPersistenceIdsQuery
  2. ReadJournal
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. 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.