import { trace } from '@opentelemetry/api' import { instrument, ResolveConfigFn } from '@inference-net/otel-cf-workers' export interface Env { SIGNOZ_ENDPOINT: string SIGNOZ_ACCESS_TOKEN: string MY_KV: KVNamespace MY_D1: D1Database } const handler = { async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> { // Auto-instrumented: HTTP handler await fetch('https://api.example.com') // Auto-instrumented: outbound fetch await env.MY_KV.get('key') // Auto-instrumented: KV operations await env.MY_D1.prepare('SELECT * FROM users').all() // Auto-instrumented: D1 queries // Manual instrumentation: add custom attributes trace.getActiveSpan()?.setAttribute('user.id', '123') return new Response('Hello World!') }, } const config: ResolveConfigFn = (env: Env, _trigger) => { return { service: { name: 'my-worker' }, trace: { exporter: { url: env.SIGNOZ_ENDPOINT, headers: { 'signoz-access-token': env.SIGNOZ_ACCESS_TOKEN }, }, }, } } export default instrument(handler, config)

import { trace } from '@opentelemetry/api' import { instrument, getLogger, OTLPTransport, ConsoleTransport } from '@inference-net/otel-cf-workers' const handler = { async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> { const logger = getLogger('my-app') // Logs automatically include trace context (trace ID, span ID) logger.info('Processing request', { 'http.url': request.url, 'user.id': '123', }) try { await env.MY_KV.get('key') logger.debug('KV operation complete') return new Response('OK') } catch (error) { // Error logs automatically extract exception info logger.error(error as Error) return new Response('Error', { status: 500 }) } }, } const config: ResolveConfigFn = (env: Env, _trigger) => ({ service: { name: 'my-worker' }, trace: { exporter: { url: `${env.OTEL_ENDPOINT}/v1/traces`, headers: { 'x-api-key': env.API_KEY }, }, }, logs: { transports: [ new OTLPTransport({ url: `${env.OTEL_ENDPOINT}/v1/logs`, headers: { 'x-api-key': env.API_KEY }, }), new ConsoleTransport({ pretty: true }), // Also log to console ], }, }) export default instrument(handler, config)

import { instrumentDO, ResolveConfigFn } from '@inference-net/otel-cf-workers' class MyDurableObject implements DurableObject { async fetch(request: Request): Promise<Response> { // Auto-instrumented: DO fetch handler await this.ctx.storage.get('key') // Auto-instrumented: DO storage await this.ctx.storage.sql.exec('SELECT * FROM data') // Auto-instrumented: DO SQL return new Response('Hello from DO!') } async alarm(): Promise<void> { // Auto-instrumented: DO alarm handler } } const config: ResolveConfigFn = (env, _trigger) => ({ exporter: { url: env.OTEL_ENDPOINT }, service: { name: 'my-durable-object' }, }) export const MyDO = instrumentDO(MyDurableObject, config)

const config: ResolveConfigFn = (env: Env, trigger) => ({ service: { name: 'my-service', version: '1.0.0', // Optional namespace: 'production', // Optional }, trace: { exporter: { url: env.SIGNOZ_ENDPOINT, headers: { 'signoz-access-token': env.SIGNOZ_ACCESS_TOKEN }, }, }, // Logs are optional logs: { transports: [new OTLPTransport({ url: env.LOGS_ENDPOINT })], }, })

const config: ResolveConfigFn = (env, trigger) => ({ // ... exporter config sampling: { // Head sampling: sample 10% of requests at start headSampler: { ratio: 0.1, acceptRemote: true, // Accept parent trace decisions }, // Tail sampling: always keep errors even if not head-sampled tailSampler: (trace) => { const rootSpan = trace.localRootSpan return ( rootSpan.status.code === SpanStatusCode.ERROR || (rootSpan.spanContext().traceFlags & TraceFlags.SAMPLED) !== 0 ) }, }, })

const config: ResolveConfigFn = (env, trigger) => ({ // ... exporter config // Control outbound trace context fetch: { includeTraceContext: (request) => { // Only propagate to same-origin requests return new URL(request.url).hostname === 'api.example.com' }, }, // Control inbound trace context handlers: { fetch: { acceptTraceContext: (request) => { // Accept trace context from trusted origins return request.headers.get('x-trusted') === 'true' }, }, }, })

const config: ResolveConfigFn = (env, trigger) => ({ // ... exporter config postProcessor: (spans) => { return spans.map((span) => { // Redact URLs with tokens if (span.attributes['http.url']) { span.attributes['http.url'] = span.attributes['http.url'].replace(/token=[^&]+/, 'token=REDACTED') } // Remove sensitive headers delete span.attributes['http.request.header.authorization'] return span }) }, })

const config: ResolveConfigFn = (env, trigger) => ({ // ... exporter config propagator: new MyCustomPropagator(), })

import { trace } from '@opentelemetry/api' const handler = { async fetch(request: Request, env: Env) { const span = trace.getActiveSpan() if (span) { span.setAttribute('user.id', '123') span.setAttribute('user.role', 'admin') } return new Response('OK') }, }

import { trace, SpanStatusCode } from '@opentelemetry/api' const handler = { async fetch(request: Request, env: Env) { const tracer = trace.getTracer('my-app') return await tracer.startActiveSpan('process-request', async (span) => { span.setAttribute('request.id', crypto.randomUUID()) try { const result = await doWork() span.setStatus({ code: SpanStatusCode.OK }) return new Response(result) } catch (error) { span.recordException(error) span.setStatus({ code: SpanStatusCode.ERROR }) throw error } finally { span.end() } }) }, }