Creates an Akka Streams source stage that emits the
DurableEvents stored in eventLog
.
Creates an Akka Streams source stage that emits the
DurableEvents stored in eventLog
. The source also emits events that have been written to the event log after
source creation. Behavior of the source can be configured with:
eventuate.log.replay-batch-size
. Maximum number of events to read from the event log when the internal
buffer (of same size) is empty.eventuate.log.read-timeout
. Timeout for reading events from the event log.eventuate.log.replay-retry-delay
. Delay between a failed read and the next read retry.
source event log.
sequence number from where the DurableEvent stream should start.
if defined, emit only DurableEvents with that aggregate id, otherwise, emit DurableEvents with any aggregate id (see also event routing).
Stream-based alternative to EventsourcedView.