add tracing example

planetarium · Jul 11, 2024 · 1973000 · 1973000
1 parent 4e9d8dd
commit 1973000
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 2 deletions.
diff --git a/Lib9c b/Lib9c
diff --git a/NineChronicles.Headless.Executable/NineChronicles.Headless.Executable.csproj b/NineChronicles.Headless.Executable/NineChronicles.Headless.Executable.csproj
@@ -24,6 +24,12 @@
     <PackageReference Include="GraphQL.Client" Version="5.1.1" />
     <PackageReference Include="GraphQL.Client.Serializer.SystemTextJson" Version="5.1.1" />
     <PackageReference Include="Destructurama.Attributed" Version="2.0.0" />
+    <PackageReference Include="OpenTelemetry.Exporter.Console" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.GrpcNetClient" Version="1.9.0-beta.1" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.9.0" />
+    <PackageReference Include="Pyroscope" Version="0.8.14" />
+    <PackageReference Include="Pyroscope.OpenTelemetry" Version="0.2.0" />
     <PackageReference Include="Sentry.Serilog" Version="3.23.0" />
     <PackageReference Include="Sentry" Version="3.23.0" />
     <PackageReference Include="Sentry.AspNetCore.Grpc" Version="3.22.0" />
@@ -42,6 +48,7 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
+    <PackageReference Include="System.Diagnostics.DiagnosticSource" Version="8.0.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/NineChronicles.Headless.Executable/Program.cs b/NineChronicles.Headless.Executable/Program.cs
@@ -41,6 +41,8 @@
 using OpenTelemetry;
 using OpenTelemetry.Metrics;
 using Nekoyume;
+using OpenTelemetry.Resources;
+using OpenTelemetry.Trace;
 
 namespace NineChronicles.Headless.Executable
 {
@@ -474,15 +476,38 @@ IActionLoader MakeSingleActionLoader()
                         MaxTransactionPerBlock = headlessConfig.MaxTransactionPerBlock
                     };
                 var arenaMemoryCache = new StateMemoryCache();
+                string otlpEndpoint = Environment.GetEnvironmentVariable("OPTL_ENDPOINT") ?? "http://localhost:4317";
                 hostBuilder.ConfigureServices(services =>
                 {
                     services.AddSingleton(_ => standaloneContext);
                     services.AddSingleton<ConcurrentDictionary<string, ITransaction>>();
                     services.AddOpenTelemetry()
+                        .ConfigureResource(resource => resource.AddService(
+                                serviceName: Assembly.GetEntryAssembly()?.GetName().Name ?? "NineChronicles.Headless",
+                                serviceVersion: Assembly.GetEntryAssembly()?.GetName().Version?.ToString(),
+                                serviceInstanceId: Environment.MachineName
+                            ).AddAttributes(new Dictionary<string, object>
+                            {
+                                { "deployment.environment", Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Unknown" },
+                            }))
                         .WithMetrics(
                             builder => builder
                                 .AddMeter("NineChronicles")
-                                .AddPrometheusExporter());
+                                .AddPrometheusExporter())
+                        .WithTracing(
+                            builder => builder
+                                .AddSource("Lib9c.Action.HackAndSlash")
+                                .AddSource("Libplanet.Action.State")
+                                .AddSource("Libplanet.Blockchain.BlockChainStates")
+                                //.AddAspNetCoreInstrumentation()
+                                .AddGrpcClientInstrumentation()
+                                .AddConsoleExporter()
+                                .AddProcessor(new Pyroscope.OpenTelemetry.PyroscopeSpanProcessor())
+                                .AddOtlpExporter(opt =>
+                                {
+                                    opt.Endpoint = new Uri(otlpEndpoint, UriKind.Absolute);
+                                })
+                        );
 
                     // worker
                     if (arenaParticipantsSync)

diff --git a/NineChronicles.Headless/NineChronicles.Headless.csproj b/NineChronicles.Headless/NineChronicles.Headless.csproj
@@ -44,6 +44,7 @@
     <PackageReference Include="Microsoft.Data.Sqlite" Version="7.0.11" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.2" />
     <PackageReference Include="NRedisStack" Version="0.9.0" />
+    <PackageReference Include="Pyroscope" Version="0.8.14" />
     <PackageReference Include="Sentry" Version="3.23.0" />
     <PackageReference Include="Sentry.AspNetCore.Grpc" Version="3.22.0" />
     <PackageReference Include="Sentry.DiagnosticSource" Version="3.22.0" />
@@ -64,6 +65,7 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
+    <PackageReference Include="System.Diagnostics.DiagnosticSource" Version="8.0.0" />
   </ItemGroup>
 
   <ItemGroup>
+1 −1		.Libplanet
+92 −0		Lib9c/Action/HackAndSlash.cs
+1 −0		Lib9c/Lib9c.csproj