wow-core/me.ahoo.wow.eventsourcing/AbstractEventStore

AbstractEventStore

abstract class AbstractEventStore : EventStore

Abstract base implementation of EventStore that provides common functionality for event storage and retrieval. This class handles logging, validation, and error mapping for event stream operations.

Inheritors

InMemoryEventStore

Constructors

AbstractEventStore

constructor()

Functions

append

open override fun append(eventStream: DomainEventStream): Mono<Void>

Appends a domain event stream to the event store. Logs the operation and maps version conflicts to appropriate exceptions.

load

open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>

Loads domain event streams for the specified aggregate within the given version range. Validates that headVersion is non-negative and tailVersion is greater than or equal to headVersion.

open override fun load(aggregateId: AggregateId, headEventTime: Long, tailEventTime: Long): Flux<DomainEventStream>

Loads domain event streams for the specified aggregate within the given event time range. Validates that tailEventTime is greater than or equal to headEventTime.

metrizable

fun EventStore.metrizable(): EventStore

Wraps an EventStore with metrics collection capabilities. Returns a MetricEventStore that collects metrics on event storage operations.