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

MetricDistributedDomainEventBus

class MetricDistributedDomainEventBus(delegate: DistributedDomainEventBus) : MetricDomainEventBus<DistributedDomainEventBus> , DistributedDomainEventBus

Metric decorator specifically for distributed domain event buses. Extends MetricDomainEventBus to provide metrics collection for distributed domain event bus operations while maintaining the DistributedDomainEventBus interface.

Constructors

constructor(delegate: DistributedDomainEventBus)

Properties

delegate

override val delegate: DistributedDomainEventBus

the original component being decorated, must implement the Decorator interface

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.

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

Closes the domain event bus and releases any resources. This delegates to the underlying domain event bus implementation.

metrizable

fun DistributedDomainEventBus.metrizable(): DistributedDomainEventBus

Wraps a DistributedDomainEventBus with metrics collection capabilities. Returns a MetricDistributedDomainEventBus that collects metrics on domain event operations.

receive

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

Receives event stream exchanges for the specified named aggregates and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification and subscriber information.

send

open override fun send(message: DomainEventStream): Mono<Void>

Sends a domain event stream and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

tagSource

fun <M> 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> 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.