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

MetricSnapshotHandler

class MetricSnapshotHandler(val delegate: SnapshotHandler) : SnapshotHandler, Decorator<SnapshotHandler>

Metric decorator for snapshot handlers that collects metrics on snapshot processing operations. This class wraps a SnapshotHandler and adds metrics collection with tags for aggregate name to track snapshot handling performance and success rates.

Constructors

constructor(delegate: SnapshotHandler)

Properties

delegate

open override val delegate: SnapshotHandler

the underlying snapshot handler implementation

Functions

handle

open override fun handle(exchange: StateEventExchange<*>): Mono<Void>

Handles a state event exchange for snapshot creation and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

metrizable

fun SnapshotHandler.metrizable(): SnapshotHandler

Wraps a SnapshotHandler with metrics collection capabilities. Returns a MetricSnapshotHandler that collects metrics on snapshot handling operations.