persistenceIdPage

persistenceIdPage(all, afterPersistenceId, limit): string[]

Defined in: src/persistence/Journal.ts:118

Cut one page out of a full list of persistence ids — the reference semantics every Journal.persistenceIdsPaginated implementation has to match, and the fallback the query layer uses for a journal that has no such method.

Lives here rather than in the query layer because it is a statement about the journal contract: it defines what “ascending” and “after” mean for a backend that has no opinion of its own. InMemoryJournal uses it as its implementation; the tests use it as the oracle the SQL and CQL push-downs are checked against.

The dedupe is not redundant with persistenceIds() being distinct: it is what makes “each id exactly once per sweep” hold even for a journal whose enumeration repeats an id, and it costs one pass over a list already being sorted.

Parameters

all

readonly string[]

afterPersistenceId

string | undefined

limit

number

Returns

string[]