QueueInstrumentation

Register the instrumentation with normalized options.

Register queue listeners, propagation, and instruments.

Determine whether trace output is enabled.

Determine whether a metric is enabled.

Determine whether the throwable is a direct coroutine cancellation.

Ending an operation by direct cancellation is control flow, not a failure.

Return the semantic conventions schema URL for Hypervel instrumentation scopes.

Every tracer, meter and logger obtained for one scope must pass the same URL.

Index callback observers by their matching instrument name.

The SDK supplies observers in the same order as the instruments passed to batchObserve(), so the unchanged name order is the mapping contract.

Create queue instrumentation.

Create enabled queue metric instruments.

Register outbox delivery metrics without observing or resolving ordinary queue operations.

Record confirmed acceptance separately from publication or settlement failure.

Inject propagation and start a persistent producer span.

Complete persistent producer telemetry.

Complete producer telemetry from its started state.

Return a framework UUID from a rewritten terminal payload.

Register flat propagation for local asynchronous queue drivers.

Start consumer telemetry when a job reaches application processing.

Retain the first ordinary consumer failure.

Retain a timeout when no earlier failure explains the attempt.

Complete consumer telemetry at the canonical attempt boundary.

Register collection-only queue depth in event worker zero.

Return low-cardinality attributes shared by queue spans and metrics.

Return configured connection drivers by connection name.

Return a queue operation span name.