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

MetricStatelessSagaHandler

class MetricStatelessSagaHandler(val delegate: StatelessSagaHandler) : StatelessSagaHandler, Decorator<StatelessSagaHandler>

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

Constructors

constructor(delegate: StatelessSagaHandler)

Properties

delegate

open override val delegate: StatelessSagaHandler

the underlying stateless saga handler implementation

Functions

handle

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

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

metrizable

fun StatelessSagaHandler.metrizable(): StatelessSagaHandler

Wraps a StatelessSagaHandler with metrics collection capabilities. Returns a MetricStatelessSagaHandler that collects metrics on saga handling operations.