Provide metrics for NineChronicles node

See https://github.com/planetarium/9c-headless-metric-gql-aggregator
planetarium · Feb 1, 2023 · 4bb0c7a · 4bb0c7a
1 parent 3249a4f
commit 4bb0c7a
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 0 deletions.
diff --git a/NineChronicles.Headless/ActionEvaluationPublisher.cs b/NineChronicles.Headless/ActionEvaluationPublisher.cs
@@ -3,6 +3,7 @@
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Collections.Immutable;
+using System.Diagnostics.Metrics;
 using System.IO;
 using System.IO.Compression;
 using System.Linq;
@@ -66,6 +67,12 @@ public ActionEvaluationPublisher(
             _context = context;
             _sentryTraces = sentryTraces;
 
+            var meter = new Meter("NineChronicles");
+            meter.CreateObservableGauge(
+                "ninechronicles_rpc_clients_count",
+                () => this.GetClients().Count,
+                description: "Number of RPC clients connected.");
+
             ActionEvaluationHub.OnClientDisconnected += RemoveClient;
         }
 

diff --git a/NineChronicles.Headless/HostBuilderExtensions.cs b/NineChronicles.Headless/HostBuilderExtensions.cs
@@ -84,6 +84,7 @@ RpcNodeServiceProperties properties
                     services.AddOpenTelemetry()
                         .WithMetrics(
                             builder => builder
+                                .AddMeter("NineChronicles")
                                 .AddRuntimeInstrumentation()
                                 .AddAspNetCoreInstrumentation()
                                 .AddPrometheusExporter());

diff --git a/NineChronicles.Headless/NineChroniclesNodeService.cs b/NineChronicles.Headless/NineChroniclesNodeService.cs
@@ -21,6 +21,7 @@
 using System.Linq;
 using System.Collections.Generic;
 using System.Collections.Immutable;
+using System.Diagnostics.Metrics;
 using System.Reflection;
 using System.Security.Cryptography;
 using System.Threading;
@@ -278,6 +279,19 @@ StandaloneContext context
                 txQuotaPerSigner: properties.TxQuotaPerSigner
             );
             service.ConfigureContext(context);
+            var meter = new Meter("NineChronicles");
+            meter.CreateObservableGauge(
+                "ninechronicles_tip_index",
+                () => service.BlockChain.Tip.Index,
+                description: "The tip block's index.");
+            meter.CreateObservableGauge(
+                "ninechronicles_staged_txids_count",
+                () => service.BlockChain.GetStagedTransactionIds().Count,
+                description: "Number of staged transactions.");
+            meter.CreateObservableGauge(
+                "ninechronicles_subscriber_addresses_count",
+                () => context.AgentAddresses.Count);
+
             return service;
         }