Package-level declarations
Types
Link copied to clipboard
class OpenTelemetryAMQPChannel(delegate: <Error class: unknown class>, tracer: <Error class: unknown class>, config: TracingConfig = TracingConfig.default())
OpenTelemetry-instrumented wrapper around AMQPChannel.
Link copied to clipboard
class OpenTelemetryAMQPConnection(delegate: <Error class: unknown class>, tracer: <Error class: unknown class>, tracingConfig: TracingConfig = TracingConfig.default())
OpenTelemetry-instrumented wrapper around AMQPConnection.
Link copied to clipboard
object SemanticAttributes
OpenTelemetry semantic conventions for messaging systems.
Link copied to clipboard
object SpanPropagator
Handles W3C Trace Context propagation via AMQP message headers.
Link copied to clipboard
data class TracingConfig(val traceConnectionOperations: Boolean = false, val traceChannelManagementOperations: Boolean = false, val captureMessageBody: Boolean = false, val maxBodySizeToCapture: Int = 1024, val publishSpanNameFormatter: (exchange: String, routingKey: String) -> String = defaultPublishSpanNameFormatter, val consumeSpanNameFormatter: (queue: String) -> String = defaultConsumeSpanNameFormatter)
Configuration options for OpenTelemetry tracing behavior.
Functions
Link copied to clipboard
fun <Error class: unknown class>.withTracing(tracer: <Error class: unknown class>, tracingConfig: TracingConfig = TracingConfig.default()): <Error class: unknown class>
Wraps an existing channel with OpenTelemetry instrumentation.
fun <Error class: unknown class>.withTracing(tracer: <Error class: unknown class>, tracingConfig: TracingConfig = TracingConfig.default()): <Error class: unknown class>
Wraps an existing connection with OpenTelemetry instrumentation.