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

MetricProjectionHandler

class MetricProjectionHandler(val delegate: ProjectionHandler) : ProjectionHandler, Decorator<ProjectionHandler>

Metric decorator for projection handlers that collects metrics on projection processing operations. This class wraps a ProjectionHandler and adds metrics collection with tags for aggregate name, event name, and processor name to track projection performance and success rates.

Constructors

constructor(delegate: ProjectionHandler)

Properties

delegate

open override val delegate: ProjectionHandler

the underlying projection handler implementation

Functions

handle

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

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

metrizable

fun ProjectionHandler.metrizable(): ProjectionHandler

Wraps a ProjectionHandler with metrics collection capabilities. Returns a MetricProjectionHandler that collects metrics on projection handling operations.