scanAggregateId
open override fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String, limit: Int): Flux<AggregateId>
Scans for aggregate IDs in the snapshot repository starting after the specified ID and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification.
Return
a Flux of aggregate IDs
Parameters
namedAggregate
the named aggregate to scan for
afterId
the aggregate ID to start scanning after
limit
the maximum number of aggregate IDs to return