Package-level declarations

Abstract base class for metric decorators that provides common functionality for tagging reactive streams with source information. This class implements the Decorator pattern to wrap components and add metrics collection capabilities.

Metric decorator for command buses that collects metrics on command sending and receiving operations. This class wraps any CommandBus implementation and adds metrics collection with tags for aggregate name, command name, and source identification.

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

Metric decorator specifically for distributed command buses. Extends MetricCommandBus to provide metrics collection for distributed command bus operations while maintaining the DistributedCommandBus interface.

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.

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

Metric decorator for domain event buses that collects metrics on domain event sending and receiving operations. This class wraps any DomainEventBus implementation and adds metrics collection with tags for aggregate name and source identification.

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

Metric decorator for event stores that collects metrics on event storage and retrieval operations. This class wraps an EventStore implementation and adds metrics collection with tags for aggregate name and source identification to track event store performance.

Metric decorator specifically for local command buses. Extends MetricCommandBus to provide metrics collection for local command bus operations while maintaining the LocalCommandBus interface.

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

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.

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.

Central utility object for metrics collection and tagging in the Wow framework. Provides constants for metric keys, extension functions for reactive streams tagging, and factory methods to wrap components with metric decorators.

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.

Metric decorator for snapshot repositories that collects metrics on snapshot storage and retrieval operations. This class wraps a SnapshotRepository implementation and adds metrics collection with tags for aggregate name and source identification to track snapshot repository performance.

Metric decorator for snapshot strategies that collects metrics on snapshot strategy operations. This class wraps a SnapshotStrategy and adds metrics collection with tags for aggregate name to track snapshot strategy performance and success rates.

Metric decorator for state event buses that collects metrics on state event sending and receiving operations. This class wraps any StateEventBus implementation and adds metrics collection with tags for aggregate name and source identification.

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.

Marker interface indicating that a component has been wrapped with metrics collection capabilities. Components implementing this interface are already decorated with metric decorators and should not be wrapped again to avoid double metrics collection.