MonadicSharp.Telemetry 1.0.0

MonadicSharp.Telemetry

OpenTelemetry tracing and metrics for AI agent pipelines — zero overhead when disabled.

Overview

MonadicSharp.Telemetry integrates agent pipelines with the OpenTelemetry ecosystem:

• Distributed tracing — one Activity span per agent, one root span per pipeline
• Metrics — execution count, latency histograms, failure rates via System.Diagnostics.Metrics
• TelemetryAgentWrapper — transparent decorator that instruments any IAgent<TIn, TOut>
• TelemetryAgentOrchestrator — instrumented orchestrator with per-dispatch spans
• TelemetryPipelineExtensions — WithTelemetry() fluent extension for pipelines
• Zero overhead when no listener is subscribed (standard .NET ActivitySource model)

Installation

dotnet add package MonadicSharp.Telemetry

Setup

DI Registration

services.AddMonadicSharpTelemetry("MyApp");

Hook into your OpenTelemetry pipeline

builder.Services.AddOpenTelemetry()
    .WithTracing(tracing => tracing
        .AddSource(TelemetryConstants.ActivitySourceName) // "MonadicSharp.Agents"
        .AddJaegerExporter()
        .AddConsoleExporter())
    .WithMetrics(metrics => metrics
        .AddMeter(TelemetryConstants.MeterName)           // "MonadicSharp.Agents"
        .AddPrometheusExporter());

Tracing

Instrument a single agent

IAgent<string, string> tracedAgent = new TelemetryAgentWrapper<string, string>(
    inner: summaryAgent,
    activitySource: AgentActivitySource.Source);

Instrument a pipeline

var result = await AgentPipeline
    .Start("DocumentProcessing", extractorAgent)
    .Then(classifierAgent)
    .WithTelemetry()           // adds pipeline root span
    .RunAsync(input, context);

Spans emitted

Metrics

// Injected via DI
public class MyService(AgentMeter meter)
{
    public async Task RunAsync(...)
    {
        meter.RecordExecution("SummaryAgent", success: true, durationMs: 120);
        meter.RecordPipelineRun("DocumentProcessing", stepCount: 3, success: true);
    }
}

Instruments registered

Telemetry Constants

TelemetryConstants.ActivitySourceName // "MonadicSharp.Agents"
TelemetryConstants.MeterName          // "MonadicSharp.Agents"
TelemetryConstants.AttrAgentName      // "agent.name"
TelemetryConstants.AttrPipelineName   // "pipeline.name"
TelemetryConstants.AttrSessionId      // "session.id"

TelemetryAgentOrchestrator

Drop-in replacement for AgentOrchestrator with automatic span wrapping:

var orchestrator = new TelemetryAgentOrchestrator(AgentActivitySource.Source);
orchestrator.Register("summary", summaryAgent);

// Each RunAsync call emits an "agent.execute" span
var result = await orchestrator.RunAsync("summary", input, context);

License

MIT — part of MonadicSharp.Framework.