wow-core/me.ahoo.wow.metrics/MetricEventStore

MetricEventStore

class MetricEventStore(delegate: EventStore) : AbstractMetricDecorator<EventStore> , EventStore, Metrizable

Metric decorator for event stores that collects metrics on event storage and retrieval operations. This class wraps an EventStore implementation and adds metrics collection with tags for aggregate name and source identification to track event store performance.

Constructors

MetricEventStore

constructor(delegate: EventStore)

Properties

delegate

override val delegate: EventStore

the original component being decorated, must implement the Decorator interface

source

val source: String

The source identifier derived from the original delegate's class name. This is used for metrics tagging to identify the component type.

Functions

append

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

Appends a domain event stream to the event store and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

existsRequestId

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

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

last

open override 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 ID within the given version range and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification.

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.

metrizable

fun EventStore.metrizable(): EventStore

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

scanAggregateId

open override 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.

tagSource

fun <M : Any> Flux<M>.tagSource(): Flux<M>

Extension function to tag a Flux publisher with the current source identifier. This adds the source tag to metrics collected from this reactive stream.

fun <M : Any> Mono<M>.tagSource(): Mono<M>

Extension function to tag a Mono publisher with the current source identifier. This adds the source tag to metrics collected from this reactive stream.