wow-opentelemetry/me.ahoo.wow.opentelemetry.messaging

Package-level declarations

Types

CommandProducerInstrumenter

object CommandProducerInstrumenter

CommandProducerSpanNameExtractor

object CommandProducerSpanNameExtractor : SpanNameExtractor<CommandMessage<*>>

EventProducerInstrumenter

object EventProducerInstrumenter

EventProducerSpanNameExtractor

object EventProducerSpanNameExtractor : SpanNameExtractor<DomainEventStream>

MessageExchangeTextMapGetter

class MessageExchangeTextMapGetter<E : MessageExchange<*, Message<*, *>>> : TextMapGetter<E>

MessageTextMapSetter

class MessageTextMapSetter<M : Message<*, *>> : TextMapSetter<M>

StateEventProducerInstrumenter

object StateEventProducerInstrumenter

StateEventProducerProducerSpanNameExtractor

object StateEventProducerProducerSpanNameExtractor : SpanNameExtractor<StateEvent<*>>

TracingDistributedCommandBus

class TracingDistributedCommandBus(val delegate: DistributedCommandBus, val producerInstrumenter: Instrumenter<CommandMessage<*>, Unit> = CommandProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<CommandMessage<*>, ServerCommandExchange<*>, DistributedCommandBus> , DistributedCommandBus

TracingDistributedEventBus

class TracingDistributedEventBus(val delegate: DistributedDomainEventBus, val producerInstrumenter: Instrumenter<DomainEventStream, Unit> = EventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<DomainEventStream, EventStreamExchange, DistributedDomainEventBus> , DistributedDomainEventBus

TracingDistributedStateEventBus

class TracingDistributedStateEventBus(val delegate: DistributedStateEventBus, val producerInstrumenter: Instrumenter<StateEvent<*>, Unit> = StateEventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<StateEvent<*>, StateEventExchange<*>, DistributedStateEventBus> , DistributedStateEventBus

TracingLocalCommandBus

class TracingLocalCommandBus(val delegate: LocalCommandBus, val producerInstrumenter: Instrumenter<CommandMessage<*>, Unit> = CommandProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<CommandMessage<*>, ServerCommandExchange<*>, LocalCommandBus> , LocalCommandBus

TracingLocalEventBus

class TracingLocalEventBus(val delegate: LocalDomainEventBus, val producerInstrumenter: Instrumenter<DomainEventStream, Unit> = EventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<DomainEventStream, EventStreamExchange, LocalDomainEventBus> , LocalDomainEventBus

TracingLocalStateEventBus

class TracingLocalStateEventBus(val delegate: LocalStateEventBus, val producerInstrumenter: Instrumenter<StateEvent<*>, Unit> = StateEventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<StateEvent<*>, StateEventExchange<*>, LocalStateEventBus> , LocalStateEventBus

TracingMessageBus

interface TracingMessageBus<M : Message<*, *>, E : MessageExchange<*, M>, B : MessageBus<M, E>> : MessageBus<M, E> , Decorator<B>