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

MetricEventStore

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

Constructors

MetricEventStore

constructor(delegate: EventStore)

Properties

override val delegate: EventStore

open override val name: String

Functions

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

Append event stream to EventStore. Ensure transaction consistency.

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

根据聚合ID加载事件流.

fun EventStore.metrizable(): EventStore

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

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