feat(otel): Added support for W3C Trace Context format (#1151)
* feat(otel): Added support for W3C Trace Context format * removed unneeded HonoRequestpull/1152/head
parent
0debb59474
commit
414f0a6c95
|
@ -0,0 +1,5 @@
|
||||||
|
---
|
||||||
|
'@hono/otel': minor
|
||||||
|
---
|
||||||
|
|
||||||
|
Added support for W3C Trace Context format
|
|
@ -1,5 +1,5 @@
|
||||||
import type { TracerProvider } from '@opentelemetry/api'
|
import type { TracerProvider } from '@opentelemetry/api'
|
||||||
import { SpanKind, SpanStatusCode, trace } from '@opentelemetry/api'
|
import { SpanKind, SpanStatusCode, trace, context, propagation } from '@opentelemetry/api'
|
||||||
import {
|
import {
|
||||||
ATTR_HTTP_REQUEST_HEADER,
|
ATTR_HTTP_REQUEST_HEADER,
|
||||||
ATTR_HTTP_REQUEST_METHOD,
|
ATTR_HTTP_REQUEST_METHOD,
|
||||||
|
@ -42,6 +42,12 @@ export const otel = <E extends Env = any, P extends string = any, I extends Inpu
|
||||||
const tracerProvider = options.tracerProvider ?? trace.getTracerProvider()
|
const tracerProvider = options.tracerProvider ?? trace.getTracerProvider()
|
||||||
const tracer = tracerProvider.getTracer(PACKAGE_NAME, PACKAGE_VERSION)
|
const tracer = tracerProvider.getTracer(PACKAGE_NAME, PACKAGE_VERSION)
|
||||||
return createMiddleware<E, P, I>(async (c, next) => {
|
return createMiddleware<E, P, I>(async (c, next) => {
|
||||||
|
// Handle propagation of trace context from a request using the W3C Trace Context format
|
||||||
|
let activeContext = context.active()
|
||||||
|
if (c.req.header('traceparent')) {
|
||||||
|
activeContext = propagation.extract(context.active(), c.req.header())
|
||||||
|
}
|
||||||
|
|
||||||
const routePath = c.req.routePath
|
const routePath = c.req.routePath
|
||||||
await tracer.startActiveSpan(
|
await tracer.startActiveSpan(
|
||||||
`${c.req.method} ${c.req.routePath}`,
|
`${c.req.method} ${c.req.routePath}`,
|
||||||
|
@ -53,6 +59,7 @@ export const otel = <E extends Env = any, P extends string = any, I extends Inpu
|
||||||
[ATTR_HTTP_ROUTE]: routePath,
|
[ATTR_HTTP_ROUTE]: routePath,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
activeContext,
|
||||||
async (span) => {
|
async (span) => {
|
||||||
for (const [name, value] of Object.entries(c.req.header())) {
|
for (const [name, value] of Object.entries(c.req.header())) {
|
||||||
span.setAttribute(ATTR_HTTP_REQUEST_HEADER(name), value)
|
span.setAttribute(ATTR_HTTP_REQUEST_HEADER(name), value)
|
||||||
|
|
Loading…
Reference in New Issue