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.

existsRequestId

open override fun existsRequestId(aggregateId: AggregateId, requestId: String): Mono<Boolean>

Checks whether the request ID already exists for the specified aggregate.

last

abstract fun last(aggregateId: AggregateId): Mono<DomainEventStream>

Loads the last domain event stream for the specified aggregate.

load

open override fun load(aggregateId: AggregateId, headVersion: Int = DEFAULT_HEAD_VERSION, tailVersion: Int = DEFAULT_TAIL_VERSION): 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.

scanAggregateId

open fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String = FIRST_ID, limit: Int = 10): Flux<AggregateId>

Scans for aggregate IDs within the specified named aggregate, starting after the given ID. Returns a limited number of aggregate IDs in lexicographical order.

single

open fun single(aggregateId: AggregateId, version: Int): Mono<DomainEventStream>

Loads a single domain event stream for the specified aggregate at the given version.