load
open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>
Loads domain event streams for the specified aggregate ID within the given version range and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification.
Return
a Flux of domain event streams
Parameters
aggregateId
the aggregate ID to load events for
headVersion
the starting version number (inclusive)
tailVersion
the ending version number (inclusive)
open override fun load(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>
Loads domain event streams for the specified aggregate ID within the given time range and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification.
Return
a Flux of domain event streams
Parameters
aggregateId
the aggregate ID to load events for
headEventTime
the starting event time (inclusive) in milliseconds since epoch
tailEventTime
the ending event time (inclusive) in milliseconds since epoch