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

MetricLocalStateEventBus

class MetricLocalStateEventBus(delegate: LocalStateEventBus) : MetricStateEventBus<LocalStateEventBus> , LocalStateEventBus

Metric decorator specifically for local state event buses. Extends MetricStateEventBus to provide metrics collection for local state event bus operations while maintaining the LocalStateEventBus interface.

Parameters

delegate

the underlying local state event bus implementation

Constructors

MetricLocalStateEventBus

constructor(delegate: LocalStateEventBus)

Properties

delegate

override val delegate: LocalStateEventBus

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

The topic kind for state events.

Functions

open override fun close()

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

metrizable

fun LocalStateEventBus.metrizable(): LocalStateEventBus

Wraps a LocalStateEventBus with metrics collection capabilities. Returns a MetricLocalStateEventBus that collects metrics on state event operations.

receive

open override fun receive(subscription: MessageSubscription): Flux<StateEventExchange<*>>

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

receiver

open override fun receiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

Creates a single message source with an explicit transport readiness boundary.

runtimeReceiver

open override fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

Creates the message source owned by a me.ahoo.wow.runtime.WowRuntime dispatcher.

send

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

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

sendIfSubscribed

open override fun sendIfSubscribed(message: StateEvent<*>): Mono<Boolean>

Attempts local delivery only while a processing subscriber is routable.

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate. This delegates to the underlying local state event bus implementation.

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.