|
| 1 | +using System; |
| 2 | +using System.Diagnostics; |
| 3 | +using System.Threading.Tasks; |
| 4 | +using Microsoft.Extensions.Logging; |
| 5 | +using OpenTelemetry; |
| 6 | +using OpenTelemetry.Metrics; |
| 7 | +using OpenTelemetry.Resources; |
| 8 | +using OpenTelemetry.Trace; |
| 9 | +using Proto; |
| 10 | +using Proto.OpenTelemetry; |
| 11 | + |
| 12 | +// Configure logging so Proto.Actor writes to the console |
| 13 | +var loggerFactory = LoggerFactory.Create(builder => builder.AddConsole()); |
| 14 | +Log.SetLoggerFactory(loggerFactory); |
| 15 | + |
| 16 | +// Export spans and metrics to the console and an OTLP collector (e.g., TraceLens) |
| 17 | +using var tracerProvider = Sdk.CreateTracerProviderBuilder() |
| 18 | + .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService("ActorOpenTelemetrySample")) |
| 19 | + .AddProtoActorInstrumentation() |
| 20 | + .AddConsoleExporter() |
| 21 | + .AddOtlpExporter() |
| 22 | + .Build(); |
| 23 | + |
| 24 | +using var meterProvider = Sdk.CreateMeterProviderBuilder() |
| 25 | + .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService("ActorOpenTelemetrySample")) |
| 26 | + .AddProtoActorInstrumentation() |
| 27 | + .AddConsoleExporter() |
| 28 | + .AddOtlpExporter() |
| 29 | + .Build(); |
| 30 | + |
| 31 | +var system = new ActorSystem(ActorSystemConfig.Setup().WithMetrics()); |
| 32 | + |
| 33 | +// Simple actor that prints its trace id |
| 34 | +var props = Props.FromFunc(ctx => |
| 35 | +{ |
| 36 | + if (ctx.Message is string msg) |
| 37 | + { |
| 38 | + Console.WriteLine($"[actor] received '{msg}' traceId={Activity.Current?.TraceId}"); |
| 39 | + } |
| 40 | + |
| 41 | + return Task.CompletedTask; |
| 42 | +}).WithTracing(); |
| 43 | + |
| 44 | +var pid = system.Root.Spawn(props); |
| 45 | +var tracedRoot = system.Root.WithTracing(); |
| 46 | + |
| 47 | +using var rootActivity = new ActivitySource(Proto.ProtoTags.ActivitySourceName).StartActivity("root"); |
| 48 | +tracedRoot.Send(pid, "hello"); |
| 49 | + |
| 50 | +// Flush telemetry before exiting |
| 51 | +tracerProvider.ForceFlush(); |
| 52 | +meterProvider.ForceFlush(); |
| 53 | + |
| 54 | +Console.WriteLine("Press enter to exit"); |
| 55 | +Console.ReadLine(); |
0 commit comments