@flowcraft/opentelemetry-middleware

OpenTelemetry middleware for Flowcraft workflows, providing distributed tracing and observability.

Installation

npm install @flowcraft/opentelemetry-middleware

Usage

import { FlowRuntime } from 'flowcraft'
import { OpenTelemetryMiddleware } from '@flowcraft/opentelemetry-middleware'
import { NodeSDK } from '@opentelemetry/sdk-node'
import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http'

// Set up OpenTelemetry SDK
const sdk = new NodeSDK({
  traceExporter: new OTLPTraceExporter(),
})
sdk.start()

// Create middleware
const otelMiddleware = new OpenTelemetryMiddleware('flowcraft-worker')

// Add to FlowRuntime
const runtime = new FlowRuntime({
  middleware: [otelMiddleware],
})

Features

• Distributed tracing across workflow executions
• Automatic span creation for each node
• Context propagation between nodes
• Error recording and status tracking