messaging/src

Classes

• EventPublisher
• InProcessBus
• MessageClient
• OktoidTransportStrategy
• Receiver
• StreamAbsentError
• StreamMismatchError
• WireError
• WiringError

Interfaces

• AccessDenial
• ActorVerificationInput
• ActorVerifier
• BrokerServer
• BrokerWire
• Clock
• ConnectNatsOptions
• DeclaredStream
• ErrorDescription
• EventPublication
• EventPublisherOptions
• HandlerContext
• IdempotencyInfo
• Inbound
• InProcessRequest
• LeafScopeRequest
• MessageClientOptions
• MessagingLogger
• OktoidTransportOptions
• PlatformGrantEvidence
• ReceiverOptions
• RequestCall
• Served
• StoredTrace
• StreamBounds
• WireMessage
• WireResponse
• WireSubscription

Type Aliases

• AccessDenyHook
• ActorVerification
• Adapter
• DeclaredConsumerConfig
• DeclaredStreamConfig
• DeclareOutcome
• DenyReason
• EventKey
• Handler
• HandlerMap
• IdempotencyHook
• KeyedTo
• LeafScopeMinter
• MintedScope
• ProveActor
• ReceiveOutcome
• RequestKey
• ScopeFromActor
• StreamName
• WireErrorKind

Variables

• MESSAGING_SPAN_ATTRIBUTES
• silentLogger
• STREAM_BOUNDS
• systemClock
• TRACEPARENT_HEADER

Functions

• activeTraceId
• captureTrace
• connectNats
• consumerConfig
• consumerMismatches
• declareStreams
• describeError
• extractTrace
• inHandlerSpan
• injectTrace
• inSendSpan
• natsWire
• openConsumer
• serveBroker
• streamConfig
• streamMismatches
• withStoredTrace