Merge pull request #19 from MarimerLLC/feature/otel-alloy-integration

Hook up OpenTelemetry to Grafana Alloy collector in k8s

Author: rockfordlhotka

k8s/configmap.yaml

@@ -10,3 +10,4 @@ data:
   ASPNETCORE_ENVIRONMENT: Production
   ASPNETCORE_URLS: http://+:8080
   MCPAGGREGATOR__DATADIRECTORY: /data
+  OTEL_EXPORTER_OTLP_ENDPOINT: http://alloy.loki.svc.cluster.local:4317

src/McpAggregator.HttpServer/McpAggregator.HttpServer.csproj

@@ -20,6 +20,7 @@
     <PackageReference Include="Scalar.AspNetCore" Version="2.*" />
     <PackageReference Include="Serilog.AspNetCore" Version="9.*" />
     <PackageReference Include="Serilog.Sinks.OpenTelemetry" Version="4.*" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.*" />
     <PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.*" />
     <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.*" />
   </ItemGroup>

src/McpAggregator.HttpServer/ServeCommand.cs

@@ -6,6 +6,7 @@
 using Microsoft.Extensions.AI;
 using Microsoft.Extensions.Options;
 using OpenTelemetry.Metrics;
+using OpenTelemetry.Resources;
 using OpenTelemetry.Trace;
 using Scalar.AspNetCore;
 using Serilog;
@@ -69,8 +70,19 @@ public override async Task<int> ExecuteAsync(CommandContext context, ServeSettin
 
         // OpenTelemetry tracing & metrics
         builder.Services.AddOpenTelemetry()
-            .WithTracing(t => t.AddAspNetCoreInstrumentation())
-            .WithMetrics(m => m.AddAspNetCoreInstrumentation());
+            .ConfigureResource(r => r.AddService("mcp-aggregator"))
+            .WithTracing(t =>
+            {
+                t.AddAspNetCoreInstrumentation();
+                if (!string.IsNullOrEmpty(otlpEndpoint))
+                    t.AddOtlpExporter(o => o.Endpoint = new Uri(otlpEndpoint));
+            })
+            .WithMetrics(m =>
+            {
+                m.AddAspNetCoreInstrumentation();
+                if (!string.IsNullOrEmpty(otlpEndpoint))
+                    m.AddOtlpExporter(o => o.Endpoint = new Uri(otlpEndpoint));
+            });
 
         // Core services
         builder.Services.AddAggregatorCore(builder.Configuration);