@pmcollab/coworkstream-otel

OpenTelemetry instrumentation for @pmcollab/coworkstream-engine.

Install

npm install @pmcollab/coworkstream-otel @opentelemetry/api

Use

import { trace, metrics } from '@opentelemetry/api'
import { instrumentEngine } from '@pmcollab/coworkstream-otel'
import { createEngine } from '@pmcollab/coworkstream-engine'

const engine = createEngine({ /* ... */ })
instrumentEngine(engine, {
  tracer: trace.getTracer('workstream', '0.1.0'),
  meter:  metrics.getMeter('workstream', '0.1.0'),
})

What you get

Spans:

• workstream.engine.process — wraps the full process() call
• workstream.engine.dispatch — child span for the parallel agent run
• workstream.engine.resolve — wraps human resolution

Span attributes:

• workstream.item.id, workstream.item.category, workstream.item.priority
• workstream.dispatch.agent_count, workstream.dispatch.error_count
• workstream.alignment.status, workstream.escalated
• workstream.action, workstream.user.id (resolve)

Metrics:

• workstream.engine.processed_total (counter, by category + status)
• workstream.engine.escalated_total (counter, by category)
• workstream.engine.auto_resolved_total (counter, by category)
• workstream.engine.resolved_total (counter, by action)
• workstream.engine.dispatch_ms (histogram)

Without an OTel SDK installed, instrumentEngine is a no-op — safe to leave on in dev.

License

Commercial. See LICENSE in the repository root.