Distributed Tracing & OpenTelemetry (Trace & Span IDs)

// W3C TraceContext Header Propagation
import { trace, context, propagation } from '@opentelemetry/api';

const tracer = trace.getTracer('payment-service');

export async function processPayment(orderId: string, amount: number) {
  // Start active span inheriting trace parent from active context
  return tracer.startActiveSpan('processPayment', async (span) => {
    span.setAttribute('order.id', orderId);
    span.setAttribute('payment.amount', amount);

    try {
      const chargeResult = await paymentGateway.charge(amount);
      span.setStatus({ code: 1 }); // OK
      return chargeResult;
    } catch (error) {
      span.recordException(error);
      span.setStatus({ code: 2, message: error.message }); // ERROR
      throw error;
    } finally {
      span.end(); // Flushes span metrics to collector
    }
  });
}