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

MetricSnapshotStore

class MetricSnapshotStore(delegate: SnapshotStore) : AbstractMetricDecorator<SnapshotStore> , SnapshotStore

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

Constructors

MetricSnapshotStore

constructor(delegate: SnapshotStore)

Properties

delegate

override val delegate: SnapshotStore

the original component being decorated, must implement the Decorator interface

name

open override val name: String

The name of the snapshot store. This delegates to the underlying snapshot store implementation.

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

getVersion

open override fun getVersion(aggregateId: AggregateId): Mono<Int>

Gets the version of the latest snapshot for the specified aggregate ID and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification.

load

open override fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

Loads a snapshot for the specified aggregate ID and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

metrizable

fun SnapshotStore.metrizable(): SnapshotStore

Wraps a SnapshotStore with metrics collection capabilities. Returns a MetricSnapshotStore that collects metrics on snapshot storage operations.

save

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>

Saves a snapshot and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

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.