From 34bf80ba9c2b35f7d4be8829bc73c1b37da485b2 Mon Sep 17 00:00:00 2001
From: Tyera Eulberg <teulberg@gmail.com>
Date: Fri, 13 Nov 2020 12:31:23 -0700
Subject: [PATCH] Send pubsub metrics to metrics server (#13584)

---
 core/src/rpc_subscriptions.rs | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/core/src/rpc_subscriptions.rs b/core/src/rpc_subscriptions.rs
index 0a2364830b..7c38833aa1 100644
--- a/core/src/rpc_subscriptions.rs
+++ b/core/src/rpc_subscriptions.rs
@@ -936,6 +936,19 @@ impl RpcSubscriptions {
                 num_signatures_notified,
                 signatures_time,
             );
+            datapoint_info!(
+                "rpc_subscriptions",
+                ("source", source.to_string(), String),
+                ("num_account_subscriptions", pubkeys.len(), i64),
+                ("num_account_pubkeys_notified", num_pubkeys_notified, i64),
+                ("accounts_time", accounts_time.as_us() as i64, i64),
+                ("num_program_subscriptions", programs.len(), i64),
+                ("num_programs_notified", num_programs_notified, i64),
+                ("programs_time", programs_time.as_us() as i64, i64),
+                ("num_signature_subscriptions", signatures.len(), i64),
+                ("num_signatures_notified", num_signatures_notified, i64),
+                ("signatures_time", signatures_time.as_us() as i64, i64)
+            );
         }
     }